C#中回滚TransactionScope的使用方法和原理

摘要:
每当操作失败时,TransactionScope将自动回滚。完成意味着交易已完成。事实上,理解Complete()方法是提交事务是错误的。事实上,它用于指示事务已完成。它通常放在try{}的末尾。不需要判断前台操作是否成功。如果不成功,它将自动回滚。在的时代。net1.1,没有TransactionScope类,因此许多事务由SqlTrans处理
TransactionScope只要一个操作失败,它会自动回滚,Complete表示事务完成
 

实事上,一个错误的理解就是Complete()方法是提交事务的,这是错误的,事实上,它的作用的表示本事务完成,它一般放在try{}的结尾处,不用判断前台操作是否成功,如果不成功,它会自己回滚。

在.net 1.1的时代,还没有TransactionScope类,因此很多关于事务的处理,都交给了SqlTransaction和SqlConnection,每个Transaction是基于每个Connection的。这种设计对于跨越多个程序集或者多个方法的事务行为来说,不是非常好,需要把事务和数据库连接作为参数传入。

在.net 2.0后,TransactionScope类的出现,大大的简化了事务的设计。示例代码如下:

  1.  
    staticvoidMain(string[] args)
  2.  
    {
  3.  
    using (TransactionScope ts = new TransactionScope())
  4.  
    {
  5.  
    userBLL u = new userBLL();
  6.  
    TeacherBLL t = new TeacherBLL();
  7.  
    u.ADD();
  8.  
    t.ADD();
  9.  
    ts.Complete();
  10.  
    }
  11.  
    }

只需要把需要事务包裹的逻辑块写在using (TransactionScope ts = new TransactionScope())中就可以了。从这种写法可以看出,TransactionScope实现了IDispose接口。除非显示调用ts.Complete()方法。否则,系统不会自动提交这个事务。如果在代码运行退出这个block后,还未调用Complete(),那么事务自动回滚了。在这个事务块中,u.ADD()方法和t.ADD()方法内部都没有用到任何事务类。

TransactionScope是基于当前线程的,在当前线程中,调用Transaction.Current方法可以看到当前事务的信息。具体关于TransactionScope的使用方法,已经它的成员方法和属性,可以查看 MSDN 。

TransactionScope类是可以嵌套使用,如果要嵌套使用,需要在嵌套事务块中指定TransactionScopeOption参数。默认的这个参数为Required。

该参数的具体含义可以参考http://msdn.microsoft.com/zh-cn/library/system.transactions.transactionscopeoption(v=vs.80).aspx

比如下面代码:

  1.  
    staticvoidMain(string[] args)
  2.  
    {
  3.  
    using (TransactionScope ts = new TransactionScope())
  4.  
    {
  5.  
    Console.WriteLine(Transaction.Current.TransactionInformation.LocalIdentifier);
  6.  
    userBLL u = new userBLL();
  7.  
    TeacherBLL t = new TeacherBLL();
  8.  
    u.ADD();
  9.  
    using (TransactionScope ts2 = new TransactionScope(TransactionScopeOption.Required))
  10.  
    {
  11.  
    Console.WriteLine(Transaction.Current.TransactionInformation.LocalIdentifier);
  12.  
    t.ADD();
  13.  
    ts2.Complete();
  14.  
    }
  15.  
    ts.Complete();
  16.  
    }
  17.  
    }

当嵌套类的TransactionScope的TransactionScopeOption为Required的时候,则可以看到如下结果,他们的事务的ID都是同一个。并且,只有当2个TransactionScope都complete的时候才能算真正成功。



ED8FDA3E241D48B0A90F30A5AC8A9A59

如果把TransactionScopeOption设为RequiresNew,则嵌套的事务块和外层的事务块各自独立,互不影响。

  1.  
    staticvoidMain(string[] args)
  2.  
    {
  3.  
    using (TransactionScope ts = new TransactionScope())
  4.  
    {
  5.  
    Console.WriteLine(Transaction.Current.TransactionInformation.LocalIdentifier);
  6.  
    userBLL u = new userBLL();
  7.  
    TeacherBLL t = new TeacherBLL();
  8.  
    u.ADD();
  9.  
    using (TransactionScope ts2 = new TransactionScope(TransactionScopeOption.RequiresNew))
  10.  
    {
  11.  
    Console.WriteLine(Transaction.Current.TransactionInformation.LocalIdentifier);
  12.  
    t.ADD();
  13.  
    ts2.Complete();
  14.  
    }
  15.  
    ts.Complete();
  16.  
    }
  17.  
    }

