注意到其中的sqlcommand對象mycomm，它的commandtext屬性僅僅是前面sql代碼字符串連接起來即可，當然，其中的"go"語句已經全部去掉了。這個語句就像普通的查詢一樣，程序將sql文本事實上提交給dbms去處理了，然后接收返回的結果（如果有結果返回的話）。

很自然，我們最后看到了輸出"事務處理已經成功完成"，再用企業(yè)管理器查看pubs數據庫的roysched表，所有title_id字段以"pc"開頭的書籍的royalty字段的值都增加了0.1倍。

這里，我們并沒有使用ado.net的事務處理機制，而是簡單地將執(zhí)行事務的sql語句當作普通的查詢來執(zhí)行，因此，事實上該事務完全沒有用到.net的相關特性。
了解.net中的事務機制

如你所知，在.net框架中主要有兩個命名空間(namespace)用于應用程序同數據庫系統(tǒng)的交互：system.data.sqlclient和system.data.oledb。前者專門用于連接microsoft公司自己的sql server數據庫，而后者可以適應多種不同的數據庫。這兩個命名空間中都包含有專門用于管理數據庫事務的類，分別是system.data.sqlclient.sqltranscation類和system.data.oledb.oledbtranscation類。

就像它們的名字一樣，這兩個類大部分功能是一樣的，二者之間的主要差別在于它們的連接機制，前者提供一組直接調用 sql server 的對象，而后者使用本機 ole db 啟用數據訪問。 事實上，ado.net 事務完全在數據庫的內部處理，且不受 microsoft 分布式事務處理協(xié)調器 (dtc) 或任何其他事務性機制的支持。本文將主要介紹system.data.sqlclient.sqltranscation類，下面的段落中，除了特別注明，都將使用system.data.sqlclient.sqltranscation類。
事務的開啟和提交

現在我們對事務的概念和原理都了然于心了，并且作為已經有一些基礎的c#開發(fā)者，我們已經熟知編寫數據庫交互程序的一些要點，即使用sqlconnection類的對象的open()方法建立與數據庫服務器的連接，然后將該連接賦給sqlcommand對象的connection屬性，將欲執(zhí)行的sql語句賦給它的commandtext屬性，于是就可以通過sqlcommand對象進行數據庫操作了。對于我們將要編寫的事務處理程序，當然還需要定義一個sqltransaction類型的對象。并且看到sqlcommand對象的transcation屬性，我們很容易想到新建的sqltransaction對象應該與它關聯(lián)起來。

基于以上認識，下面我們就開始動手寫我們的第一個事務處理程序。我們可以很熟練地寫出下面這一段程序：

//dotran.csusing system;
using system.data;
using system.data.sqlclient;
namespace aspcn
{
　 public class dbtran
　 {
　　 file://執(zhí)行事務處理
　　 public void dotran()
　　 {
　　　 file://建立連接并打開
　　　 sqlconnection myconn=getconn();
　　　 myconn.open();
　　　 sqlcommand mycomm=new sqlcommand();
　　　 sqltransaction mytran=new sqltransaction();
　　　 try
　　　 {
　　　 mycomm.connection=myconn;
　　　 mycomm.transaction=mytran;

　　　　 file://定位到pubs數據庫　
　　　　 mycomm.commandtext="use pubs";
　　　　 mycomm.executenonquery();

　　　　 file://更新數據
　　　　 file://將所有的計算機類圖書
　　　　 mycomm.commandtext="update roysched set royalty = royalty * 1.10 where title_id like 'pc%'";
　　　　 mycomm.executenonquery();//提交事務
　　　　 mytran.commit();
　　　 }
　　　 catch(exception err)
　　　 {
　　　　 throw new applicationexception("事務操作出錯，系統(tǒng)信息："+err.message);
　　　 }
　　　 finally
　　　 {
　　　　 myconn.close();
　　　 }
　　 }
　　 file://獲取數據連接
　　 private sqlconnection getconn()
　　 {
　　　 string strsql="data source=localhost;integrated security=sspi;user id=sa;password=";
　　　 sqlconnection myconn=new sqlconnection(strsql);
　　　 return myconn;
　　 }
　 }

　 public class test{public static void main()
　 {
　　 dbtran trantest=new dbtran();
　　 trantest.dotran();
　　 console.writeline("事務處理已經成功完成。");
　　 console.readline();
　 }
}
} 

顯然，這個程序非常簡單，我們非常自信地編譯它，但是，出乎意料的結果使我們的成就感頓時煙消云散：

 error cs1501: 重載"sqltransaction"方法未獲取"0"參數

是什么原因呢？注意到我們初始化的代碼：

sqltransaction mytran=new sqltransaction(); 

顯然，問題出在這里，事實上，sqltransaction類并沒有公共的構造函數，我們不能這樣新建一個sqltrancaction類型的變量。在事務處理之前確實需要有一個sqltransaction類型的變量，將該變量關聯(lián)到sqlcommand類的transcation屬性也是必要的，但是初始化方法卻比較特別一點。在初始化sqltransaction類時，你需要使用sqlconnection類的begintranscation()方法：

sqltransaction mytran; mytran=myconn.begintransaction(); 

該方法返回一個sqltransaction類型的變量。在調用begintransaction()方法以后，所有基于該數據連接對象的sql語句執(zhí)行動作都將被認為是事務mytran的一部分。同時，你也可以在該方法的參數中指定事務隔離級別和事務名稱，如：

sqltransaction mytran;
mytran=myconn.begintransaction(isolationlevel.readcommitted,"sampletransaction"); 

關于隔離級別的概念我們將在隨后的內容中探討，在這里我們只需牢記一個事務是如何被啟動，并且關聯(lián)到特定的數據鏈接的。

先不要急著去搞懂我們的事務都干了些什么，看到這一行：

mytran.commit(); 

是的，這就是事務的提交方式。該語句執(zhí)行后，事務的所有數據庫操作將生效，并且為數據庫事務的持久性機制所保持--即使系統(tǒng)在這以后發(fā)生致命錯誤，該事務對數據庫的影響也不會消失。

對上面的程序做了修改之后我們可以得到如下代碼（為了節(jié)約篇幅，重復之處已省略，請參照前文）：

//dotran.cs……｝

file://執(zhí)行事務處理
public void dotran()
{
　 file://建立連接并打開
　 sqlconnection myconn=getconn();
　 myconn.open();
　 sqlcommand mycomm=new sqlcommand();

　 file://sqltransaction mytran=new sqltransaction();
　 file://注意，sqltransaction類無公開的構造函數

　 sqltransaction mytran;

　 file://創(chuàng)建一個事務
　 mytran=myconn.begintransaction();
　 try
　 {
　　 file://從此開始，基于該連接的數據操作都被認為是事務的一部分
　　 file://下面綁定連接和事務對象
　　 mycomm.connection=myconn;
　　 mycomm.transaction=mytran; file://定位到pubs數據庫
　　 mycomm.commandtext="use pubs";
　　 mycomm.executenonquery();//更新數據
　　 file://將所有的計算機類圖書
　　 mycomm.commandtext="update roysched set royalty = royalty * 1.10 where title_id like 'pc%'";
　　 mycomm.executenonquery();

　　 file://提交事務
　　 mytran.commit();
　 }
　 catch(exception err)
　 {
　　 throw new applicationexception("事務操作出錯，系統(tǒng)信息："+err.message);
　 }
　 finally
　 {
　　 myconn.close();
　 }
}
…… 

到此為止，我們僅僅掌握了如何開始和提交事務。下一步我們必須考慮的是在事務中可以干什么和不可以干什么。

另一個走向極端的錯誤

滿懷信心的新手們可能為自己所掌握的部分知識陶醉不已，剛接觸數據庫庫事務處理的準開發(fā)者們也一樣，躊躇滿志地準備將事務機制應用到他的數據處理程序的每一個模塊每一條語句中去。的確，事務機制看起來是如此的誘人——簡潔、美妙而又實用，我當然想用它來避免一切可能出現的錯誤——我甚至想用事務把我的數據操作從頭到尾包裹起來。

看著吧，下面我要從創(chuàng)建一個數據庫開始：

using system;
using system.data;
using system.data.sqlclient;

