在Python中获取pymysql.connect cursor.execute()块

Question

我有这个代码：

with DATAB.connect().execution_options(autocommit=True) as DB:
with DB.begin():
DataContainer = []
for chunk in pd.read_sql_query("SELECT id, plat_id FROM plats WHERE date_request >= '{}';".format(Previous_Date), con=DB, chunksize=10000):
DataContainer.append(chunk)
del chunk
gc.collect()
DataFrame = pd.concat(DataContainer, ignore_index=True)
DB.close()
DATAB.dispose()

我想从SQL查询中获得块，就像我在上面的代码中使用pymysql:所做的那样

Conn = pymysql.connect(user=Config[0], password=Config[1], host=Config[2], database=Config[3], charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
with Conn.cursor() as cursor:
cursor.execute() ??????
cursor.close() 
Conn.close()

Answer 1

您可以这样分页；

query = "select * from table order by id limit %d offset %d" % (chunksize, offset)
result_rows = cursor.execute(query)

放入一个循环，每次迭代将offset增加chunkSize。