Dapper的TransactionScope怎么用 Dapper分布式事务处理-C#.Net教程-PHP中文网

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

幻夢星雲

发布： 2025-12-18 00:01:08

原创

282人浏览过

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

dapper的transactionscope怎么用 dapper分布式事务处理

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>}

登录后复制

HIX Translate

由 ChatGPT 提供支持的智能AI翻译器

114

查看详情

隔离级别与超时控制

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

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

例如：

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

登录后复制