使用SQLAlchemy在for循环中执行INSERT语句异常问题排查

• 最常见的诱因是事务未显式提交：绝大多数Python数据库连接组件（包括SQLAlchemy、SingleStore官方Python驱动的默认配置）对于INSERT这类DML操作，默认关闭自动提交特性。你执行engine.execute()后没有主动提交事务，当连接被销毁时，未提交的事务会被直接回滚，因此数据库中不会残留操作记录，也不会抛出报错。
• 次要可能原因：你在循环中重复初始化引擎，没有显式管理连接生命周期，执行的操作随连接释放被回滚；如果你的SQL包含多段语句，部分引擎默认关闭多语句执行支持，只会运行第一段SQL，和你在编辑器中全量执行的效果不一致。

1. 显式管理事务提交（最稳妥方案） #

不要在循环中重复创建引擎，同时用上下文管理器管理连接、显式提交事务，参考修改后代码：

fh = 'file_containing_insert_select_query.sql'
qry = open(fh).read()
# 引擎初始化移到循环外，避免重复创建资源
engine = tls.custom_engine_function()

for i in range(2):
    qry_new = some_custom_function_to_replace_dates(qry, i)
    # 用上下文管理器获取连接，异常时自动回滚
    with engine.connect() as conn:
        exec_result = conn.execute(qry_new)
        # 显式提交事务
        conn.commit()
        # 可选：打印受影响行数验证执行效果
        print(f"第{i}次执行，插入行数：{exec_result.rowcount}")

2. 开启自动提交（适配简单场景） #

如果你的业务场景不需要严格的事务控制，可以在创建引擎时开启自动提交，无需手动调用commit：

• 若使用SQLAlchemy引擎：创建时添加参数execution_options={"autocommit": True}
• 若使用SingleStore原生驱动：连接参数中添加autocommit=True

3. 多语句场景适配 #

如果你的SQL文件包含多条用分号分隔的语句，需要在引擎连接配置中开启多语句执行支持，避免后续语句被忽略。

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