Python批量执行sql语句

注意:
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()

Python批量执行sql语句

上一篇:Jmeter之连接数据库


下一篇:烂泥:kvm安装windows系统蓝屏