db_opreation.py 文件源码

def execute_Iterator(self, sql, pretchNum=1000):
        """
        ??SQL??(??????)
        :param sql: SQL??
        :param pretchNum: ??????
        :return: ???
        """
        log_db.info('??:' + sql)
        Iterator_count = 0
        result = None
        result_list = []
        try:
                Resultnum = self.cursor.execute(sql)
                for i in range(Resultnum):
                    result = self.cursor.fetchone()
                    result_list.append(result)
                    Iterator_count += 1
                    if Iterator_count == pretchNum:
                        yield result_list
                        result_list = []
                        Iterator_count = 0
                yield result_list  # ????????
        except MySQLdb.Error, e:
                log_db.error('execute_Iterator error:' + str(e))
                log_db.error('SQL : ' + sql)