Dapper通过ExecuteAsync等扩展方法支持异步增删改操作,底层封装IDbConnection的异步实现,需确保驱动支持、连接已打开并正确异常处理。

Dapper 本身不直接提供异步的 ExecuteAsync 方法(比如 ExecuteAsync 对应原生 ADO.NET 的 ExecuteNonQueryAsync),但它通过扩展方法支持异步执行增删改操作——关键在于使用 IDbConnection 的异步方法,并配合 Dapper 的扩展方法,如 ExecuteAsync、QueryAsync、QueryFirstOrDefaultAsync 等。
Dapper ExecuteAsync 异步执行原理
Dapper 的 ExecuteAsync 是对 ADO.NET IDbConnection.ExecuteAsync 的封装(实际调用的是底层 provider 的异步实现,如 SqlClient 的 SqlCommand.ExecuteNonQueryAsync)。它适用于 INSERT/UPDATE/DELETE 语句,返回影响行数(int),且不会映射结果集。
要使用它,需确保:
- 数据库驱动支持异步(如 Microsoft.Data.SqlClient 或较新版本的 System.Data.SqlClient)
- 连接字符串启用异步(SqlClient 默认支持,无需额外配置)
- 方法标记为
async,调用时用await
Dapper 异步插入(INSERT)示例
使用 ExecuteAsync 执行带参数的插入语句,推荐用匿名对象或强类型模型传参:
var sql = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email);";
var user = new { Name = "张三", Email = "zhang@example.com" };
int rows = await connection.ExecuteAsync(sql, user); // 返回 1(成功插入一行)
若需获取自增 ID,可改用 QuerySingleAsync 或 QueryFirstOrDefaultAsync 配合 SELECT SCOPE_IDENTITY():
var sql = @"
INSERT INTO Users (Name, Email) VALUES (@Name, @Email);
SELECT CAST(SCOPE_IDENTITY() AS INT);";
int newId = await connection.QuerySingleAsync(sql, user);
Dapper 异步更新与删除(UPDATE/DELETE)
语法结构一致,只需更换 SQL 语句和参数:
// 异步更新
var updateSql = "UPDATE Users SET Email = @Email WHERE Id = @Id;";
int updated = await connection.ExecuteAsync(updateSql, new { Email = "new@ex.com", Id = 123 });
// 异步删除
var deleteSql = "DELETE FROM Users WHERE Id = @Id;";
int deleted = await connection.ExecuteAsync(deleteSql, new { Id = 123 });
注意:Dapper 不校验 SQL 类型,ExecuteAsync 对任何非查询语句都适用,但务必确保参数化以防止 SQL 注入。
常见问题与注意事项
执行失败时会抛出异常(如连接中断、超时、约束冲突),建议配合 try/catch 和超时控制:
- 连接需在调用前已打开(
await connection.OpenAsync()) - 避免在同步方法中混用
await(会导致死锁,尤其在 ASP.NET Core 以外环境) - 批量操作慎用
ExecuteAsync单条循环;高并发场景考虑Transaction+ 批量 SQL 或 Dapper.FastCrud 等扩展 - EF Core 用户注意:Dapper 不参与 EF 的变更跟踪,纯 SQL 操作独立生效
基本上就这些。Dapper 的异步增删改不复杂但容易忽略连接状态和异常处理,写对了效率和响应性提升明显。










