不使用本地库,使用mariadb完成存储
This commit is contained in:
@@ -32,7 +32,7 @@ def write_to_db():
|
|||||||
with connection.cursor() as cursor:
|
with connection.cursor() as cursor:
|
||||||
# 插入消息信息
|
# 插入消息信息
|
||||||
sql = """
|
sql = """
|
||||||
INSERT OR REPLACE INTO speech_counts (group_id, wx_id, date, count) VALUES (%s, %s, %s, %s)
|
INSERT INTO speech_counts (group_id, wx_id, date, count) VALUES (%s, %s, %s, %s)
|
||||||
"""
|
"""
|
||||||
cursor.execute(sql, (group_id, wx_id, yesterday, count))
|
cursor.execute(sql, (group_id, wx_id, yesterday, count))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user