C#使用COM+实现事务控制,操作多个数据库

其中大部分内容参考自http://blog.itpub.net/10752043/viewspace-991224/

上面的是sqlserver的操作方式,因为我实际项目是用的oracle,就拿oracle试了一下,为了自己记录或者方便其他人,其中的demo代码我就拿了上来,仅供参考。

测试环境:VS2008+oracle 10G,其中红色部分是我自己加的备注。


一般的数据库事务控制要求事务里所做的操作必须在同一个数据库内,这样在出现错误的时候才能回滚(RllBack)到初始状态。这就存在一个问题,在分布式应用程序中,我们往往需要同时操作多个数据库,使用数据库本身的事务处理,很难满足程序对事务控制的要求。在COM+中,提供了完整的事务服务,我们可以利用它来完成在分布式应用程序中的事务控制。


具体过程如下

一:用VS.NET生成一个类库 。

二:添加对System.EnterpristServices的引用,具体步骤

菜单:(项目-添加引用-在.NET选项卡选择System.EnterpristServices-确定)

三:构建类

1:源程序

using System;
using System.EnterpriseServices;
using System.Reflection;
using System.Data.Odbc;
using System.Data.Sql;
using System.Data.OracleClient;
namespace COMPlusSamples
{
    //表明需要事务支持
    [Transaction(TransactionOption.Required)]
    //声明为服务器应用程序,还可以选择Library,表示为库应用程序
    [assembly: ApplicationActivation(ActivationOption.Server)]
    //描述信息
    [assembly: Description("sample")]
    public class TxCfgClass : ServicedComponent
    {
        private static string init1 = "data source=mysnhis;password=his;persist security info=True;user id=mysnhis;Pooling=False";
        private static string init2 = "data source=mylyhis;password=his;persist security info=True;user id=mylyhis;Pooling=False";
        private static string add1 = "insert into testtest(TYPE,CODE) values(‘test1‘, ‘test2‘)";
        private static string add2 = "insert into testtsdfest(TYPE,CODE) values(‘test1‘, ‘test2‘)";
        public TxCfgClass() { }
        private int ExecSQL(string init, string sql)
        {
            int i = 0;
            OracleConnection conn = new OracleConnection(init);
            try
            {
                conn.Open();
                OracleCommand cmd = conn.CreateCommand();
                cmd.CommandText = sql;
                i = cmd.ExecuteNonQuery();
            }
            catch (Exception ee)
            {
                Console.WriteLine(ee.Message);//如果有错误,输出错误信息
            }
            finally
            {
                conn.Close(); //关闭连接
            }
            return i;
        }
        //添加一条记录到数据库
        public void Add()
        {
            try
            {
                //在一数据库中插入一条记录
                int i = ExecSQL(init1, add1);
                //在另外一个数据库中插入一条记录
                //这次执行的是一个错误的SQL语句
                if (i > 0)
                {
                    int j = ExecSQL(init2, add2);
                }
                if (i > 0 && j > 0)
                {
                    ContextUtil.SetComplete();//提交
                }
                else
                {
                    ContextUtil.SetAbort();//回滚
                }
            }
            catch (Exception e)
            {
                //事务回滚
                ContextUtil.SetAbort();
            }
        }
    }
}

2:程序说明:

添加命名空间 using System.EnterpriseServices;因为本程序使用了其中的ContextUtil类

[ Transaction(TransactionOption.Required) ]  说明DLL需要事务支持


 本程序的TxCfgClass 类从ServicedComponent类中继承,这样并不会影响该类,而只是在该类中添加了两个额外的方法,这两个方法可以使代码共享变得更加容易


 程序使用的oracle数据库在本机运行,init1 和 init2是两个连接数据库的连接字符串,add1和add2是两条sql语句,作用是分别向两个数据库的表里添加一条记录。注意:add2是一条错误的语句,因为根本没有sample表,这样,会在执行时引起异常。(这正是我们所期望的)


 在执行到add2语句时,由于它是错误的,所以会引发异常,转到错误处理语句里来执行。


 ContextUtil.SetAbort();该语句使所有的数据库操作回滚,这样add1语句所插入的记录也将不存在。(达到预期目标)


四:给程序添加强名(strong name)

 1:创建一对密钥

 用来创建密钥的工具是称为sn.exe的共享工具。通常通过命令提示运行它,该工具可执行各种任务以生成并提取密钥。我们需要用以下方式来运行sn.exe。

 sn –k key.snk

  其中key.snk 代表将保存密钥的文件的名称。它的名称可以是任意的,不过习惯上带有.snk后缀名。

备注:在开始→vs2008→命令窗口执行该语句,并且将生成的snk文件要拷贝到可执行程序的同目录下。

 2:签名

 签名通常是在编译时进行的。签名时,用户可利用C#属性通知编译器应该使用正确的密钥文件对DLL进行签名。要做到这一点用户需要打开工程中的AssemblyInfo.cs文件并进行修改。

 [assembly:AssemblyKeyFile(“....key.snk”)]

 注:key.snk文件和项目文件在同一个文件夹

 [assembly: ComVisible(false)]改成[assembly: ComVisible(true)]


五:编译成DLL (具体步骤)

 菜单:(生成-生成)

 如果一切正常,就会生成DLL文件


六:使用regsvcs.exe将Dll注册到COM+ Services里面

 我们需要用以下方式运行regsvcs.exe

 regsvcs dll文件名

  如果一切正常的话,regsvcs.exe就会把dll输入到COM+ Services中。


至此,我们已经生成并注册了这个可以由其它程序使用的类,现在,我们来写一个控制台程序来检验这个类是否正常运行


七:构建客户机

1:新建控制台应用程序项目

菜单(文件-新建-项目)

 1:选择控制台应用程序 ,并选择 添入解决方案 ,确定

 2:同上面的第二步一样,添加对System.EnterpriseServices的引用。

 3:添加对自己刚才做好的类的引用。

菜单(项目-添加引用-浏览),选择刚才生成的DLL,确定

 4:输入以下程序

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.EnterpriseServices;
namespace ConsoleApplication2
{
    class Program
    {
        static void Main(string[] args)
        {
            COMPlusSamples.TxCfgClass p = new COMPlusSamples.TxCfgClass();
            p.Add();
        }
    }
}

  5:将控制台程序设置为启动项,然后编译运行,就会看到结果。

 正如我们希望的,第一条记录没有插入数据库


C#使用COM+实现事务控制,操作多个数据库,布布扣,bubuko.com

C#使用COM+实现事务控制,操作多个数据库

上一篇:84. 柱状图中最大的矩形


下一篇:Silverlight实用窍门系列:43.Silverlight从ListBox拖拽图标到另一ListBox【附带源码实例】