在ASP.NET 2.0中操作数据之六十一：在事务里对数据库修改进行封

　　类声明里的关键字partial向编译器表明代码里添加的成员(members)是添加到命名空间NorthwindTableAdapters里的ProductsTableAdapter class类.我们注意到在文件的顶部有一个using System.Data.SqlClient声明，这是因为TableAdapter被设置为使用SqlClient provider，在其内部使用一个SqlDataAdapter object对象来向数据库发出命令.因此，我们需要使用SqlTransaction class类来启动事务，然后提交或回滚事务.如果没有使用Microsoft SQL Server数据库的话，你需要调用恰当的provider.

　　这些方法被标记为public，我们可以在ProductsTableAdapter里，或数据访问层DAL的其它类，甚至是其它层比如业务逻辑层BLL来调用这些法.
BeginTransaction()方法打开了TableAdapter的内部的SqlConnection(如果需要的话), 开启事务并赋值给Transaction属性，并将事务分配(attache)给SqlDataAdapter的SqlCommand objects对象.CommitTransaction()和 RollbackTransaction()方法在关闭内部的Connection object对象前分别调用Transaction object对象的Commit 和 Rollback方法.

　　添加上述代码后，我们将在ProductsDataTable 或业务逻辑层BLL里添加方法以执行一系列的置于事务之下的命令. 下面的代码在Batch Update pattern模式里使用一个事务来更新一个ProductsDataTable instance实例.它调用BeginTransaction method方法来启动一个事务，然后用一个try...catch模块来发布数据更改命令.如果调用Adapter object对象的Update方法出现异常，那么将转到catch区域，对事务进行回滚.记得执行Batch Update pattern模式的Update方法将遍历ProductsDataTable里的所有行(rows)，执行相应的InsertCommand, UpdateCommand, 和DeleteCommands命令.如果这些命令中的其中一个出现异常，事务将回滚，撤销在事务里的所做的更改.如果Update命令全部执行无异常，那么提交事务.

public int UpdateWithTransaction(Northwind.ProductsDataTable dataTable)
{
 this.BeginTransaction();

 try
 {
 // Perform the update on the DataTable
 int returnValue = this.Adapter.Update(dataTable);

 // If we reach here, no errors, so commit the transaction
 this.CommitTransaction();

 return returnValue;
 }
 catch
 {
 // If we reach here, there was an error, so rollback the transaction
 this.RollbackTransaction();

 throw;
 }
}

　　将上述的UpdateWithTransaction()方法添加到文件ProductsTableAdapter.TransactionSupport.cs里的ProductsTableAdapter class类。另外，还可以将该方法添加到业务逻辑层的ProductsBLL class类，不过要做些许修改：即将this.BeginTransaction(), this.CommitTransaction(), and this.RollbackTransaction()三中方法里的关键字“this”替换为“Adapter”(我们知道，ProductsBLL类里的ProductsTableAdapter的name属性即是Adapter).

　　UpdateWithTransaction()方法使用的是Batch Update模式，不过也可在事务里调用DB-Direct模式，就像下面的代码显示的那样.DeleteProductsWithTransaction()方法接受一个int类型的List<T>，也就是要删除的ProductIDs.该方法通过调用BeginTransaction来启动事务，然后在try模块里对每一个ProductID值调用DB-Direct模式的Delete方法.如果任何一个对Delete的调用出错，将转到catch 模块，事务将会回滚；如果所有对Delete的调用成功，那就提交事务。添加该方法给ProductsBLL class类.

public void DeleteProductsWithTransaction
 (System.Collections.Generic.List<int> productIDs)
{
 // Start the transaction
 Adapter.BeginTransaction();

 try
 {
 // Delete each product specified in the list
 foreach (int productID in productIDs)
 {
 Adapter.Delete(productID);
 }

 // Commit the transaction
 Adapter.CommitTransaction();
 }
 catch
 {
 // There was an error - rollback the transaction
 Adapter.RollbackTransaction();

 throw;
 }
}

在多个TableAdapters应用事务

　　到目前为止我们考察的是对ProductsTableAdapter里的多个命令采用原子操作.如果我们是对多个不同的数据库表进行改动，并对这些改动执行原子操作那又怎么办呢？比如：当删除一个category时，在删除之前我们想把该种类对应的products分配给其它的category.对这种2步操作——分配products和删除category——应该执行原子操作.但是ProductsTableAdapter只包含修改Products表的方法；而CategoriesTableAdapter只包含修改Categories表的方法.那么怎样使用一个包含这2个TableAdapters的事务呢？

　　其中一个办法是向CategoriesTableAdapter添加一个名为DeleteCategoryAndReassignProducts(categoryIDtoDelete, reassignToCategoryID)的方法.再定义一个方法来调用一个存储过程，使用事务来达到分配products和删除category的目的.我们将在后面考察在一个存储过程里开始、提交和回滚事务.

　　另一个方法是在数据访问层里添加一个类，来包含DeleteCategoryAndReassignProducts(categoryIDtoDelete, reassignToCategoryID)方法.该方法创建CategoriesTableAdapter 和 the ProductsTableAdapter的实例，并将这2个TableAdapters的Connection属性设置为相同的SqlConnection实例。这样，它们都将调用BeginTransaction来开启事务.然后在try...catch模块里执行分配products和删除category的方法，最后提交或回滚事务.

第四步：向业务逻辑层添加UpdateWithTransaction方法

　　在第三步我们向数据访问层DAL里的ProductsTableAdapter添加了一个UpdateWithTransaction方法，我们将向业务逻辑层添加相应的方法.虽然表现层可以直接向DAL调用UpdateWithTransaction方法，但是我们在这里仍然将它们分隔开。

（编辑：开发网_开封站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!