封装代码骨架：

创建连接
创建游标
执行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数据库事务操作相关推荐

qt中mysql怎么支持事务_Qt踩坑之mysql数据库不支持事务操作?
文章已更新,最新地址:https://www.fearlazy.com/index.php/post/145.html 现象: 在调试数据库操作时发现还没commit数据已经插入表中,执行rollba ...
Entity Framework 4 数据事务操作
利用数据库链接进行事务操作 var db = ConnectionHelper.GetConn(ConnectionType.Write);//获取上下文 var conn = db.Connecti ...
DB-概念-数据库：数据库/Database
ylbtech-DB-概念-数据库:数据库/Database 数据库是以一定方式储存在一起.能与多个用户共享.具有尽可能小的冗余度.与应用程序彼此独立的数据集合,可视为电子化的文件柜--存储电子文件的 ...
python---django中orm的使用（5）数据库的基本操作(性能相关：select_related,和prefetch_related重点)（以及事务操作）...
################################################################## # PUBLIC METHODS THAT ALTER ATTRI ...
2.关于QT中数据库操作，简单数据库连接操作，数据库的增删改查，QSqlTableModel和QTableView，事务操作，关于QItemDelegate 代理
Linux下的qt安装,命令时:sudoapt-get install qt-sdk 安装mysql数据库,安装方法参考博客:http://blog.csdn.net/tototuzuoquan ...
【Java数据库】使用JDBC操作MySQL数据库、Batch批处理、事务的概念
MySQL 数据库的命令行操作登陆操作mysql -hlocalhost –uroot –p123456 退出操作exit 数据库操作建库:create database 库名; 卸载库:drop ...
python多线程读取数据库数据_python多线程操作MySQL数据库pymysql
python多线程操作MySQL数据库pymysql 项目中使用多线程操作数据库提示错误:pymysql.err.InterfaceError: (0, "),原因是pymysql的exec ...
使用JDBC进行数据库的事务操作(2)
本篇将讲诉如何使用JDBC进行数据库有关事务的操作.在上一篇博客中已经介绍了事务的概念,和在MySQL命令行窗口进行开启事务,提交事务以及回滚事务的操作. 似乎事务和批处理都可以一次同时执行多条SQL ...
第二百七十九节，MySQL数据库-pymysql模块操作数据库
MySQL数据库-pymysql模块操作数据库 pymysql模块是python操作数据库的一个模块 connect()创建数据库链接,参数是连接数据库需要的连接参数使用方式: 模块名称.conne ...
数据库新增幂等操作_使用数据库唯一键实现事务幂等性
幂等性概念在分布式系统中,幂等性是一致性方面的一个重要概念. 幂等(idempotent.idempotence)是一个数学与计算机学概念,常见于抽象代数中. 在编程中一个幂等操作的特点是其任意多 ...

【数据库】pymysql数据库事务操作

封装代码骨架：

【数据库】pymysql数据库事务操作相关推荐

最新文章

热门文章