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 参数传递这一步。
以上就是Dapper怎么实现异步事务 Dapper异步Transaction用法的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1443172.html
微信扫一扫 
支付宝扫一扫 
