在.NET 1.0/1.1 版本我们使用SqlTransaction.处理事务
-
string connString = ConfigurationManager.ConnectionStrings["db"].ConnectionString;
-
using (var conn = new SqlConnection(connString))
-
{
-
conn.Open();
-
using (IDbTransaction tran = conn.BeginTransaction())
-
{
-
try
-
{
-
// transactional code...
-
using (SqlCommand cmd = conn.CreateCommand())
-
{
-
cmd.CommandText = "INSERT INTO Data(Code) VALUES('A-100');";
-
cmd.Transaction = tran as SqlTransaction;
-
cmd.ExecuteNonQuery();
-
}
-
tran.Commit();
-
}
-
catch(Exception ex)
-
{
-
tran.Rollback();
-
throw;
-
}
-
}
-
}
到了.NET2.0微软提供了TransactionScope
-
using (var scope = new TransactionScope())
-
{
-
//transctional code…
-
scope.Complete();
-
}
TransactionScope使用起来简单,只需要把代码写在大括号里,最后加上scope.Complete();就可以了
接下来主要介绍TransactionScope的简单使用
TransactionScope有三个属性:IsolationLevel,Timeout,TransactionScopeOption
Property | Default Value | Available Options |
IsolationLevel(隔离等级) | Serializable | Serializable, Read Committed, Read Un Committed, Repeatable Read |
Timeout(超时) | 1 Minute | Maximum 10 Minutes |
TransactionScopeOption (选项) | Required | Required, Required New, Suppress |
用以下代码可以看到他们属性的值
-
using (var scope = new System.Transactions.TransactionScope())
-
{
-
System.Transactions.IsolationLevel isolationLevel = Transaction.Current.IsolationLevel;
-
TimeSpan defaultTimeout = TransactionManager.DefaultTimeout;
-
TimeSpan maximumTimeout = TransactionManager.MaximumTimeout;
-
}
由图可以看到,TransactionScope默认情况下的隔离等级为Serializable,超时时间为1分钟
Dirty Read(脏读):脏读就是指当一个事务正在访问数据,并且对数据进行了修改,而这种修改还没有提交到数据库中,这时,另外一个事务也访问这个数据,然后使用了这个数据。
Non Repeatable Read(不可重复读):是指在一个事务内,多次读同一数据。在这个事务还没有结束时,另外一个事务也访问该同一数据。那么,在第一个事务中的两次读数据之间,由于第二个事务的修改,那么第一个事务两次读到的的数据可能是不一样的。这样就发生了在一个事务内两次读到的数据是不一样的,因此称为是不可重复读。(即不能读到相同的数据内容)
Phantom Read(幻读):是指当事务不是独立执行时发生的一种现象,例如第一个事务对一个表中的数据进行了修改,这种修改涉及到表中的全部数据行。同时,第二个事务也修改这个表中的数据,这种修改是向表中插入一行新数据。那么,以后就会发生操作第一个事务的用户发现表中还有没有修改的数据行,就好象
发生了幻觉一样。
隔离等级的四种选择:
Serializable(序列化):它在读/写操作时锁定数据。由于这个原因,很多时候它会创建一个死锁,因此你可能会得到一个超时异常。可以将此隔离级别用于高度安全的事务性应用程序(如金融应用程序)。缺点是性能低
Repeatable Read(可重复读):同为Serializable,除了允许幻读。可以使用在金融中的应用或严重事务性应用,但需要知道幻读创造的场景是不存在的。
Read Committed(读提交):大多数应用程序都可以使用它。SQLServer默认隔离级别是这个。不会有脏读
Read Un-Committed(读不提交):这些应用程序不需要支持并发事务。
TransactionScope使用:
对CommonTest_ExamInfo_ExamStudents表中的一个学生进行修改操作,隔离等级为Read Committed
-
var option = new TransactionOptions();
-
option.IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted;
-
option.Timeout = TimeSpan.FromMinutes(1);
-
using (var scope = new TransactionScope(TransactionScopeOption.Required, option))
-
{
-
String sql = @"UPDATE Students SET sStuName = @sStuName WHERE sID = @sID AND sIdentityID = @sIdentityID ";
-
SqlParameter[] args = new SqlParameter[3];
-
args[0] = new SqlParameter("@sStuName", "张三");
-
args[1] = new SqlParameter("@sTID", "2017120608575");
-
args[2] = new SqlParameter("@sIdentityID", "36281763861231231");
-
if (testDB.Database.ExecuteSqlCommand(sql, args) > 0)
-
{
-
scope.Complete();
-
return true;
-
}
-
else
-
{
-
return false;
-
}
-
}
当执行完代码红色那行后,可以看到,SQLserver启动了隔离等级为Read Committed的事务,然后执行修改操作。 此时,如果执行
SELECT TOP 1000 * FROM [dbo].[Students] SQL语句,如正在修改的数据也包括在内,则不能被查出来,修改操作也是如此。
直到跳出using括号后,查询语句才能被真正执行。
但是,此时数据库可以执行与事务修改操作无关的数据,如执行
SELECT * FROM Students
WHERE sTID = '2017120608575' AND sIdentityID = '36281763861231231' SQL语句,可以顺利查询到数据
此外,还有一点需要说明,当连续执行两次相同的修改操作,即第二次其实是没有真正修改数据库数据的,此时可以对操作的数据行查询
场次安排不使用事务和使用TransactionScope的Read Committed进行对比
不使用事务如下:
-
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted }))
-
{
-
testDB.Database.ExecuteSqlCommand("delete from dbo.ChildTestList where sTID=@sTid;delete from dbo.ExamStudents where sTID=@sTid;", new SqlParameter("@sTid", sTID));
-
if (testDB.Database.Connection.State != ConnectionState.Open)
-
{
-
testDB.Database.Connection.Open(); //打开Connection连接
-
}
-
if(!DbHelper.BulkInsert<ExamStudents>((SqlConnection)testDB.Database.Connection, "ExamStudents", lstExamStudents))
-
{
-
if (testDB.Database.Connection.State != ConnectionState.Closed)
-
{
-
testDB.Database.Connection.Close(); //关闭Connection连接
-
}
-
return false;
-
}
-
if (!DbHelper.BulkInsert<ChildTestList>((SqlConnection)testDB.Database.Connection, "ChildTestList", lstCldTestTB))
-
{
-
if (testDB.Database.Connection.State != ConnectionState.Closed)
-
{
-
testDB.Database.Connection.Close(); //关闭Connection连接
-
}
-
return false;
-
}
-
if (testDB.Database.Connection.State != ConnectionState.Closed)
-
{
-
testDB.Database.Connection.Close(); //关闭Connection连接
-
}
-
var testInfo = testDB.TestList.Where(p => p.sTID == sTID).FirstOrDefault();
-
if (nSaveType == 1)
-
{
-
testInfo.nTestState = 14;
-
}
-
else
-
{
-
testInfo.nTestState = 13;
-
}
-
testDB.SaveChanges();
-
scope.Complete();
-
return true;
-
}
添加TransactionScope事务:
以上两图显示他们性能上并无明显区别。
总结:可以使用TransactionScope的Read Committed隔离等级进行一系列事务操作,性能没有太大影响。一般不使用TransactionScope默认的Serializable隔离等级,因为它需要开很多锁,性能会因此而下降。使用TransactionScope应注意尽量让using大括号里面的代码都短一些,这样它出错的几率更小,事务回滚的几率也会减少。所以出于数据的一致性考虑,一系列对数据库的操作可添加TransactionScope的Read Committed隔离等级的事务。
引用一下别人的导读:在实际开发工作中,执行一个事件,然后调用另一接口插入数据,如果处理逻辑出现异常,那么之前插入的数据将成为垃圾数据,我们所希望的是能够在整个这个方法定义为一个事务,TransactionScope 类提供一个简单方法,通过这一方法,您不必与事务本身交互,即可将代码块标记为参与某个事务。TransactionScope对象创建了一个事务,同时将该事务设置给Transaction类的Current属性。
一、TransactionScope的优点
1、使用起来比较方便.TransactionScope可以实现隐式的事务,使你可以在写数据访问层代码的时候不用考虑到事务,而在业务层的控制事务.
2、可以实现分布式事务,比如跨库或MSMQ.
二、TransactionScope缺点
1、性价比不高.比如,你只是在"Scope"里控制一个库的事务.用"TransactionScope"就有点浪费了.
2、一般情况下只要你使用"TransactionScope",都要配置MSDTC,要配防火墙,要开139端口.这个端口不可以更改
三、如果你不得不用分布式事务,那也得琢磨琢磨
1.这步操作一定得在事务当中吗?这步操作如果没完成或者失败了,值得回滚整个事务吗?难道没有优雅的补偿措施或者容错措施?
2.分布式事务涉及到的点,必须的这么多?必须得实时的操作这一大串?不能通过通知类操作去精简掉某些点?
3.在发起分布式事务之后,你是不是做了事务无关的操作,尽管这些操作跟事务无关?(如,读取数据、计算、等用户返回消息、等其他模块的调用返回等等)要知道事务应该尽快结束。
4.你没有把一些读操作也算在事务里面了吧?这是很容易犯的错误,你在事务中Enlist了一个select 操作。
5.你的操作,某些步骤可以等全部操作完成之后再执行.这类操作具有明显的通知类特点。通知类操作是说,我给你一个通知,并且我保证通知到了你;你必须吃下这个通知,并且保证处理成功,但是你不必我一通知你你就处理。这样的操作很明显可以用另外一个任务去搞。
四、使用分布式事务注意如下几点
1:确保参与事务的machine开启了分布式事务支持;
2:如果machine开启了防火墙,需要设置msdtc进程为例外;
3:参与事务的machine不能跨域(如果跨域,目前微软还没有确切的解决方案);
4:多数据库时才使用分布式事务,如果是同一个数据库,最好使用SqlTransaction.