封裝代碼骨架：

創(chuàng)建連接

創(chuàng)建游標(biāo)

執(zhí)行sql

try:# 獲取游標(biāo)對(duì)象# 調(diào)用游標(biāo)對(duì)象# 如果是 查詢：#返回所有數(shù)據(jù)# 否則：# 提交事務(wù)# 返回受影響的行數(shù) except:# 回滾事務(wù)# 拋出異常 finally:# 關(guān)閉游標(biāo)# 關(guān)閉連接

關(guān)閉游標(biāo)

關(guān)閉連接

封裝代碼骨架如下：

# 導(dǎo)包 import pymysql# 創(chuàng)建工具類 class DBUtil():# 創(chuàng)建連接@classmethoddef __get_conn(cls):pass# 獲取游標(biāo)@classmethoddef __get_cursor(cls):pass# 執(zhí)行sql@classmethoddef exe_sql(cls, sql):try:passexcept Exception as e:passfinally:pass# 關(guān)閉游標(biāo)@classmethoddef __close_cursor(cls):pass# 關(guān)閉連接@classmethoddef __close_conn(cls):pass

創(chuàng)建連接方法完整代碼：

# 導(dǎo)包 import pymysql# 創(chuàng)建工具類 class DBUtil():# 初始化__conn = None__cursor = None# 創(chuàng)建連接@classmethoddef __get_conn(cls):if cls.__conn is None:cls.__conn = pymysql.connect(host="localhost",port=3307,user="root",password="root",database="books")return cls.__conn# 獲取游標(biāo)@classmethoddef __get_cursor(cls):if cls.__cursor is None:cls.__cursor = cls.__get_conn().cursor()return cls.__cursor# 執(zhí)行sql@classmethoddef exe_sql(cls, sql):try:# 獲取游標(biāo)對(duì)象cursor = cls.__get_cursor()# 調(diào)用游標(biāo)對(duì)象的execute方法，執(zhí)行sqlcursor.execute(sql)# 如果是查詢if sql.split()[0].lower() == "select":# 返回所有數(shù)據(jù)return cursor.fetchall()# 否則：else:# 提交事務(wù)cls.__conn.commit()# 返回受影響的行數(shù)return cursor.rowcountexcept Exception as e:# 事務(wù)回滾cls.__conn.rollback()# 打印異常信息print(e)finally:# 關(guān)閉游標(biāo)cls.__close_cursor()# 關(guān)閉連接cls.__close_conn()# 關(guān)閉游標(biāo)@classmethoddef __close_cursor(cls):if cls.__cursor:cls.__cursor.close()cls.__cursor = None# 關(guān)閉連接@classmethoddef __close_conn(cls):if cls.__conn:cls.__conn.close()cls.__conn = None 創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的【数据库】pymysql数据库事务操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。