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