c#中SqlTransaction——事務(wù)詳解

來源：本站原創(chuàng)|時間：2020-01-10|欄目：C#教程|點擊：次

事務(wù)處理基本原理

事務(wù)是將一系列操作作為一個單元執(zhí)行，要么成功，要么失敗，回滾到最初狀態(tài)。在事務(wù)處理術(shù)語中，事務(wù)要么提交，要么中止。若要提交事務(wù)，所有參與者都必須保證對數(shù)據(jù)的任何更改是永久的。不論系統(tǒng)崩潰或是發(fā)生其他無法預(yù)料的事件，更改都須是持久的。只要有一個參與者無法做出此保證，整個事務(wù)就會失敗。事務(wù)范圍內(nèi)的所有數(shù)據(jù)更改將回滾到特定設(shè)置點。

事務(wù)將多個操作緊密聯(lián)系到一起，這樣就能保證有聯(lián)系的兩種操作的一致性、以及數(shù)據(jù)的完整性。舉個簡單例子：公司的員工信息管理系統(tǒng)，現(xiàn)在要錄入數(shù)據(jù),員工信息系統(tǒng)假設(shè)只有部門、員工信息兩張表，其中員工信息表中有標(biāo)識部門的字段。在你錄入信息的時候首先你得錄入部門信息，再錄入員工信息。具體實現(xiàn)代碼：

private static void ExecuteSqlTransaction(string connectionString)

    {

      using (SqlConnection connection = new SqlConnection(connectionString))

      {

        connection.Open();

        SqlCommand command = connection.CreateCommand();

        SqlTransaction transaction; 

        transaction = connection.BeginTransaction("SampleTransaction");

        command.Connection = connection;

        command.Transaction = transaction;

        try

        {

          command.CommandText =

            "Insert into Department (ID, Name) VALUES (1, '工程部')";

          command.ExecuteNonQuery();

          command.CommandText =

            "Insert into Users(ID, Name,DepartmentID) VALUES (1, 'xyz',1)";

          command.ExecuteNonQuery();

          transaction.Commit();

        }

        catch (Exception ex)

        {

          transaction.Rollback();

        }

      }

    }

事務(wù)的誤區(qū)

事務(wù)有很多優(yōu)點【原理中已經(jīng)闡述】，由于它的要求比較高，所以注意事務(wù)不能濫用，如果用不好就會造成很大的麻煩。

事務(wù)有一個開頭和一個結(jié)尾，它們指定了事務(wù)的邊界，事務(wù)在其邊界之內(nèi)可以跨越進程和計算機。事務(wù)邊界內(nèi)的所有資源都參與同一個事務(wù)。要維護事務(wù)邊界內(nèi)資源間的一致性，事務(wù)必須具備 ACID 屬性，即原子性、一致性、隔離性和持續(xù)性。這是MSDN的權(quán)威說明。

也許針對一般的小邏輯、小數(shù)據(jù)事務(wù)應(yīng)用非常的高效、可靠。但如果數(shù)據(jù)量很大，在單個事務(wù)中集合的操作繁多而且復(fù)雜，事務(wù)的致命傷就會暴露出來。一個事務(wù)進行時，必須保證邊界資源的原子性、一致性、隔離性和持續(xù)性。

我曾經(jīng)設(shè)計了一個測試用例，測試事務(wù)在執(zhí)行時對資源的利用情況。測試結(jié)果很令人驚訝：在事務(wù)執(zhí)行時，獨占事務(wù)涉及到的數(shù)據(jù)表,造成其它操作詞表的功能，因等待時間過長，而暴跳“獲得數(shù)據(jù)連接超時”的警告。

具體的測試用例：
Transaction

