快捷導(dǎo)航

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

更新時(shí)間：2016年12月01日 09:44:03 作者：停留的風(fēng)

這篇文章主要介紹了c#中SqlTransaction——事務(wù)詳解，具有一定的參考價(jià)值，有興趣的可以了解一下。

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

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

事務(wù)將多個(gè)操作緊密聯(lián)系到一起，這樣就能保證有聯(lián)系的兩種操作的一致性、以及數(shù)據(jù)的完整性。舉個(gè)簡(jiǎn)單例子：公司的員工信息管理系統(tǒng)，現(xiàn)在要錄入數(shù)據(jù),員工信息系統(tǒng)假設(shè)只有部門(mén)、員工信息兩張表，其中員工信息表中有標(biāo)識(shí)部門(mén)的字段。在你錄入信息的時(shí)候首先你得錄入部門(mén)信息，再錄入員工信息。具體實(shí)現(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)點(diǎn)【原理中已經(jīng)闡述】，由于它的要求比較高，所以注意事務(wù)不能濫用，如果用不好就會(huì)造成很大的麻煩。

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

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

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

具體的測(cè)試用例：
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 = "這是第一次測(cè)試";
      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>
    /// 檢測(cè)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, "插入失敗");
    }
  }

測(cè)試步驟

<1>運(yùn)行程序

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

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

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

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

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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: