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

隔离级别与超时控制

TransactionScope 支持精细控制事务行为：

• 通过 TransactionOptions 设置 IsolationLevel（如 Serializable 防幻读）
• 可指定 Timeout（默认 60 秒），避免长时间挂起阻塞资源
• 建议显式声明，避免依赖数据库默认值导致行为不一致

例如：

var options = new TransactionOptions
{
  IsolationLevel = IsolationLevel.RepeatableRead,
  Timeout = TimeSpan.FromSeconds(30)using (var scope = new TransactionScope(TransactionScopeOption.Required, options))
{ ... }

分布式事务注意事项

不是所有环境都开箱即用，实际部署前需确认：

• SQL Server：确保 MSDTC 服务启用（Windows 环境），或使用支持轻量级升级的版本（如 SQL Server 2019+）
• Oracle / MySQL：原生不支持自动分布式事务，需改用 Saga、TCC 或消息队列补偿
• 连接字符串中不要加 Enlist=false，否则无法加入当前事务
• 避免在 Scope 内做耗时操作（如 HTTP 调用、文件 IO），防止事务长时间持有锁

基本上就这些。TransactionScope 对开发者最友好，但背后有协调成本，单库事务优先用 connection.BeginTransaction 更轻量。