Dapper怎么实现异步事务 Dapper异步Transaction用法

Dapper异步事务需显式使用ADO.NET的BeginTransactionAsync创建事务，并将同一SqlTransaction实例传给所有Dapper异步方法（如ExecuteAsync、QueryAsync），最后调用CommitAsync或RollbackAsync完成控制。

Dapper 本身不直接管理事务，它依赖 ADO.NET 的 SqlTransaction（或其他数据库对应的 Transaction 类型）来实现事务控制。所谓“Dapper 异步事务”，其实是使用支持异步的 ADO.NET API（如 BeginTransactionAsync、CommitAsync、RollbackAsync）配合 Dapper 的异步方法（如 ExecuteAsync、QueryAsync）来完成——关键在于把同一个 SqlTransaction 实例显式传给每个 Dapper 调用。

1. 使用 BeginTransactionAsync 创建异步事务

在打开连接后，调用 connection.BeginTransactionAsync() 获取事务对象。注意：必须确保连接已打开（Dapper 不会自动帮你打开），且事务生命周期与连接绑定。

连接需手动 OpenAsync()，否则抛异常
事务对象要保存下来，后续所有 Dapper 操作都需传入它
不要在 using 块里提前释放连接或事务，否则可能引发“连接已关闭”错误

2. 所有 Dapper 异步操作必须显式传入 transaction 参数

Dapper 的异步方法（如 ExecuteAsync、QueryFirstOrDefaultAsync）都有重载支持传入 IDbTransaction。漏传就等于没走事务——它会走默认的自动提交模式。

正确写法：conn.ExecuteAsync(sql, param, transaction)
错误写法：conn.ExecuteAsync(sql, param)（脱离事务上下文）
多个操作共用同一个 transaction 实例，才能保证原子性

3. 手动控制 CommitAsync / RollbackAsync

事务结束后，必须显式调用 transaction.CommitAsync() 或 transaction.RollbackAsync()。推荐用 try/catch 包裹业务逻辑，出异常时回滚。

未调用 CommitAsync → 数据不会持久化（即使连接关闭，事务也会自动回滚）
未捕获异常导致 RollbackAsync 被跳过 → 可能造成连接挂起或数据不一致
建议配合 using 或 try/finally 确保事务终态被处理

4. 完整示例（SQL Server）

（注意：实际项目中建议封装为 service 方法或使用 UnitOfWork 模式）

using var conn = new SqlConnection(connectionString); await conn.OpenAsync();

using var transaction = await conn.BeginTransactionAsync();

try { await conn.ExecuteAsync("INSERT INTO Orders (...) VALUES (...)", order, transaction); await conn.ExecuteAsync("UPDATE Products SET Stock = Stock - @Qty WHERE Id = @Pid", stockParam, transaction);

await transaction.CommitAsync();

} catch { await transaction.RollbackAsync(); throw; }

基本上就这些。Dapper 异步事务不是魔法，核心就是「一个连接 + 一个开启的异步事务 + 所有操作显式传参 + 显式提交或回滚」。不复杂但容易忽略 transaction 参数传递这一步。

# app # ai # nas # .net # sql # 封装 # try # throw # catch # using # finally # 对象 # 异步 # 数据库 # 都有 # 也会 # 多个 # 帮你 # 并将 # 或其他 # 它会 # 来实现 # 来完成 # 绑定

返回目录在线咨询

上一篇：如何创建一个吸引人的WordPress首页设计？
下一篇：北京建站哪家好：如何确保网站的SEO优化效果？

您的项目需求