python - 如果使用长查询，pymysql 将返回错误

Question

使用以下代码，如果我使用长查询，则会收到错误。我给出的查询大小有限制吗？

抱歉，但我无法分享我正在传递的确切查询。如果在 MySQL Workbench 中给出相同的查询，则数据将正确返回。任何建议将不胜感激。

我的代码:

import pymysql.cursors
import pymysql
import pandas as pd


connection = pymysql.connect(host = host,
                       user = user,
                       db = db,
                       password = password,
                        port = port)

def sql_to_df(sql_query):
    df = pd.read_sql(sql_query, connection)
    connection.close()
    return df

query = '''long query'''

#use pandas to pass SQL query
df = sql_to_df(query)    
df.head()

返回此错误:

    497             sql, index_col=index_col, params=params,
    498             coerce_float=coerce_float, parse_dates=parse_dates,
--> 499             chunksize=chunksize)
    500 
    501     try:

   1602         if chunksize is not None:

TypeError: 'NoneType' object is not iterable

Answer 1

def sql_to_df(sql_query):
     df = pd.read_sql(sql_query, connection)
     connection.close()
     return df

query = '''long query'''

#use pandas to pass SQL query
df = sql_to_df(query)    
df.head()

你只需要下面..

df = pd.read_sql(query, connection) 
connection.close()
df.head()