注意：
1、需要放到事务中，失败回滚
2、记得commit
3、结束后记得close连接
# -*- coding: utf-8 -*- import pymysql.cursors # 连接数据库 connect = pymysql.Connect( host=‘localhost‘, port=3310, user=‘user‘, passwd=‘123‘, db=‘test‘, charset=‘utf8‘ ) # 事务处理 sql_1 = "UPDATE staff SET saving = saving + 1000 WHERE user_id = ‘1001‘ " sql_2 = "UPDATE staff SET expend = expend + 1000 WHERE user_id = ‘1001‘ " sql_3 = "UPDATE staff SET income = income + 2000 WHERE user_id = ‘1001‘ " try: cursor.execute(sql_1) # 储蓄增加1000 cursor.execute(sql_2) # 支出增加1000 cursor.execute(sql_3) # 收入增加2000 except Exception as e: connect.rollback() # 事务回滚 print(‘事务处理失败‘, e) else: connect.commit() # 事务提交 print(‘事务处理成功‘, cursor.rowcount) # 关闭连接 cursor.close() connect.close()
原文：https://www.cnblogs.com/zyh0430/p/14764320.html
如果您也喜欢它,动动您的小指点个赞吧
602392714
清零编程群