program.cs

< SQL Server2005程序设计>

using System;
using System.Data;
using System.Data.SqlClient;
using System.Transactions;

namespace DistributedTrans
{
    class Program
    {

        static void Main(string[] args)
        {
            string connStr1 = "Data Source=(local);Initial Catalog=Test1;Integrated Security=SSPI;";
            string connStr2 = "Data Source=(local);Initial Catalog=Test2;Integrated Security=SSPI;";

            string cmdText1 = "Update FromTable Set Amount = Amount - 50";
            string cmdText2 = "Update ToTable Set Amount = Amount + 50";

            using (TransactionScope tsc = new TransactionScope())
            {
                using (SqlConnection conn1 = new SqlConnection(connStr1))
                {
                    SqlCommand cmd1 = conn1.CreateCommand();
                    cmd1.CommandText = cmdText1;
                    conn1.Open();
                    cmd1.ExecuteNonQuery();
                }

                // Operation #1 is done, going to Operation #2

                Console.WriteLine(
                    System.Transactions.Transaction.Current.TransactionInformation.DistributedIdentifier.ToString());

                using (SqlConnection conn2 = new SqlConnection(connStr2))
                {
                    SqlCommand cmd2 = conn2.CreateCommand();
                    cmd2.CommandText = cmdText2;
                    conn2.Open();
                    cmd2.ExecuteNonQuery();
                }

                Console.WriteLine(
                    System.Transactions.Transaction.Current.TransactionInformation.DistributedIdentifier.ToString());

                tsc.Complete();
            }
        }
    }
}