db_opreation.py 文件源码

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