format

utils/mysql_db.py

@@ -49,50 +49,50 @@ class MysqlHelper:
         except Exception as e:
             print(f"get_values异常:{e}\n")
 
-@classmethod
-def update_values(cls, sql, params=None):
-    """
-    执行更新操作（INSERT/UPDATE/DELETE）
-    
-    参数:
-        sql: 要执行的SQL语句
-        params: SQL参数（可选，元组或字典）
-    
-    返回:
-        成功时返回影响的行数，失败返回None
-    """
-    connect = None
-    cursor = None
-    
-    try:
-        connect = cls.connect_mysql()
-        cursor = connect.cursor()
-        
-        # 执行SQL语句
-        if params:
-            affected_rows = cursor.execute(sql, params)
-        else:
-            affected_rows = cursor.execute(sql)
-        
-        connect.commit()
-        return affected_rows
+    @classmethod
+    def update_values(cls, sql, params=None):
+        """
+        执行更新操作（INSERT/UPDATE/DELETE）
         
-    except Exception as e:
-        logger.error(f"SQL执行失败: {e}")
-        logger.error(f"SQL语句: {sql}")
-        if params:
-            logger.error(f"参数: {params}")
+        参数:
+            sql: 要执行的SQL语句
+            params: SQL参数（可选，元组或字典）
         
-        if connect:
-            connect.rollback()
-        return None
+        返回:
+            成功时返回影响的行数，失败返回None
+        """
+        connect = None
+        cursor = None
         
-    finally:
-        # 确保资源关闭
-        if cursor:
-            cursor.close()
-        if connect:
-            connect.close()
+        try:
+            connect = cls.connect_mysql()
+            cursor = connect.cursor()
+            
+            # 执行SQL语句
+            if params:
+                affected_rows = cursor.execute(sql, params)
+            else:
+                affected_rows = cursor.execute(sql)
+            
+            connect.commit()
+            return affected_rows
+            
+        except Exception as e:
+            logger.error(f"SQL执行失败: {e}")
+            logger.error(f"SQL语句: {sql}")
+            if params:
+                logger.error(f"参数: {params}")
+            
+            if connect:
+                connect.rollback()
+            return None
+            
+        finally:
+            # 确保资源关闭
+            if cursor:
+                cursor.close()
+            if connect:
+                connect.close()