|
|
@@ -1,3 +1,4 @@
|
|
|
+import time
|
|
|
import traceback
|
|
|
|
|
|
from db_helper import MysqlHelper
|
|
|
@@ -80,9 +81,11 @@ def update_wechat_score_data(data):
|
|
|
if len(insert_temp_data) > 0:
|
|
|
insert_sql_values = ', '.join([f"({item['word_id']}, {item['score']}, '{item['score_date']}')"
|
|
|
for item in insert_temp_data])
|
|
|
+ insert_start_time = time.time()
|
|
|
insert_sql = f"insert into word.word_wechat_score (word_id, wechat_score, score_date) " \
|
|
|
f"values {insert_sql_values};"
|
|
|
mysql_helper.add_data(sql=insert_sql)
|
|
|
+ log_.info(f"insert executeTime: {(time.time() - insert_start_time) * 1000}")
|
|
|
log_.info(f"insert wechat score data finished! insert count = {len(insert_data)}")
|
|
|
|
|
|
# 批量更新
|
|
|
@@ -93,6 +96,7 @@ def update_wechat_score_data(data):
|
|
|
if len(update_temp_data) > 0:
|
|
|
update_id = [item['id'] for item in update_temp_data]
|
|
|
update_sql_values = ' '.join([f"when {item['id']} then {item['score']}" for item in update_temp_data])
|
|
|
+ update_start_time = time.time()
|
|
|
if len(update_id) > 1:
|
|
|
update_sql = f"update word.word_wechat_score set wechat_score = " \
|
|
|
f"case id {update_sql_values} end where id in {tuple(update_id)};"
|
|
|
@@ -100,6 +104,7 @@ def update_wechat_score_data(data):
|
|
|
update_sql = f"update word.word_wechat_score set wechat_score = " \
|
|
|
f"case id {update_sql_values} end where id in ({update_id[0]});"
|
|
|
mysql_helper.add_data(sql=update_sql)
|
|
|
+ log_.info(f"update executeTime: {(time.time() - update_start_time) * 1000}")
|
|
|
log_.info(f"update wechat score data finished! update count = {len(update_data)}")
|
|
|
|
|
|
|
