Dapper怎么获取自增ID Dapper插入数据后返回ID教程

Dapper插入后获取自增主键应优先使用数据库原生机制:SQL Server用OUTPUT INSERTED.Id,PostgreSQL用RETURNING id,MySQL用LAST_INSERT_ID()配合多语句;避免SCOPE_IDENTITY()和@@IDENTITY等不安全方式。

在使用 Dapper 插入数据后获取数据库自增主键(如 SQL Server 的 IDENTITY、MySQL 的 AUTO_INCREMENT 或 PostgreSQL 的 SERIAL),关键在于让数据库在插入时**直接返回新生成的 ID**,而不是再查一次。Dapper 本身不提供 ORM 式的“插入后自动赋值”功能,但通过合理写法可以轻松实现。

用 OUTPUT 或 RETURNING 获取刚插入的 ID(推荐)

这是最高效、线程安全的方式,避免了额外查询,也规避了并发插入时 ID 被其他操作干扰的风险。

  • SQL Server:用 OUTPUT INSERTED.Id

var sql = @"INSERT INTO Users (Name, Email) OUTPUT INSERTED.Id VALUES (@Name, @Email)";
var newId = connection.QuerySingle(sql, new { Name = "张三", Email = "zhang@example.com" });

  • PostgreSQL:用 RETURNING id

var sql = @"INSERT INTO users (name, email) VALUES (@Name, @Email) RETURNING id";
var newId = connection.QuerySingle(sql, new { Name = "李四", Email = "li@example.com" });

  • MySQL:需配合 LAST_INSERT_ID(),但注意它依赖连接会话(不能跨连接用),且必须在同一条命令中执行(可用多语句或存储过程封装);更稳妥做法是用 SELECT LAST_INSERT_ID() 紧跟 INSERT(Dapper 支持多语句)

var sql = @"INSERT INTO users (name, email) VALUES (@Name, @Email); SELECT LAST_INSERT_ID();";
var newId = connection.QuerySingle(sql, new { Name = "王五", Email = "wang@example.com" });

用 SCOPE_IDENTITY()(仅 SQL Server,慎用)

如果无法改写 INSERT 语句(比如已有复杂逻辑或触发器),可在插入后立即调用 SCOPE_IDENTITY()。但它只在**同一作用域和同一连接**下有效,且不如 OUTPUT 高效和安全。

connection.Execute("INSERT INTO Users (Name, Email) VALUES (@Name, @Email)", new { Name = "赵六", Email = "zhao@example.com" });
var newId = connection.QuerySingle("SELECT SCOPE_IDENTITY()");

⚠️ 注意:不要用 @@IDENTITY(可能被触发器影响),也不要跨连接/异步调用后读取。

实体类配合 QuerySingle 自动映射(可选优化)

如果你希望插入后直接得到完整对象(含新 ID),可以定义返回类型为实体,并让 SQL 返回整行:

var sql = @"INSERT INTO Users (Name, Email) OUTPUT INSERTED.* VALUES (@Name, @Email)";
var user = connection.QuerySingle(sql, new { Name = "孙七", Email = "sun@example.com" });
// user.Id 已自动填充

前提是你的 User 类有对应属性(如 public int Id { get; set; }),且列名匹配(Dapper 默认按名称映射)。

常见踩坑提醒

  • MySQL 中若启用了 NO_AUTO_VALUE_ON_ZERO 模式,可能影响 LAST_INSERT_ID() 行为
  • PostgreSQL 的 RETURNING 不支持多行插入后返回全部 ID(除非用 RETURNING * 配合批量插入语法扩展)
  • Dapper 的 Execute 方法只返回影响行数,**不会返回 ID**,别误用
  • 异步方法如 QuerySingleAsync 同样适用,记得 await

基本上就这些。核心就一条:优先用数据库原生的 OUTPUT / RETURNING / LAST_INSERT_ID() 机制,而不是插入后再查——既快又准。