22D29B0134CD4993B629F085EEBF63D9

可以看到,他们的事务id是不一样的。

TransactionScopeOption的属性值:
C#中回滚TransactionScope的使用方法和原理第3张

C#中回滚TransactionScope的使用方法和原理第4张

C#中回滚TransactionScope的使用方法和原理第3张

对于多个不同服务器之间的数据库操作,TransactionScope依赖DTC(Distributed Transaction Coordinator)服务完成事务一致性。

但是对于单一服务器数据,TransactionScope的机制则比较复杂。主要用的的是线程静态特性。线程静态特性ThreadStaticAttribute让CLR知道,它标记的静态字段的存取是依赖当前线程,而独立于其他线程的。既然存储在线程静态字段中的数据只对存储该数据的同一线程中所运行的代码可见,那么,可使用此类字段将其他数据从一个方法传递到该第一个方法所调用的其他方法,而且完全不用担心其他线程会破坏它的工作。TransactionScope 会将当前的 Transaction 存储到线程静态字段中。当稍后实例化 SqlCommand 时(在此 TransactionScope 从线程局部存储中删除之前),该 SqlCommand 会检查线程静态字段以查找现有 Transaction,如果存在则列入该 Transaction 中。通过这种方式,TransactionScope 和 SqlCommand 能够协同工作,从而开发人员不必将 Transaction 显示传递给 SqlCommand 对象。实际上,TransactionScope 和 SqlCommand 所使用的机制非常复杂。

免责声明:文章转载自《C#中回滚TransactionScope的使用方法和原理》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇实用 zsh 插件解决Eclipse Install New Software太慢的问题下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Android Handler与多线程

本文首先解释一下handler是用来干嘛的,然后通过例子介绍其在多线程中的应用。 什么是Handler      handler通俗一点讲就是用来在各个进程之间发送数据的处理对象。在任何进程中,只要获得了另一个进程的handler则可以通过 handler.sendMessage(message)方法向那个进程发送数据。基于这个机制,我们在处理多线程的时...

[从源码学设计] Flume 之 memory channel

[从源码学设计] Flume 之 memory channel 目录 [从源码学设计] Flume 之 memory channel 0x00 摘要 0x01 业务范畴 1.1 用途和特点 1.2 Channel 1.3 研究重点 1.4 实际能够学到什么 1.5 总述 0x02 定义 2.1 接口 2.2 配置参数2.2.1 channe...

Java 并发系列之七:java 阻塞队列(7个)

1.基本概念 2.实现原理 3.ArrayBlockingQueue 4.LinkedBlockingQueue 5.LinkedBlockingDeque 6.PriorityBlockingQueue 7.DelayQueue 8.SynchronousQueue 9.LinkedTransferQueue 10.小总结 11.t...

SQL Server2000中死锁经验总结

将死锁减至最少 虽然不能完全避免死锁,但可以使死锁的数量减至最少。将死锁减至最少可以增加事务的吞吐量并减少系统开销,因为只有很少的事务: 回滚,而回滚会取消事务执行的所有工作。 由于死锁时回滚而由应用程序重新提交。 下列方法有助于最大限度地降低死锁: 按同一顺序访问对象。 避免事务中的用户交互。 保持事务简短并在一个批处理中。 使用低隔离级别。...

Neety的基础使用及说明

BIO(缺乏弹性伸缩能力,并发量小,容易出现内存溢出,出现宕机每一个客户端对应一个线程 伪异步IO:创建线程池,由线程池里边的线程负责连接处理,M个个请求进来时,会在线程池创建N个线程。容易出现线程池阻塞。由一个线程池来处理客户端的请求。 NIO:异步非阻塞,服务器实现模式为一个请求一个线程,客户端发送的连接请求都会注册到多路复用器上,多路...

什么是高并发?

一、什么是高并发 ​ 高并发(High Concurrency)是一种系统运行过程中遇到的一种“短时间内遇到大量操作请求”的情况,主要发生在web系统集中大量访问收到大量请求(例如:12306的抢票情况;天猫双十一活动)。该情况的发生会导致系统在这段时间内执行大量操作,例如对资源的请求、数据库的操作等。 二、高并发的处理指标 高并发相关常用的一些指标有:响...