namespace aspcn
{
　 public class dbtran
　 {
　　 file://執(zhí)行事務處理
　　 public void dotran()
　　 {
　　　 file://建立連接并打開
　　　 sqlconnection myconn=getconn();
　　　 myconn.open();

　　　 sqlcommand mycomm=new sqlcommand();
　　　 sqltransaction mytran;

　　　 mytran=myconn.begintransaction();

　　　 file://下面綁定連接和事務對象
　　　 mycomm.connection=myconn;
　　　 mycomm.transaction=mytran;

　　　 file://試圖創(chuàng)建數據庫testdb
　　　 mycomm.commandtext="create database testdb";
　　　 mycomm.executenonquery();

　　　 file://提交事務
　　　 mytran.commit();
　　 }

　　 file://獲取數據連接
　　 private sqlconnection getconn()
　　 {
　　　 string strsql="data source=localhost;integrated security=sspi;user id=sa;password=";
　　　 sqlconnection myconn=new sqlconnection(strsql);
　　　 return myconn;
　　 }
　 }

　 public class test
　 {
　　 public static void main()
　　 {
　　　 dbtran trantest=new dbtran();
　　　 trantest.dotran();
　　　 console.writeline("事務處理已經成功完成。");
　　　 console.readline();
　　 }
　 }
}

//--------------- 

　　未處理的異常： system.data.sqlclient.sqlexception: 在多語句事務內不允許使用 create database 語句。

at system.data.sqlclient.sqlcommand.executenonquery()
at aspcn.dbtran.dotran()
at aspcn.test.main() 

注意，如下的sql語句不允許出現在事務中：

alter database  修改數據庫 
backup log  備份日志 
create database  創(chuàng)建數據庫 
disk init  創(chuàng)建數據庫或事務日志設備 
drop database  刪除數據庫 
dump transaction  轉儲事務日志 
load database  裝載數據庫備份復本 
load transaction  裝載事務日志備份復本 
reconfigure  更新使用 sp_configure 系統(tǒng)存儲過程更改的配置選項的當前配置（sp_configure 結果集中的 config_value 列）值。 
restore database  還原使用backup命令所作的數據庫備份 
restore log  還原使用backup命令所作的日志備份 
update statistics  在指定的表或索引視圖中，對一個或多個統(tǒng)計組（集合）有關鍵值分發(fā)的信息進行更新 

除了這些語句以外，你可以在你的數據庫事務中使用任何合法的sql語句。
事務回滾

事務的四個特性之一是原子性，其含義是指對于特定操作序列組成的事務，要么全部完成，要么就一件也不做。如果在事務處理的過程中，發(fā)生未知的不可預料的錯誤，如何保證事務的原子性呢？當事務中止時，必須執(zhí)行回滾操作，以便消除已經執(zhí)行的操作對數據庫的影響。

一般的情況下，在異常處理中使用回滾動作是比較好的想法。前面，我們已經得到了一個更新數據庫的程序，并且驗證了它的正確性，稍微修改一下，可以得到：

//rollback.cs
using system;
using system.data;
using system.data.sqlclient;

namespace aspcn
{
　 public class dbtran
　 {
　　 file://執(zhí)行事務處理
　　 public void dotran()
　　 {
　　　 file://建立連接并打開
　　　 sqlconnection myconn=getconn();
　　　 myconn.open();

　　　 sqlcommand mycomm=new sqlcommand();
　　　 sqltransaction mytran;

　　　 file://創(chuàng)建一個事務
　　　 mytran=myconn.begintransaction();
　　　 file://從此開始，基于該連接的數據操作都被認為是事務的一部分
　　　 file://下面綁定連接和事務對象
　　　 mycomm.connection=myconn;
　　　 mycomm.transaction=mytran;

　　　 try
　　　 {
　　　　 file://定位到pubs數據庫
　　　　 mycomm.commandtext="use pubs";
　　　　 mycomm.executenonquery();

　　　　 mycomm.commandtext="update roysched set royalty = royalty * 1.10 where title_id like 'pc%'";
　　　　 mycomm.executenonquery();

　　　　 file://下面使用創(chuàng)建數據庫的語句制造一個錯誤
　　　　 mycomm.commandtext="create database testdb";
　　　　 mycomm.executenonquery();

　　　　 mycomm.commandtext="update roysched set royalty = royalty * 1.20 where title_id like 'ps%'";
　　　　 mycomm.executenonquery();

　　　　 file://提交事務
　　　　 mytran.commit();
　　　 }
　　　 catch(exception err)
　　　 {
　　　　 mytran.rollback();
　　　　 console.write("事務操作出錯，已回滾。系統(tǒng)信息："+err.message);
　　　 }
　　 }

　　 file://獲取數據連接
　　 private sqlconnection getconn()
　　 {
　　　 string strsql="data source=localhost;integrated security=sspi;user id=sa;password=";
　　　 sqlconnection myconn=new sqlconnection(strsql);
　　　 return myconn;
　　 }
　 }
　 public class test
　 {
　　 public static void main()
　　 {
　　　 dbtran trantest=new dbtran();
　　　 trantest.dotran();
　　　 console.writeline("事務處理已經成功完成。");
　　　 console.readline();
　　 }
　 }
} 

