使用pymysql与pandas批量查询时遇'tuple to bytes'错误求助

这个错误的根源是你调用 pd.read_sql() 的方式不对——你把SQL语句和参数打包成了一个元组传给第一个参数，但 pd.read_sql() 要求第一个参数是纯SQL字符串，参数需要单独通过 params 参数传递，或者用正确的占位符逻辑传入，否则pymysql会把元组当成SQL内容解析，触发类型拼接错误。

错误代码分析 #

你原来的代码片段：

df = pd.read_sql(('SELECT * FROM anime LIMIT %s OFFSET %s', (batchsize,offset)), con=db)

这里你把SQL语句和参数组成的元组直接作为第一个参数传入，pymysql在处理时会尝试把这个元组当作SQL字符串去处理，进而抛出“无法将元组和字节拼接”的错误。

正确的两种写法 #

方法1：使用 params 参数（推荐，避免SQL注入）

这是最安全规范的写法，把SQL字符串和参数分开传递，pd.read_sql() 会自动安全地将参数注入到SQL语句中：

df = pd.read_sql('SELECT * FROM anime LIMIT %s OFFSET %s', con=db, params=(batchsize, offset))

这种方式既解决了类型错误，又能防止SQL注入风险，适合生产环境使用。

方法2：字符串格式化（不推荐，存在安全风险）

如果只是测试场景，你也可以用字符串格式化直接拼接参数，但注意这种方式如果参数来自用户输入，会有SQL注入的危险：

df = pd.read_sql(f'SELECT * FROM anime LIMIT {batchsize} OFFSET {offset}', con=db)

完整修正后的代码 #

import pymysql
import pandas as pd

# 假设你已提前定义好host、db_name、user、password参数
db = pymysql.connect(host=host, database=db_name, user=user, password=password)
batchsize = 100

for offset in range(0, 1000, batchsize):
    # 使用推荐的params参数方式
    df = pd.read_sql('SELECT * FROM anime LIMIT %s OFFSET %s', con=db, params=(batchsize, offset))
    print("rows and columns: ", df.shape)

# 记得关闭数据库连接，避免资源泄漏
db.close()

内容的提问来源于stack exchange，提问作者Abdul Quddus