我正在编写一个集成测试,我将把一些对象插入数据库,然后检查以确定我的方法是否检索这些对象.
我与数据库的连接是通过NHibernate ...而我创建这样一个测试的常用方法是执行以下操作:
NHibernateSession.BeginTransaction(); //use nhibernate to insert objects into database //retrieve objects via my method //verify actual objects returned are the same as those inserted NHibernateSession.RollbackTransaction();
但是,我最近发现了TransactionScope,它显然可以用于这个目的......
我发现的一些示例代码如下:
public static int AddDepartmentWithEmployees(Department dept) { int res = 0; DepartmentAdapter deptAdapter = new DepartmentAdapter(); EmployeeAdapter empAdapter = new EmployeeAdapter(); using (TransactionScope txScope = new TransactionScope()) { res += deptAdapter.Insert(dept.DepartmentName); //Custom method made to return Department ID //after inserting the department "Identity Column" dept.DepartmentID = deptAdapter.GetInsertReturnValue(); foreach(Employee emp in dept.Employees) { emp.EmployeeDeptID = dept.DepartmentID; res += empAdapter.Insert(emp.EmployeeName, emp.EmployeeDeptID); } txScope.Complete(); } return res; }
我相信,如果我不包括txScope.Complete()
插入数据将被回滚的行.但不幸的是,我不明白怎么可能......如何的txScope
对象保持的轨道deptAdapter
和empAdapter
对象及其交易的数据库.
我觉得我在这里缺少一些信息......我真的可以通过使用我的代码替换我的BeginTransaction()
和RollbackTransaction(
)调用TransactionScope
吗?
如果没有,那么如何TransactionScope
回滚交易呢?
基本上,TransactionScope不会跟踪您的适配器,它的作用是跟踪数据库连接.当您打开数据库连接时,连接将查看是否存在环境事务(事务范围),如果存在,则查看它.注意如果与同一SQL服务器的连接多一个,那么它将升级为Distribtued Transaction.
由于您正在使用using块,因此即使发生异常,也会调用dispose.因此,如果在txScope.Complete()之前调用dispose,则TransactionScope将告诉连接回滚其事务(或DTC).
该TransactionScope
班的工作原理与Transaction
阶级,这是线程特定的.
当TransactionScope
被创建,它会检查是否有Transaction
该线程; 如果存在,那么它使用它,否则,它创建一个新的并将其推入堆栈.
如果它使用现有的,那么它只增加一个计数器以释放(因为你必须调用Dispose
它).在最后一个版本中,如果Transaction
没有进行评论,它将回滚所有工作.
至于为什么类似乎神奇地了解了事务,那么这就是那些希望使用这个模型的类的实现细节.
在创建deptAdapter
和emptAdapter
实例时,它们会检查线程上是否有当前事务(类上的静态Current
属性Transaction
).如果存在,那么它将自己注册Transaction
,以参与提交/回滚序列(它Transaction
控制,并可能传播给不同的事务协调器,如内核,分布式等).