推荐方式是ORM插入后调用session.flush()再访问obj.id,兼容所有支持自增主键的数据库;进阶方式用insert().returning()仅限PostgreSQL等支持RETURNING的数据库。

SQLAlchemy 提供了跨数据库兼容的方式,在插入记录后获取自增主键 ID,核心是利用 insert().returning()(较新版本)或更通用的 session.flush() + obj.id 模式。不同数据库对 RETURNING 的支持程度不同,需按需选择策略。
推荐方式:ORM 插入后直接访问实例属性(最兼容)
这是最简单、兼容性最好的方法,适用于所有支持自增主键的数据库(如 MySQL、PostgreSQL、SQLite、SQL Server):
- 使用 ORM 模型插入对象后,调用
session.flush()触发 SQL 执行但不提交;此时自增 ID 已由数据库生成并回填到对象属性中。 - 无需手动查询,也不依赖
RETURNING语法,完全由 SQLAlchemy 自动适配底层驱动行为。
示例:
from sqlalchemy.orm import sessionmaker from mymodels import Useruser = User(name="Alice", email="a@example.com") session.add(user) session.flush() # ✅ 关键:触发 INSERT,ID 已写入 user.id print(user.id) # ✅ 此时已有值(如 123)
后续可继续操作,最后 session.commit()
进阶方式:使用 insert().returning()(仅限支持 RETURNING 的数据库)
PostgreSQL 和最新版 SQLite(3.35+)、SQL Server(通过 OUTPUT)原生支持 RETURNING,可一条语句完成插入并取 ID,性能略优。MySQL **不支持** RETURNING,此方式会报错。
- 适用于明确只跑在 PostgreSQL 等环境的项目,或已做数据库判断的封装层。
- Core 层写法(非 ORM):
from sqlalchemy import insertstmt = insert(User).values(name="Bob", email="b@example.com").returning(User.id) result = session.execute(stmt) new_id = result.scalar_one() # ✅ 返回单个 ID 值
⚠️ 注意:ORM 模型不直接支持 .returning(),需用 Core 语句;且必须确保 dialect 支持(如 postgresql 或 mssql),否则运行时报错。
避免踩坑:不要用 lastrowid 或 execute(insert).lastrowid
手动调用底层 cursor 的 lastrowid 不仅破坏抽象,还存在严重兼容问题:
- SQLite 返回正确,MySQL 在某些驱动(如 PyMySQL)中返回
0或None; - PostgreSQL 需依赖
pg_get_serial_sequence等函数,无法通用; - 多线程/连接池下可能取到其他语句的 ID,极不可靠。
✅ 正确做法始终走 SQLAlchemy 的 flush / returning / commit 流程,由它协调 dialect 行为。
补充:批量插入后获取多个 ID(有限支持)
批量插入(session.bulk_save_objects())默认不填充 ID,因绕过了 ORM 生命周期。若需 ID:
- 改用
session.add_all()+flush():虽稍慢,但 ID 可用; - PostgreSQL 可用 Core 的
insert(...).returning()配合execute_many(需 SQLAlchemy 2.0+); - MySQL 无原生批量 RETURNING,只能逐条 flush 或事后查最大 ID 范围(不推荐,有竞态风险)。










