# 封装数据库操作
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 results
def 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)
return
def 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")
return
def 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