# 封裝數據庫操作
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