# 封装数据库操作
def SELECT(db, cursor, sql):try:# 执行SQL语句db.ping(reconnect=True)cursor.execute(sql)# 获取所有记录列表results = cursor.fetchall()logging.debug("select commit")except:logging.error(sql)logging.error("select 语句执行出错")return ""return resultsdef UPDATE(db, cursor, sql):try:db.ping(reconnect=True)cursor.execute(sql)db.commit()logging.debug("update commit")except:db.ping(reconnect=True)db.rollback()logging.error(sql)logging.error("update rollback")return   def INSERT(db, cursor, sql):try:# 执行sql语句db.ping(reconnect=True)cursor.execute(sql)# 提交到数据库执行db.commit()logging.debug("insert commit")except:# 如果发生错误则回滚db.ping(reconnect=True)db.rollback() logging.error("insert rollback: " + sql)returndef DELETE(db, cursor, sql):try:# 执行SQL语句db.ping(reconnect=True)cursor.execute(sql)# 提交修改db.commit()logging.debug("delete commit")except:# 发生错误时回滚db.ping(reconnect=True)db.rollback()logging.error("delete rollback")returndef TRUNCATE(db, cursor, sql):try:# 执行SQL语句cursor.execute(sql)db.ping(reconnect=True)# 提交修改db.commit()logging.debug("truncate commit")except:# 发生错误时回滚db.ping(reconnect=True)db.rollback()logging.error("truncate rollback")return