public class TestTransaction
  {
    /// <summary>
    /// 插入新用戶
    /// </summary>
    /// <param name="tran"></param>
    /// <returns></returns>
    private static bool InsertIntoUser(SqlTransaction tran)
    {
      string strSql = @"INSERT INTO [T_User]
                      ([F_Name])
                   VALUES
                      (@F_Name)";
      SqlParameter[] Params ={ new SqlParameter("@F_Name", SqlDbType.VarChar, 20) };
      Params[0].Value="Test1001";
      int count= SqlHelper.ExecuteNonQuery(strSql,Params,tran);
      if (count > 0)
      {
        return true;
      }
      else
      {
        return false;
      }
    }
    /// <summary>
    /// 插入title
    /// </summary>
    /// <returns></returns>
    private static bool InsertIntoTitle(SqlTransaction tran)
    {
      string strSql = @"INSERT INTO [T_User_Title]
                    ([F_TitleName],
                    [F_Remark],
                    [F_Status],
                    [F_EditTime])
                 VALUES
                    (@F_TitleName,
                    @F_Remark,
                    @F_Status,
                    @F_EditTime)";
      SqlParameter[] Params = { 
        new SqlParameter("@F_TitleName",SqlDbType.VarChar, 50), 
        new SqlParameter("@F_Remark", SqlDbType.VarChar, 200), 
        new SqlParameter("@F_Status", SqlDbType.Int, 1), 
        new SqlParameter("@F_EditTime", SqlDbType.DateTime, 8) };
      Params[0].Value = "TestUser1001";
      Params[1].Value = "這是第一次測試";
      Params[2].Value = 1;
      Params[3].Value = DateTime.Now;
      int count = SqlHelper.ExecuteNonQuery(strSql,Params,tran);
      if (count > 0)
      {
        return true;
      }
      else
      {
        return false;
      }
    }
    /// <summary>
    /// 檢測Transaction
    /// </summary>
    /// <returns></returns>
    public static bool InsertWithTran()
    {
      bool success = false;
      string connectionString=System.Configuration.ConfigurationSettings.AppSettings["SqlConStr"].ToString();
      using (SqlConnection con = new SqlConnection(connectionString))
      {
        con.Open();
        SqlTransaction tran = con.BeginTransaction();
        try
        { 
          if (tran == null)
          {
            throw new Exception("Transaction is null");
          }
          if (InsertIntoUser(tran))
          {
            if (InsertIntoTitle(tran))
            {
              tran.Commit();
              success = true;
            }
          }
        }
        catch
        {
          tran.Rollback();
          success = false;
        }
        finally
        {
          tran.Dispose();
          con.Close();
        }
      }
      return success;

    }
  }

Button

 protected void Button1_Click(object sender, EventArgs e)
  {
    bool success = TestTransaction.InsertWithTran();
    if (success)
    {
      Bmc.CLUtility.ShowMessage(this.Page, "插入成功");      
    }
    else
    {
      Bmc.CLUtility.ShowMessage(this.Page, "插入失敗");
    }
  }

測試步驟

<1>運行程序

<2>將運行的地址，發(fā)給在同一個網(wǎng)段的同事，通過適當(dāng)修改也能夠看到你運行的程序

<3>兩人都點擊按鈕，并查詢數(shù)據(jù)庫，看事務(wù)是否正確執(zhí)行

<4>在事務(wù)中間創(chuàng)建斷點，主機點擊按鈕，并在斷點處中斷執(zhí)行一段時間

<5>然后你們連接到數(shù)據(jù)庫，分別查詢表的數(shù)據(jù)，發(fā)現(xiàn)不能執(zhí)行查詢操作。

<6>在同事機器點擊按鈕，查詢windows日志，發(fā)現(xiàn)了一些警告。這就證明了，事務(wù)在執(zhí)行過程中，獨占資源

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持我們。

上一篇：淺談C#中ToString()和Convert.ToString()的區(qū)別

欄目：C#教程

下一篇：詳解如何選擇使用ArrayList、HashTable、List、Dictionary數(shù)組

本文標(biāo)題：c#中SqlTransaction——事務(wù)詳解