TransactionScope的使用

编程入门行业动态更新时间:2024-10-22 09:41:03

TransactionScope的使用

简介
- 1. 命名空间
- 2.创建事务范围
- 3.嵌套事务
- 4.事务提交和回滚
- 5.支持分布式事务
- 6.配置选项
- 7.资源管理器
- 8.分布式事务协调器
应用
- 1.未设置分布式事务
- 2.设置分布式事务

简介

TransactionScope 是 .NET Framework 和 .NET Core 中的一个类，用于简化事务管理。它提供了一种简单的方式来创建分布式事务和本地事务，以确保一系列操作要么全部成功提交，要么全部回滚，以保持数据的一致性

1. 命名空间

在代码中使用 TransactionScope 时，需要导入以下命名空间：

using System.Transactions;

2.创建事务范围

要使用 TransactionScope，您可以通过创建一个新的 TransactionScope 对象来定义一个事务范围。这个事务范围将包裹一系列数据库或其他资源操作。

using (TransactionScope scope = new TransactionScope())
{// 在这里执行事务性操作
}

3.嵌套事务

您可以在代码中嵌套多个 TransactionScope 对象，形成多层嵌套的事务。在这种情况下，只有最外层的事务范围会影响整个事务。如果内部的事务范围失败，它们会自动回滚，而最外层的事务范围可以选择提交或回滚整个事务

4.事务提交和回滚

在 TransactionScope 中，如果代码成功执行，您可以调用 Complete() 方法来提交事务，确保所有操作都成功。如果在 TransactionScope 中发生异常或其他问题，事务将自动回滚，所有操作都将撤销。

5.支持分布式事务

TransactionScope 支持分布式事务，这意味着您可以在不同的数据库或资源上执行操作，并将它们包装在一个分布式事务中，以确保一致性。

6.配置选项

TransactionScope 允许您配置事务的选项，如超时时间、隔离级别等，以满足特定的业务需求。

7.资源管理器

TransactionScope 使用资源管理器来管理事务，这包括数据库、消息队列、文件系统等。每个资源管理器需要提供一个事务参与者，以便 TransactionScope 能够协调它们的事务。

8.分布式事务协调器

在分布式事务中，TransactionScope 使用分布式事务协调器（DTC）来协调事务。DTC 协调器确保所有事务参与者在提交或回滚时协调一致性。

应用

1.未设置分布式事务

现有数据

这里没有设置事务，且通过NetCore+EF实现的增删改查功能

  [HttpGet][Route("Transaction")]public async Task Transaction(int id){try{//using (System.Transactions.TransactionScope scope = new System.Transactions.TransactionScope())//{//增加Student_studentService.Add(new Student { Name = "DX", Address = "上城1", Sex = "男", Phone = "123456" });//获取指定Id的StudentStudent item = _studentService.GetById(id).Result;//更新数据_studentService.Upate(item);//删除数据_studentService.Delete(item);//抛出异常throw new Exception();//scope.Complete();//}}catch (ThreadAbortException ex){throw ex;}}

正常抛出异常

在不设置分布式事务的情况下，数据在抛出异常情况时，并未回滚操作，而是全部执行完成

2.设置分布式事务

   [HttpGet][Route("Transaction")]public async Task Transaction(int id){try{using (System.Transactions.TransactionScope scope = new System.Transactions.TransactionScope()){_studentService.Add(new Student { Name = "DX", Address = "上城1", Sex = "男", Phone = "123456" });Student item = _studentService.GetById(id).Result;_studentService.Upate(item);_studentService.Delete(item);throw new Exception();scope.Complete();}}catch (ThreadAbortException ex){throw ex;}}