SQLAlchemy 1.4中engine.connect()行为与文档不符的原因咨询

核心原因 #

1. MySQL的DDL自动提交特性 #

MySQL中所有DDL语句（如CREATE TABLE）会强制触发事务提交，无论当前事务状态如何。你第一个代码块执行建表操作后，不仅提交了建表的事务，还可能让MySQL连接自动进入autocommit模式（默认配置下），后续的INSERT操作在该模式下会自动提交，因此无需显式调用commit()就能查询到数据。

2. SQLAlchemy 1.4的API变更 #

你使用的1.4.13是2.0版本的过渡版本，事务控制逻辑发生了关键变化：

• 旧版本中engine.connect()返回的连接对象自带commit()方法，但1.4的新Connection类（sqlalchemy.engine.Connection）的事务需要通过begin()上下文管理器显式开启。
• 默认情况下，with engine.connect()的上下文会以自动提交模式执行语句，所有非事务内的操作都会自动提交，这也是INSERT生效的直接原因。
• 若未开启事务就直接调用conn.commit()，会触发AttributeError——因为此时没有活跃事务可供提交。

验证与修正方案 #

验证自动提交状态 #

可以打印当前连接的自动提交配置：

from sqlalchemy import create_engine, text

mysql_engine = create_engine("mysql+pymysql://user:password@host/test")
with mysql_engine.connect() as conn:
    print(conn.execution_options.get("autocommit"))  # 通常输出True

正确的事务控制方式 #

方式1：显式开启事务上下文

手动控制事务提交/回滚：

with mysql_engine.connect() as conn:
    with conn.begin() as tx:
        # 事务内的操作需手动提交（或由with块自动提交）
        conn.execute(text("insert into test.test_commit(x, y) VALUES(3, 4)"))
        # 若无需手动干预，with块结束时会自动提交，异常则回滚

方式2：直接使用engine.begin()

自动处理事务生命周期：

# 无需手动commit，with块结束自动提交，异常自动回滚
with mysql_engine.begin() as conn:
    conn.execute(text("insert into test.test_commit(x, y) VALUES(5, 6)"))

方式3：全局关闭自动提交

创建engine时禁用默认自动提交：

mysql_engine = create_engine("mysql+pymysql://user:password@host/test", autocommit=False)

此时必须显式开启事务并提交：

with mysql_engine.connect() as conn:
    tx = conn.begin()
    try:
        conn.execute(text("insert into test.test_commit(x, y) VALUES(7, 8)"))
        tx.commit()
    except Exception:
        tx.rollback()
        raise

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