Browse Source

mysql_db: 增加修改sql执行方法

Signed-off-by: binren <zhangbr@elab-plus.com>
binren 5 years ago
parent
commit
cca4a15fbe
1 changed files with 11 additions and 0 deletions
  1. 11 0
      mysql_db.py

+ 11 - 0
mysql_db.py

@@ -30,6 +30,17 @@ class MysqlDB:
             self.cursor.execute(sql)
         return self.cursor.fetchall()
 
+    def update(self, sql, params=None):
+        try:
+            if params:
+                self.cursor.execute(sql, params)
+            else:
+                self.cursor.execute(sql)
+            self.con.commit()
+        except Exception as e:
+            print(e)
+            self.con.rollback()
+
     def delete(self, sql):
         try:
             self.cursor.execute(sql)