首先，我們在中間人為地制造了一個錯誤——使用前面講過的create database語句。然后，在異常處理的catch塊中有如下語句：

mytran.rollback();

當異常發(fā)生時，程序執(zhí)行流跳轉到catch塊中，首先執(zhí)行的就是這條語句，它將當前事務回滾。在這段程序可以看出，在create database之前，已經有了一個更新數據庫的操作——將pubs數據庫的roysched表中的所有title_id字段以“pc”開頭的書籍的royalty字段的值都增加0.1倍。但是，由于異常發(fā)生而導致的回滾使得對于數據庫來說什么都沒有發(fā)生。由此可見，rollback()方法維護了數據庫的一致性及事務的原子性。

使用存儲點

事務只是一種最壞情況下的保障措施，事實上，平時系統(tǒng)的運行可靠性都是相當高的，錯誤很少發(fā)生，因此，在每次事務執(zhí)行之前都檢查其有效性顯得代價太高——絕大多數的情況下這種耗時的檢查是不必要的。我們不得不想另外一種辦法來提高效率。

事務存儲點提供了一種機制，用于回滾部分事務。因此，我們可以不必在更新之前檢查更新的有效性，而是預設一個存儲點，在更新之后，如果沒有出現錯誤，就繼續(xù)執(zhí)行，否則回滾到更新之前的存儲點。存儲點的作用就在于此。要注意的是，更新和回滾代價很大，只有在遇到錯誤的可能性很小，而且預先檢查更新的有效性的代價相對很高的情況下，使用存儲點才會非常有效。

使用.net框架編程時，你可以非常簡單地定義事務存儲點和回滾到特定的存儲點。下面的語句定義了一個存儲點“noupdate”：

mytran.save("noupdate");

當你在程序中創(chuàng)建同名的存儲點時，新創(chuàng)建的存儲點將替代原有的存儲點。

在回滾事務時，只需使用rollback()方法的一個重載函數即可：

　　 mytran.rollback("noupdate");

下面這段程序說明了回滾到存儲點的方法和時機：
using system;
using system.data;
using system.data.sqlclient;

namespace aspcn
{
　 public class dbtran
　 {　
　　 file://執(zhí)行事務處理
　　 public void dotran()
　　 {
　　　 file://建立連接并打開
　　　 sqlconnection myconn=getconn();
　　　 myconn.open();

　　　 sqlcommand mycomm=new sqlcommand();
　　　 sqltransaction mytran;

　　　 file://創(chuàng)建一個事務
　　　 mytran=myconn.begintransaction();
　　　 file://從此開始，基于該連接的數據操作都被認為是事務的一部分
　　　 file://下面綁定連接和事務對象
　　　 mycomm.connection=myconn;
　　　 mycomm.transaction=mytran;

　　　 try
　　　 {
　　　　 mycomm.commandtext="use pubs";
　　　　 mycomm.executenonquery();

　　　　 mytran.save("noupdate");

　　　　 mycomm.commandtext="update roysched set royalty = royalty * 1.10 where title_id like 'pc%'";
　　　　 mycomm.executenonquery();

　　　　 file://提交事務
　　　　 mytran.commit();
　　　 }
　　　 catch(exception err)
　　　 {
　　　　 file://更新錯誤，回滾到指定存儲點
　　　　 mytran.rollback("noupdate");
　　　　 throw new applicationexception("事務操作出錯，系統(tǒng)信息："+err.message);
　　　 }
　　 }

　　 file://獲取數據連接
　　 private sqlconnection getconn()
　　 {
　　　 string strsql="data source=localhost;integrated security=sspi;user id=sa;password=";
　　　 sqlconnection myconn=new sqlconnection(strsql);
　　　 return myconn;
　　 }
　 }
　 public class test
　 {
　　 public static void main()
　　 {
　　　 dbtran trantest=new dbtran();
　　　 trantest.dotran();
　　　 console.writeline("事務處理已經成功完成。");
　　　 console.readline();
　　 }
　 }
}
 

很明顯，在這個程序中，更新無效的幾率是非常小的，而且在更新前驗證其有效性的代價相當高，因此我們無須在更新之前驗證其有效性，而是結合事務的存儲點機制，提供了數據完整性的保證。

