|
@@ -44,6 +44,8 @@ class MysqlDB(Database):
|
|
self._lock.acquire() # 上锁
|
|
self._lock.acquire() # 上锁
|
|
self._cursor.execute(sql)
|
|
self._cursor.execute(sql)
|
|
except pymysql.MySQLError:
|
|
except pymysql.MySQLError:
|
|
|
|
+ print(f"{sql}")
|
|
|
|
+ traceback.print_exc()
|
|
return None
|
|
return None
|
|
finally:
|
|
finally:
|
|
self._lock.release() # 释放锁
|
|
self._lock.release() # 释放锁
|
|
@@ -58,6 +60,7 @@ class MysqlDB(Database):
|
|
self._cursor.execute(sql)
|
|
self._cursor.execute(sql)
|
|
except pymysql.MySQLError:
|
|
except pymysql.MySQLError:
|
|
self._db.rollback()
|
|
self._db.rollback()
|
|
|
|
+ print(f"{sql}")
|
|
traceback.print_exc()
|
|
traceback.print_exc()
|
|
return None
|
|
return None
|
|
finally:
|
|
finally:
|
|
@@ -73,6 +76,8 @@ class MysqlDB(Database):
|
|
self._cursor.execute(sql)
|
|
self._cursor.execute(sql)
|
|
except pymysql.MySQLError:
|
|
except pymysql.MySQLError:
|
|
self._db.rollback()
|
|
self._db.rollback()
|
|
|
|
+ print(f"{sql}")
|
|
|
|
+ traceback.print_exc()
|
|
return None
|
|
return None
|
|
finally:
|
|
finally:
|
|
self._lock.release()
|
|
self._lock.release()
|
|
@@ -82,5 +87,7 @@ class MysqlDB(Database):
|
|
try:
|
|
try:
|
|
self._lock.acquire()
|
|
self._lock.acquire()
|
|
self._db.commit()
|
|
self._db.commit()
|
|
|
|
+ except pymysql.err:
|
|
|
|
+ traceback.print_exc()
|
|
finally:
|
|
finally:
|
|
self._lock.release()
|
|
self._lock.release()
|