封裝代碼骨架：

創建連接

創建游標

執行sql

try:# 獲取游標對象# 調用游標對象# 如果是 查詢：#返回所有數據# 否則：# 提交事務# 返回受影響的行數 except:# 回滾事務# 拋出異常 finally:# 關閉游標# 關閉連接

關閉游標

關閉連接

封裝代碼骨架如下：

# 導包 import pymysql# 創建工具類 class DBUtil():# 創建連接@classmethoddef __get_conn(cls):pass# 獲取游標@classmethoddef __get_cursor(cls):pass# 執行sql@classmethoddef exe_sql(cls, sql):try:passexcept Exception as e:passfinally:pass# 關閉游標@classmethoddef __close_cursor(cls):pass# 關閉連接@classmethoddef __close_conn(cls):pass

創建連接方法完整代碼：

# 導包 import pymysql# 創建工具類 class DBUtil():# 初始化__conn = None__cursor = None# 創建連接@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# 獲取游標@classmethoddef __get_cursor(cls):if cls.__cursor is None:cls.__cursor = cls.__get_conn().cursor()return cls.__cursor# 執行sql@classmethoddef exe_sql(cls, sql):try:# 獲取游標對象cursor = cls.__get_cursor()# 調用游標對象的execute方法，執行sqlcursor.execute(sql)# 如果是查詢if sql.split()[0].lower() == "select":# 返回所有數據return cursor.fetchall()# 否則：else:# 提交事務cls.__conn.commit()# 返回受影響的行數return cursor.rowcountexcept Exception as e:# 事務回滾cls.__conn.rollback()# 打印異常信息print(e)finally:# 關閉游標cls.__close_cursor()# 關閉連接cls.__close_conn()# 關閉游標@classmethoddef __close_cursor(cls):if cls.__cursor:cls.__cursor.close()cls.__cursor = None# 關閉連接@classmethoddef __close_conn(cls):if cls.__conn:cls.__conn.close()cls.__conn = None 創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。