TransactionScope使用说明
本文转载：http://www.cnblogs.com/ghfsusan/archive/2010/03/23/1692627.html
http://www.189works.com/article-85378-1.html
如果在C#中使用TransactionScope类(分布式事务),则须注意如下事项: 1、在项目中引用using System.Transactions命名空间（先要在添加net组件的引用）;
3、对MSDTC组件设置: 步骤: 在控制面板--->管理工具--->服务 中，开启Distributed Transaction Coordinator 服务。 a.控制面板->管理工具->组件服务->计算机->我的电脑->右键->属性 b.选择MSDTC页, 确认"使用本地协调器" c.点击下方"安全配置"按钮 d.勾选: "允许网络DTC访问","允许远程客户端","允许入站","允许出站","不要求进行身份验证". e.对于数据库服务器端, 可选择"要求对呼叫方验证" f.勾选:"启用事务Internet协议（TIP)事务"。 g.在双方防火墙中增加MSDTC.exe例外 可用命令行: netsh firewall set allowedprogram %windir%\system32\msdtc.exe MSDTC enable
4、重启IIS服务器。
注意：
我们只要确保数据库的打开操作是在事务范围内打开就行了。这样就可以做到事务的正确操作。
如果WEB服务器和数据库是在同一台服务器上，TransactionScope使用的是本地事务，这时不需要配置MSDTC。 如果WEB服务器和数据库不在同一台服务器上，TransactionScope会自动提升事务级别为分布式事务，这时就需要配置MSDTC。配置很简单的，网上有教程，做两次就知道了。
在程序的开发过程中，对数据库的增删改通常要用到事务，用来实现的全部更新和全部回滚。单数据库还比较好做，如果遇到同时操作多个数据库增删改，可以用下面的方法
一。TransactionScope类
TransactionScope类是framework2.0 新增的一个类，在System.Transactions命名空间中，使用时必须先添加System.Transactions引用；另外还要在windows控制面版-->管理工具-->服务-->Distributed Transaction Coordinator-->属性-->启动，启动这个服务.示例代码如下：
try
{
using (TransactionScope scope = new TransactionScope())
{
//更新northwind数据库的Employees表
using (SqlConnection conOne = new SqlConnection("server=.;uid=sa;pwd=123;database=northwind"))
{
conOne.Open();
SqlCommand command = new SqlCommand("update Employees set lastname='chen' where employeeid='1'", conOne);
int i = command.ExecuteNonQuery();
}
//更新pubs数据库的jobs表
using (SqlConnection conTwo = new SqlConnection("server=.;uid=sa;pwd=123;database=pubs"))
{
conTwo.Open();
SqlCommand command = new SqlCommand("update jobs set job_desc='chen' where job_id='1'", conTwo);
int i = command.ExecuteNonQuery();
}
scope.Complete(); //提交事物
}
}
catch (Exception ex) //发生异常后自动回滚
{
//throw;
}二。另一种方法就是建立两个事务，两个连接了。代码如下；
SqlConnection conNorthwind = new SqlConnection("server=.;uid=sa;pwd=123;database=northwind");
SqlConnection conPubs = new SqlConnection("server=.;uid=sa;pwd=123;database=pubs");
SqlCommand commandNorthwind = new SqlCommand();
SqlCommand commandPubs = new SqlCommand();
try
{
conNorthwind.Open();
conPubs.Open();
//更新northwind数据库的Employees表
SqlTransaction tranNorthwind = conNorthwind.BeginTransaction();
commandNorthwind.Connection = conNorthwind;
commandNorthwind.Transaction = tranNorthwind;
commandNorthwind.CommandText = "update Employees set lastname='chen' where employeeid='1'";
int i = commandNorthwind.ExecuteNonQuery();
//更新pubs数据库的jobs表
SqlTransaction tranPubs = conPubs.BeginTransaction();
commandPubs.Connection = conPubs;
commandPubs.Transaction = tranPubs;
commandPubs.CommandText = "update jobs set job_desc='chen' where job_id='1'";
int k = commandPubs.ExecuteNonQuery();
//throw new Exception();
//提交事务
commandNorthwind.Transaction.Commit();
conNorthwind.Close();
commandPubs.Transaction.Commit();
conPubs.Close();
}
catch (Exception ex)
{
//回滚事务
if (commandNorthwind.Transaction != null && conNorthwind != null)
{
commandNorthwind.Transaction.Rollback();
conNorthwind.Close();
}
if (commandPubs.Transaction!= null && conPubs != null)
{
commandPubs.Transaction.Rollback();
conPubs.Close();
}
//throw;
}腾讯云开发者
