处理中………………
”：如何解决数据库事务问题？ ” />
python3 程序报错
在执行一段业务代码时，出现 “
处理中………………
” 的错误提示。
经过排查，发现代码中的数据库操作部分有问题，具体代码如下：
import requests import time import json import pymysql mydb = pymysql.connect( host="92.68.40.12", port=3306, user="root", password="iss_root", database="dynamic_premium_db" ) mycursor = mydb.cursor() def excute_sql_db(stratagy_id, city_id, app_name, total_price, over_flow_price, date_time): sql = "insert into over_flow_price(straragy_id,city_id,app_name,total_price,over_flow_price,time_stamp)values('%s','%s','%s','%s','%s','%s')" % (stratagy_id, city_id, app_name, total_price, over_flow_price, date_time) mycursor.execute(sql) # 报错行
解决方案：
立即学习“Python免费学习笔记（深入）”；
通过仔细分析代码，发现代码中缺少对数据库事务的处理。在数据库操作中，特别是涉及到多个表的操作时，需要使用事务来保证数据的完整性。
修改后的代码如下：
def excute_sql_db(stratagy_id, city_id, app_name, total_price, over_flow_price, date_time): sql = "INSERT INTO over_flow_price(straragy_id,city_id,app_name,total_price,over_flow_price,time_stamp)VALUES('%s','%s','%s','%s','%s','%s')" % (stratagy_id, city_id, app_name, total_price, over_flow_price, date_time) try: mycursor.execute(sql) mydb.commit() # 提交事务 print('插入成功') except Exception as e: mydb.rollback() # 回滚事务 print('err: ' + sql) print(e)
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
