基于 Transaction 類的分布式顯式事務

自.NET2.0以來增加了System.Transactions命名空間，為.NET應用程序帶來了一個新的事務編程模型。

這個命名空間提供了幾個依賴的TransactionXXX類。Transaction是所有事務處理類的基類，并且定義了所有事務類都可以使用的屬性、方法和事件。CommittableTransaction是唯一個支持提交的事務類，這個類有一個Commit()方法，所有其他事務類都只能執行回滾。

本文將通過銀行轉賬的示例介紹基于 Transaction 類的分布式顯式事務的用法。

在MySQL中建立如下表：

注意Balance是無符號的decimal類型（如下圖）

插入測試數據：

（轉賬成功的測試數據）：

（轉賬失敗的測試數據）：

示例代碼：

（1）SqlHelper.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Configuration;

using MySql.Data.MySqlClient;

using System.Transactions;

using System.Data;

namespace 事務處理

{

    public class SqlHelper

    {

        public static string GetConnection()

        {

            string connStr = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;

            return connStr;

        }

        public static int ExecuteNonQuery(Transaction transaction,string sql,params MySqlParameter[] parameters)

        {

            int result = -1;

            using (MySqlConnection conn = new MySqlConnection(GetConnection()))

            {

                conn.Open();

                if (null != transaction)

                {

                    conn.EnlistTransaction(transaction);    //將連接登記到事務

                }

                using (MySqlCommand cmd = conn.CreateCommand())

                {

                    cmd.CommandText = sql;

                    cmd.Parameters.AddRange(parameters);

                    result = cmd.ExecuteNonQuery();

                }

            }

            return result;

        }

        public static DataTable ExecuteDataTable(string sql, params MySqlParameter[] parameters)

        {

            using (MySqlConnection conn = new MySqlConnection(GetConnection()))

            {

                using (MySqlCommand cmd = conn.CreateCommand())

                {

                    cmd.CommandText = sql;

                    cmd.Parameters.AddRange(parameters);

                    using (MySqlDataAdapter da = new MySqlDataAdapter(cmd))

                    {

                        using (DataSet ds = new DataSet())

                        {

                            da.Fill(ds);

                            return ds.Tables[0];

                        }

                    }

                }

            }

        }

    }

}

（2）Bankaccountn.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using MySql.Data.MySqlClient;

using System.Data;

using System.Transactions;

namespace 事務處理

{

    public class Bankaccountn

    {

        public Bankaccountn(string bankaccountnId)

        {

            string sql = @"SELECT * FROM Bankaccountn WHERE BankaccountnId=@BankaccountnId;";

            DataTable dt = SqlHelper.ExecuteDataTable(sql, new MySqlParameter("@BankaccountnId", bankaccountnId));

            if (dt.Rows.Count <= 0)

            {

                throw new Exception("賬戶不存在！");

            }

            else if (dt.Rows.Count > 1)

            {

                throw new Exception("異常信息：有重名的賬戶存在！");

            }

            else

            {

                this.bankaccountnId = dt.Rows[0]["BankaccountnId"] as string;

                this.UserName = dt.Rows[0]["UserName"] as string;

                this.Balance = Convert.ToDecimal(dt.Rows[0]["Balance"]);

            } 

        }

        PRivate string bankaccountnId;

        public string UserName

        { 

            get; 

            private set; 

        }

        public decimal Balance

        {

            get;

            private set;

        }

        protected int Update(Transaction transaction)

        {

            string sql = @"UPDATE bankaccountn SET UserName = @UserName,Balance = @Balance 

                           WHERE BankaccountnId= @BankaccountnId;";

            return SqlHelper.ExecuteNonQuery(transaction, sql, new MySqlParameter("@BankaccountnId", this.bankaccountnId), new MySqlParameter("@UserName", this.UserName), new MySqlParameter("@Balance", this.Balance));

        }

        #region 支出 + Epend(Transaction transaction, decimal money)

        public void Epend(Transaction transaction, decimal money)

        {

            this.Balance -= money;

            this.Update(transaction);

        }

        #endregion

        #region 收入 + Income(Transaction transaction, decimal money)

        public void Income(Transaction transaction, decimal money)

        {

            this.Balance += money;

            this.Update(transaction);

        }

        #endregion

        public bool TransferOfAccount(string incomeBankaccountnId, decimal money)

        {

            using (var transaction = new CommittableTransaction())

            {

                try

                {

                    Bankaccountn incomeBankaccountn = new Bankaccountn(incomeBankaccountnId);

                    incomeBankaccountn.Income(transaction, money); //收款賬戶入賬

                    this.Epend(transaction, money); //付款賬戶支出

                    transaction.Commit();

                    return true;

                }

                catch 

                {

                    transaction.Rollback();

                    //這里寫做異常信息的記錄的代碼

                    return false; 

                }

            }

        }

    }

}

（3）測試代碼

Bankaccountn one = new Bankaccountn("6666660123456789");

           if (one.TransferOfAccount("6666669876543210", 200M))

           {

               Response.Write("<scr
           }
           else
           {
               Response.Write("<script>alert('轉賬失敗')</script>");
           }
代碼分析：
創建基于 Transaction 類的分布式顯式事務步驟如下：
1）實例化一個可提交的CommittableTransaction對象；
2）將要參與事務的連接通過MySqlConnection對象的EnlistTransaction(Transaction transaction)登記到上一步創建的CommittableTransaction對象上；
3）如果事務可以成功完成，使用CommittableTransaction對象的Commit()方法提交事務處理結果；
4）如果事務處理中發生錯誤，就調用CommittableTransaction對象的Rollback()方法，撤銷每一個修改。
這