def execute(self, sql):
"""
??SQL??
:param sql: SQL??
:return: ??SQL????????
"""
result = None
if self.db_lock.acquire():
try:
self.cursor.execute(sql)
result = self.cursor.fetchall()
except MySQLdb.Error, e:
if e.args[0] == 2013 or e.args[0] == 2006: # ??????????
self.db_lock.release()
self.db_connect()
print ('??,???????')
result = self.execute(sql) # ????
self.db_lock.acquire()
else:
print ('execute error:' + str(e))
print ('SQL : ' + sql)
self.db_lock.release()
return result if result else None
评论列表
文章目录