QueryGenerator.py 文件源码

def do_query(self,sql,cur,conn):
        rows_affected   = None
        e               = None
        row             = None
        w               = None
        with warnings.catch_warnings(record=True) as w:
            try:
                rows_affected = cur.execute(sql)
                row = self.__cur.fetchone()
            except MySQLdb.Error, e:
                #self.statistics.processError(e)
                #print self.name + " - An Error occured running query. %s" %e
                #print sql
                #print "----------------------------"
                if e[1] == 'MySQL server has gone away':
                    #print self.name + " - An Error occured running query. %s" %e
                    pass
                #print sql;
                #conn.send((rows_affected,e,w,row))
            except MySQLdb.ProgrammingError, e:
                print self.name + " - A ProgrammingError occured running query. %s" %e
                #print sql;
                #print "----------------end----------------"

        if conn != None:
            conn.send((rows_affected,e,w,row))
        else:
            return (rows_affected,e,w,row)