0
点赞
收藏
分享

微信扫一扫

python:封装CRUD操作

# 封装数据库操作
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


举报

相关推荐

0 条评论