zoukankan      html  css  js  c++  java
  • 跨数据库分布式事务的处理

    using System;
    using System.Collections.Generic;
    using System.Text;
    using System.EnterpriseServices;
    using System.Data.SqlClient;

    namespace myCOM
    {
        [Transaction(TransactionOption.Required)]
        public class MyComClass : ServicedComponent
        {
            public SqlConnection Conn;
            public SqlConnection Conn1;

            public void test(string updateStr)
            {
                try
                {
                    string connection = string.Format("server = pwdpc; database = Northwind; uid = sa; pwd = ******;");
                    SqlConnection Conn = new SqlConnection(connection);
                    Conn.Open();

                    string connection1 = string.Format("server = pwdpc; database = pubs; uid = sa; pwd = ******;");
                    SqlConnection Conn1 = new SqlConnection(connection1);
                    Conn1.Open();

                    SqlCommand cmd = new SqlCommand();
                    cmd.Connection = Conn;
                    cmd.CommandType = System.Data.CommandType.Text;
                    string sqlSentence = string.Format("update dbo.Customers set CompanyName = '{0}' where CustomerID = 'ALFKI'", updateStr);
                    cmd.CommandText = sqlSentence;
                    cmd.ExecuteNonQuery();

                    //出异常
                    //int i = 0;
                    //int j = 1 / i;

                    SqlCommand cmd1 = new SqlCommand();
                    cmd1.Connection = Conn1;
                    cmd1.CommandType = System.Data.CommandType.Text;
                    string sqlSentence1 = string.Format("update dbo.authors set au_fname = '{0}' where au_lname = 'White'", updateStr);
                    cmd1.CommandText = sqlSentence1;
                    cmd1.ExecuteNonQuery();

                    ContextUtil.SetComplete();
                    Conn.Close();
                    Conn1.Close();
                }
                catch (Exception ex)
                {
                    ContextUtil.SetAbort();
                    throw ex;
                }
                finally
                { }
            }
        }
    }

  • 相关阅读:
    Android应用开发SharedPreferences存储数据的使用方法
    Android ListView不响应OnItemClickListener解决办法
    Java 毫秒转换为日期类型、日期转换为毫秒
    关于android软键盘enter键的替换与事件监听
    如何使用adb命令查看android中的数据库
    android坐标
    getHitRect获取点击控件的位置
    UTC的相互转换(java)
    深入理解Android的startservice和bindservice
    TS格式解析
  • 原文地址:https://www.cnblogs.com/EddyPeng/p/1225851.html
Copyright © 2011-2022 走看看