前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >TransactionScope使用说明

TransactionScope使用说明

作者头像
跟着阿笨一起玩NET
发布2018-09-18 17:46:26
1.5K0
发布2018-09-18 17:46:26
举报
文章被收录于专栏:跟着阿笨一起玩NET

本文转载: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-->属性-->启动,启动这个服务.示例代码如下:

代码语言:javascript
复制
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;
            }

二。另一种方法就是建立两个事务,两个连接了。代码如下;

代码语言:javascript
复制
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;
            }
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2013-07-02 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档