mysql.connector迭代游标时执行新查询触发InternalError问题咨询

错误原因 #

这是MySQL协议的硬性限制：同一数据库连接下，只能同时存在一个活跃的结果集。你正在迭代的主游标（处理百万行数据的那个）还有大量未读取的行，此时整个连接被这个未完成的结果集占用，哪怕创建新游标，也无法在同一连接上执行新查询——这就是触发mysql.connector.errors.InternalError: Unread result found的根本原因，和游标数量无关，核心是连接的单活跃查询约束。

解决方案 #

针对你的百万行数据场景，推荐两种可行方案：

方案1：先提取所需ID到内存，再执行后续查询

如果仅需提取每行的ID，百万个ID的内存占用通常远小于全量数据（比如每个ID是8字节的bigint，百万行仅约8MB），可以先把所有ID读取到列表，关闭主游标后再用同一连接执行子查询：

import mysql.connector

# 初始化主连接与游标
conn = mysql.connector.connect(host="your_host", user="user", password="pwd", database="db")
main_cursor = conn.cursor(dictionary=True)
main_cursor.execute("SELECT id FROM large_table")

# 提取所有ID至列表
id_list = [row["id"] for row in main_cursor]
main_cursor.close()  # 关闭主游标，释放连接占用

# 用同一连接执行子查询
sub_cursor = conn.cursor(dictionary=True)
for target_id in id_list:
    sub_cursor.execute("SELECT * FROM other_table WHERE id = %s", (target_id,))
    result = sub_cursor.fetchone()
    # 处理查询结果

# 清理资源
sub_cursor.close()
conn.close()

方案2：创建独立连接处理子查询

如果ID数量极大，连ID列表都占内存，直接新建一个独立连接专门执行子查询，两个连接各自处理自己的结果集，互不干扰：

import mysql.connector

# 主连接：处理百万行数据的迭代
main_conn = mysql.connector.connect(host="your_host", user="user", password="pwd", database="db")
main_cursor = main_conn.cursor(dictionary=True)
main_cursor.execute("SELECT id FROM large_table")

# 子连接：专门执行后续查询
sub_conn = mysql.connector.connect(host="your_host", user="user", password="pwd", database="db")
sub_cursor = sub_conn.cursor(dictionary=True)

# 迭代主游标，同时用子连接查询
for row in main_cursor:
    sub_cursor.execute("SELECT * FROM other_table WHERE id = %s", (row["id"],))
    sub_result = sub_cursor.fetchone()
    # 处理sub_result

# 清理所有资源
main_cursor.close()
main_conn.close()
sub_cursor.close()
sub_conn.close()

对你疑问的直接回应 #

• 为何不同游标仍报错？因为同一连接被未完成的主结果集占用，MySQL协议不允许同一连接同时处理两个未完成的查询，和游标数量无关。
• 是否因复用同一连接导致？是的，这就是问题的核心。
• 是否需要创建新连接？是可行的解决方案之一，尤其适合大数据量场景；如果ID列表内存可承受，也可以采用方案1复用同一连接。

内容的提问来源于stack exchange，提问作者64rl0