Dapper怎么实现异步事务 Dapper异步Transaction用法
发布时间:2025-12-16 11:09
发布者:网络
浏览次数: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 包裹业务逻辑,出异常时回滚。
Project IDX
Google推出的一个实验性的AI辅助开发平台
166
查看详情
- 未调用 CommitAsync → 数据不会持久化(即使连接关闭,事务也会自动回滚)
- 未捕获异常导致 RollbackAsync 被跳过 → 可能造成连接挂起或数据不一致
- 建议配合
using或try/finally确保事务终态被处理
4. 完整示例(SQL Server)
(注意:实际项目中建议封装为 service 方法或使用 UnitOfWork 模式)
using var conn = new SqlConnection(connectionString);
await conn.OpenAsync();
<p>using var transaction = await conn.BeginTransactionAsync();</p><p>try
{
await conn.ExecuteAsync("INSERT INTO Orders (...) VALUES (...)", order, transaction);
await conn.ExecuteAsync("UPDATE Products SET Stock = Stock - @Qty WHERE Id = @Pid", stockParam, transaction);</p><pre class="brush:php;toolbar:false;">await transaction.CommitAsync();} catch { await transaction.RollbackAsync(); throw; }
基本上就这些。Dapper 异步事务不是魔法,核心就是「一个连接 + 一个开启的异步事务 + 所有操作显式传参 + 显式提交或回滚」。不复杂但容易忽略 transaction 参数传递这一步。
以上就是Dapper怎么实现异步事务 Dapper异步Transaction用法的详细内容,更多请关注其它相关文章!
# app
# ai
# nas
# .net
# 有哪些
# 你在
# 发展趋势
# 游戏开发
# 新特性
# 未来
# 都有
# 也会
# 多个
# 帮你
# 池州关键词快速排名
# 精灵seo破解
# se0网站关键词优化
# seo淘宝客怎么入驻
# 汾阳seo服务
# 柳州seo优化优势
# seo白帽优化和黑帽优化
# seo陆金手指专业二四
# 互联网垃圾分类营销推广
# 招商推广营销话术





conn.ExecuteAsync(sql, param)