隔離級別的概念

企業(yè)級的數據庫每一秒鐘都可能應付成千上萬的并發(fā)訪問，因而帶來了并發(fā)控制的問題。由數據庫理論可知，由于并發(fā)訪問，在不可預料的時刻可能引發(fā)如下幾個可以預料的問題：

臟讀 ：包含未提交數據的讀取。例如，事務1 更改了某行。事務2 在事務1 提交更改之前讀取已更改的行。如果事務1 回滾更改，則事務2 便讀取了邏輯上從未存在過的行。

不可重復讀取 ：當某個事務不止一次讀取同一行，并且一個單獨的事務在兩次（或多次）讀取之間修改該行時，因為在同一個事務內的多次讀取之間修改了該行，所以每次讀取都生成不同值，從而引發(fā)不一致問題。

幻象 ：通過一個任務，在以前由另一個尚未提交其事務的任務讀取的行的范圍中插入新行或刪除現有行。帶有未提交事務的任務由于該范圍中行數的更改而無法重復其原始讀取。

如你所想，這些情況發(fā)生的根本原因都是因為在并發(fā)訪問的時候，沒有一個機制避免交叉存取所造成的。而隔離級別的設置，正是為了避免這些情況的發(fā)生。事務準備接受不一致數據的級別稱為隔離級別。隔離級別是一個事務必須與其它事務進行隔離的程度。較低的隔離級別可以增加并發(fā)，但代價是降低數據的正確性。相反，較高的隔離級別可以確保數據的正確性，但可能對并發(fā)產生負面影響。

根據隔離級別的不同，dbms為并行訪問提供不同的互斥保證。在sql server數據庫中，提供四種隔離級別：未提交讀、提交讀、可重復讀、可串行讀。這四種隔離級別可以不同程度地保證并發(fā)的數據完整性：
隔離級別  臟 讀  不可重復讀取  幻 像 
未提交讀  是  是  是 
提交讀  否  是  是 
可重復讀  否  否  是 
可串行讀  否  否  否 

可以看出，“可串行讀”提供了最高級別的隔離，這時并發(fā)事務的執(zhí)行結果將與串行執(zhí)行的完全一致。如前所述，最高級別的隔離也就意味著最低程度的并發(fā)，因此，在此隔離級別下，數據庫的服務效率事實上是比較低的。盡管可串行性對于事務確保數據庫中的數據在所有時間內的正確性相當重要，然而許多事務并不總是要求完全的隔離。例如，多個作者工作于同一本書的不同章節(jié)。新章節(jié)可以在任意時候提交到項目中。但是，對于已經編輯過的章節(jié)，沒有編輯人員的批準，作者不能對此章節(jié)進行任何更改。這樣，盡管有未編輯的新章節(jié)，但編輯人員仍可以確保在任意時間該書籍項目的正確性。編輯人員可以查看以前編輯的章節(jié)以及最近提交的章節(jié)。這樣，其它的幾種隔離級別也有其存在的意義。

在.net框架中，事務的隔離級別是由枚舉system.data.isolationlevel所定義的：

[flags]
[serializable]
public enum isolationlevel 

其成員及相應的含義如下：

成 員  含 義 
chaos  無法改寫隔離級別更高的事務中的掛起的更改。 
readcommitted  在正在讀取數據時保持共享鎖，以避免臟讀，但是在事務結束之前可以更改數據，從而導致不可重復的讀取或幻像數據。 
readuncommitted  可以進行臟讀，意思是說，不發(fā)布共享鎖，也不接受獨占鎖。 
repeatableread  在查詢中使用的所有數據上放置鎖，以防止其他用戶更新這些數據。防止不可重復的讀取，但是仍可以有幻像行。 
serializable  在dataset上放置范圍鎖，以防止在事務完成之前由其他用戶更新行或向數據集中插入行。 
unspecified  正在使用與指定隔離級別不同的隔離級別，但是無法確定該級別。
 

顯而意見，數據庫的四個隔離級別在這里都有映射。

默認的情況下，sql server使用readcommitted(提交讀)隔離級別。

關于隔離級別的最后一點就是如果你在事務執(zhí)行的過程中改變了隔離級別，那么后面的命名都在最新的隔離級別下執(zhí)行——隔離級別的改變是立即生效的。有了這一點，你可以在你的事務中更靈活地使用隔離級別從而達到更高的效率和并發(fā)安全性。

最后的忠告