Dapper如何执行异步ExecuteAsync Dapper异步增删改教程

来源:这里教程网 时间:2026-02-21 17:35:21 作者:

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<int>(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 的异步增删改不复杂但容易忽略连接状态和异常处理,写对了效率和响应性提升明显。

相关推荐