Dapper的TransactionScope怎么用 Dapper分布式事务处理

TransactionScope 是 Dapper 实现跨库事务的核心机制，基于 System.Transactions 自动协调本地或分布式事务；需在打开连接前创建作用域，所有操作在同 Scope 内完成，调用 Complete() 提交，否则自动回滚。

TransactionScope 是 Dapper 实现跨数据库、跨连接事务最常用的方式，尤其适合分布式场景。它不依赖具体数据库连接的生命周期，而是由 .NET 的 System.Transactions 框架统一协调，自动适配本地事务或升级为 MSDTC 分布式事务。

TransactionScope 基本用法（单库/多库通用）

核心要点：事务范围必须在打开连接之前创建，且所有数据库操作需在同一个 Scope 内完成。

• 使用 new TransactionScope() 创建作用域，无需手动管理 Commit/Rollback
• 调用 scope.Complete() 表示成功，未调用则自动回滚
• 每个 SqlConnection 必须在 Scope 内新建并打开，不能复用已存在的连接
• 连接字符串中默认开启自动登记（Enlist=true），无需额外配置

跨两个数据库的分布式事务示例

比如订单写入 OrderDB，同时扣减库存写入 InventoryDB：

注意：此场景下，.NET 会自动将事务升级为分布式事务（需 MSDTC 启用或支持轻量级升级的 SQL Server 版本）

• 先启动 TransactionScope，再分别创建两个不同数据库的连接
• 两个连接执行各自 SQL，都传入参数但不传 transaction 对象（由 Scope 自动绑定）
• 全部成功后调用 Complete()；任一异常未调用，则整个事务回滚

示例代码片段：

using (var scope = new TransactionScope())<br>{<br>  using (var orderConn = new SqlConnection("OrderDB"))<br>  {<br>    orderConn.Open();<br>    orderConn.Execute("INSERT INTO Orders...");<br>  }<br>  using (var invConn = new SqlConnection("InventoryDB"))<br>  {<br>    invConn.Open();<br>    invConn.Execute("UPDATE Stock SET Qty -= @n WHERE Id = @id...");<br>  }<br>  scope.Complete(); // 缺少这句 → 全部回滚<br>}

登录后复制

标签： app 作用域 .net