修复bug

2023-12-10 12:53:50 +08:00 · 2023-12-10 12:53:50 +08:00 · 90a4d135e2
commit 90a4d135e2
parent 01040f4f78
1 changed files with 10 additions and 6 deletions
--- a/pywxdump/wx_info/merge_db.py
+++ b/pywxdump/wx_info/merge_db.py
@ -189,12 +189,16 @@ def execute_sql(connection, sql, params=None):
        - sql：要执行的SQL语句
        - params：SQL语句中的参数
    """
-    cursor = connection.cursor()
-    if params:
-        cursor.execute(sql, params)
-    else:
-        cursor.execute(sql)
-    return cursor.fetchall()
+    try:
+        cursor = connection.cursor()
+        if params:
+            cursor.execute(sql, params)
+        else:
+            cursor.execute(sql)
+        return cursor.fetchall()
+    except Exception as e:
+        print(f"**********\nSQL: {sql}\nparams: {params}\n{e}\n**********")
+        return None