searchStat_index_data = self.s.post(url=sea_tr_url, headers=search_headers, data=data).text
if len(json.loads(searchStat_index_data)['data']) == 0:
print('搜索报表没有数据')
else:
print('进入搜索报表数据')
search_index_json_data = json.loads(searchStat_index_data)
account_id = id
report_date = (str)(search_index_json_data['data'][len(search_index_json_data['data']) - 1]['dt'])
print "report_date is "+report_date
json_data = search_index_json_data['data'][len(search_index_json_data['data']) - 1]
json_data = json.dumps(json_data)
id3 = "select id from oppo_feeds_stat_total_report where account_id =%d and report_date='%s';" % (
(int)(account_id), report_date)
self.cursor.execute(id3)
id3_result = self.cursor.fetchone()
if (id3_result == None):
sql1 = "insert into oppo_search_stat_total_report (account_id,report_date,json_data)values(%d,'%s','%s');" % (
(int)(account_id), report_date, json_data)
print sql1
self.cursor.execute(sql1)
try:
self.connection.commit()
except Exception as e:
self.connection.rollback()
else:
sql2 = "update oppo_search_stat_total_report set account_id=%d,report_date='%s',json_data='%s';" % (
(int)(account_id), report_date, json_data)
print sql2
self.cursor.execute(sql2)
try:
self.connection.commit()
except Exception as e:
self.connection.rollback()
我同时跑的两个脚本,两个脚本主键不一样,为啥会覆盖呢?希望大神指教,谢谢!