1个回答
test
2024-07-07
你这完全不需要事务啊回滚啊啥的
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)
try:
mycursor.execute(sql)
print('插入成功')
except Exception as e:
print('err: ' + sql)
print(e)
这样就行了
本文参与了SegmentFault 思否面试闯关挑战赛,欢迎正在阅读的你也加入。
回复
适合作为回答的
- 经过验证的有效解决办法
- 自己的经验指引,对解决问题有帮助
- 遵循 Markdown 语法排版,代码语义正确
不该作为回答的
- 询问内容细节或回复楼层
- 与题目无关的内容
- “赞”“顶”“同问”“看手册”“解决了没”等毫无意义的内容