本文共 2460 字,大约阅读时间需要 8 分钟。
对于transactionscope我在之前写过两篇文件,在文章中已经把它何时会触发分布式事务写的很清楚了,但实现上,对于原理上为何会产生MSDTC说的还不够明白,所以,有必要再写一篇终如何去避免不必要的MSDTC。
分布式事务它依赖于windows的一个服务MSDTC,只有WWW服务器上的MSDTC服务处于启动状态,我们才可以使用分布式事务,对于分布式事务官方这样定义它:协调跨多个数据库、消息队列、文件系统等资源管理器的事务。
对于数据库多表操作来说,它何时是分布式,要看你的事务中的connection会话的数量,如果是一次,它会认识你在操作一个数据库,这当然不会引入MSDTC,但如果你是多个connection会话,它会认识你在操作多张表,这时它属于分布式的范畴,同时会引起MSDTC。
为什么我们在项目中,对于操作同一个数据库的多张表,总会产生MSDTC
这要看一个基础问题,事实很多时候解决问题的方法都是从基础知识入手了,你之所以会犯错是因为你对基础知识掌握不牢靠。
对于LINQ To SQL或者EF等ORM来说,它们会提供一个SubmitChanges,作用是打开connection,将操作内容提交到数据库,关闭connection。
而我们为了代码的精简性,有时会有CURD操作进行封装,这是正常的,为了维护代码方便进行必要的封装,是种面向对象的思想,但注意,当你insert操作之后,如果封装了SubmitChange,这时系统会认识你是一次完成的connection动作,而在进行第二个insert操作时,这时,会有两个connection会话了,而在TransactionScope范围内,对于多个Connection的理解就是多个库,所以系统肯定会把它提升为分布式事务,并启用MSDTC去支持它,这是正常的,一切都很正常,而对于我们来说,不希望每个TransactionScope都产生MSDTC,所以,我们应该如何去应对,方法很容易,将CURD操作的方法进行重装,加个参数isSubmit就可以了,代码如下:
////// 插入操作 /// ///实体类型 /// 实体 /// 是否同时提交到数据库,对于写在transactionscope里的多条语句, /// 如果本语句不是最后一条,本值为false,即不立即提交到数据 public void Insert(TEntity entity, bool isSubmit) where TEntity : class { if (entity is EntityBase) (entity as EntityBase).OnInsertBefore(); //Logger.InfoLog("Create 表名:{0},内容:{1}", entity, ToJson(entity)); _db.Entry (entity); _db.Set ().Add(entity); if (isSubmit) this.SaveChanges(); if (entity is EntityBase) (entity as EntityBase).OnInsertAfter(); }
对于具体的事务块,代码可能是这样:
using (TransactionScope trans = new TransactionScope()) { try { base.Insert(entity.Product_Comment, false); base.Insert (entity.Review); trans.Complete(); } catch (Exception) { throw; } finally { trans.Dispose(); } }
对于一个SubmitChange()所产生的SQL代码为:(一个connection会话)
对于多个SubmitChange()所产生的SQL代码为:(多个connection会话)
总结:对于数据服务器与WWW服务器不在一起电脑上时,产生MSDTC的关键在于connection会话的数据,一个会话表示操作一个数据库,这时不产生MSDTC,如果多个会话,认识是操作多个数据库,所以就产生了MSTDC!小微真聪明!
感谢阅读!
本文转自博客园张占岭(仓储大叔)的博客,原文链接:,如需转载请自行联系原博主。