SQLAlchemy无法完整执行存储过程，求解决办法

我使用以下Python代码执行SQL存储过程，该存储过程会遍历另一张表中的多条INSERT语句。但通过Python执行时，存储过程无法遍历完整数据集。
我已在SQL环境中测试该存储过程，运行正常；也曾尝试修改sql_engine连接的pool_timeout参数，但无任何效果。
如何确保下方代码能执行完整个存储过程？

import connection_manager as cm
from sqlalchemy import text

sql_engine = cm.create_db_engine('Server','Database')    

with sql_engine.connect() as conn:
    conn.execute(text("EXEC dbo.SomeStoredProcedure"))
    conn.commit()
    conn.close() 

可行解决方法 #

• 强制读取所有结果集
  部分存储过程执行时会返回多个结果集（比如每条INSERT操作返回影响行数），SQLAlchemy默认仅读取第一个结果集就终止流程，导致存储过程后续逻辑未执行。循环读取所有结果集即可解决：

  import connection_manager as cm
  from sqlalchemy import text
  
  sql_engine = cm.create_db_engine('Server','Database')    
  
  with sql_engine.connect() as conn:
      result = conn.execute(text("EXEC dbo.SomeStoredProcedure"))
      # 遍历所有结果集，确保存储过程执行完毕
      while result.nextset():
          pass
      conn.commit()
  

  注：with语句会自动管理连接生命周期，无需手动调用conn.close()

• 使用底层原生连接执行
  绕过SQLAlchemy的结果集处理逻辑，直接调用DBAPI原生连接执行：

  import connection_manager as cm
  
  sql_engine = cm.create_db_engine('Server','Database')    
  conn = sql_engine.raw_connection()
  try:
      cursor = conn.cursor()
      cursor.execute("EXEC dbo.SomeStoredProcedure")
      # 读取所有结果集
      while cursor.nextset():
          pass
      conn.commit()
  finally:
      conn.close()
  

• 检查存储过程错误处理逻辑
  确认存储过程中是否存在捕获错误但未抛出的逻辑，SQL交互环境可能自动处理这类静默错误，但Python执行时会直接中断流程。建议在存储过程末尾添加全局错误检查，确保所有遍历步骤都能完成。

• 调整SQLAlchemy执行参数
  尝试启用流式结果处理，避免结果集缓存导致的流程中断：

  with sql_engine.connect() as conn:
      result = conn.execute(text("EXEC dbo.SomeStoredProcedure"), execution_options={"stream_results": True})
      while result.nextset():
          pass
      conn.commit()
  

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