前言:
现在看官们对“mysql事务机制的实现”都比较重视,大家都需要剖析一些“mysql事务机制的实现”的相关知识。那么小编也在网络上收集了一些对于“mysql事务机制的实现””的相关资讯,希望我们能喜欢,我们一起来学习一下吧!一、应用场景Python项目对MySQL数据库进行增、删、改操作时,有时会出现执行sql异常的情况。在批量提交数据的时候,如果其中一个事务提交错误,往往导致预期的整个数据链不完整。例如银行转账数据,用户A向用户B转账,
步骤一:此时A的数据要存一份某个时间向B转账的数据。
步骤二:同时用户B也会存一份某个时间收到A转账的数据。
如果此时步骤一执行sql成功,步骤二出错并且未回滚事务,将会导致两边备份的数据校对错误。当引入事务时,步骤二出现错误,事务回滚后步骤一未执行,数据回归到出错前的情况,保证了数据的安全性。
二、使用方法配合我们之前文章提到的try的使用(Python之异常处理(try的基本用法)),还有上篇文章学到的mysql的基本操作(Python MySQL数据库连接)实现捕捉异常并且回滚。
try: cursor.execute(sql_1) cursor.execute(sql_2) cursor.execute(sql_3) except Exception as e: # 事务回滚 connect.rollback() print('事务处理失败', e)else: # 事务提交 connect.commit() print('事务处理成功', cursor.rowcount)
三、测试demo
事务出现错误demo
# -*- coding: utf-8 -*-"""@Time : 2022/1/27 17:34@Auth : 技术空间@File :rollback_demo.py@IDE :PyCharm@Motto:技术总是要日积月累的"""import pymysqlif __name__ == '__main__': db = pymysql.connect(host='localhost', user='root', password='root', database='others') cursor = db.cursor(pymysql.cursors.DictCursor) select_sql = " select id,name from user_info " cursor.execute(select_sql) data_list = cursor.fetchall() print("执行更新前的数据-->") print(data_list) try: update_sql1 = " update user_info set name='1我的头条号:code_space' where id = 1 " update_sql2 = " update user_info set name='2我的头条号:code_space' where id = 2 " # 数据库的name长度是20,这里长度超过了,会报Data too long错误 update_sql3 = " update user_info set name='测试测试测试测试测试测试测试测试测试测试测试测试' where id = 3 " cursor.execute(update_sql1) cursor.execute(update_sql2) cursor.execute(update_sql3) except Exception as e: # 事务回滚 db.rollback() print('事务处理失败', e) else: # 事务提交 db.commit() print('事务处理成功', cursor.rowcount) cursor.execute(select_sql) data_list = cursor.fetchall() print("执行更新后的数据-->") print(data_list) cursor.close() db.close()事务正确执行demo
# -*- coding: utf-8 -*-"""@Time : 2022/1/27 17:34@Auth : 技术空间@File :rollback_demo.py@IDE :PyCharm@Motto:技术总是要日积月累的"""import pymysqlif __name__ == '__main__': db = pymysql.connect(host='localhost', user='root', password='root', database='others') cursor = db.cursor(pymysql.cursors.DictCursor) select_sql = " select id,name from user_info " cursor.execute(select_sql) data_list = cursor.fetchall() print("执行更新前的数据-->") print(data_list) try: update_sql1 = " update user_info set name='1我的头条号:code_space' where id = 1 " update_sql2 = " update user_info set name='2我的头条号:code_space' where id = 2 " update_sql3 = " update user_info set name='3我的头条号:code_space' where id = 3 " cursor.execute(update_sql1) cursor.execute(update_sql2) cursor.execute(update_sql3) except Exception as e: # 事务回滚 db.rollback() print('事务处理失败', e) else: # 事务提交 db.commit() print('事务处理成功', cursor.rowcount) cursor.execute(select_sql) data_list = cursor.fetchall() print("执行更新后的数据-->") print(data_list) cursor.close() db.close()四、拓展
在处理事务过程中,往往涉及到批量执行sql语句的情况,比如批量提交订单、批量删除订单等。下篇文章我们将会讲解关于批量执行sql语句的代码,涉及到代码复用的重要操作。还请多多关注。
关注我,坚持每日积累一个技巧,长期坚持,我们将会不断进步。
#程序员##python##数据库##教育听我说##请回答,你的年度知识点#
标签: #mysql事务机制的实现