SQLAlchemy导入数据到MySQL触发未缓冲结果不完整警告如何解决

• 该警告本质是MySQL连接上存在未处理完成的无缓冲结果集：你给SELECT查询加了stream_results=True参数，这个参数会开启服务端无缓冲游标，查询结果不会一次性全部加载到客户端内存，需要逐次读取拉取。如果结果没被完全读取、也没显式关闭游标，连接就会处于被占用的状态，无法执行后续事务提交、新查询等操作。
• 你的代码中执行SELECT后仅打印了结果代理对象，既没有读取实际返回的行数据，也没有主动关闭结果游标，就进入了上下文管理器的事务提交流程，SQLAlchemy检测到残留的未完成无缓冲结果，就抛出该警告。
• 从日志输出顺序也能验证问题触发点：警告出现在结果对象打印之后、事务COMMIT日志之前，和未消费的流式查询触发时机完全匹配。

根据你的实际场景选一种即可：

• 方案1：不需要流式读取大结果集时，直接移除stream_results=True配置
  普通查询模式会在执行后自动把全量结果拉取到客户端缓冲区，不会残留未完成的无缓冲结果，注意主动调用结果获取方法消费结果即可：

  engine = create_engine('mysql+pymysql://root:root@localhost:3308/tms_local', echo=True)
  with engine.connect() as conn, conn.begin():
      book_df.to_sql(name='temporary_table', con=conn, if_exists='append', index=False)
      result = conn.execute(text("SELECT `Publisher` FROM temporary_table WHERE `Course Material Title` = 'StudyGuide';"))
      # 消费结果，按需使用fetchone/fetchall/all()等方法
      publishers = result.scalars().all()
      print(publishers)
  

• 方案2：确实需要流式查询（比如返回结果集过大，避免内存溢出）时，必须主动消费完结果或者显式关闭结果游标
  不要让未处理的流式结果残留在连接上：

  engine = create_engine('mysql+pymysql://root:root@localhost:3308/tms_local', echo=True)
  with engine.connect() as conn, conn.begin():
      book_df.to_sql(name='temporary_table', con=conn, if_exists='append', index=False)
      result = conn.execution_options(stream_results=True).execute(
          text("SELECT `Publisher` FROM temporary_table WHERE `Course Material Title` = 'StudyGuide';")
      )
      try:
          # 逐行消费流式结果
          for publisher in result.scalars():
              print(publisher)
      finally:
          # 处理完成后显式关闭结果，释放连接
          result.close()
  

• 额外注意：MySQL原生协议不支持同一连接同时持有多个未完成的结果集，如果需要在遍历流式结果的过程中执行其他增删改查操作，要么先把当前流式结果全部读取到本地，要么新建独立连接执行其他操作。

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