簡單介紹C# SQL Server
體驗SQL語言的事務機制
作為大型的企業級數據庫,C# SQL Server2000對事務提供了很好的支持。我們可以使用SQL語句來定義、提交以及回滾一個事務。
如下所示的SQL代碼定義了一個事務,并且命名為"MyTransaction
這里用到了C# SQL Server2000自帶的示例數據庫pubs,提交事務后,將為所有暢銷計算機書籍支付的版稅增加 10%。
打開C# SQL Server2000的查詢分析器,選擇pubs數據庫,然后運行這段程序,結果顯而易見。
可是如何在C#程序中運行呢?我們記得在普通的SQL查詢中,一般需要把查詢語句賦值給SalCommand.CommandText屬性,這里也就像普通的SQL查詢語句一樣,將這些語句賦給SqlCommand.CommandText屬性即可。要注意的一點是,其中的"GO"語句標志著SQL批處理的結束,編寫SQL腳本是需要的,但是在這里是不必要的。我們可以編寫如下的程序來驗證這個想法:
- //TranSql.csusingSystem;
- usingSystem.Data;
- usingSystem.Data.SqlClient;
- namespaceAspcn
- {
- publicclassDbTranSql
- {
- file://將事務放到SQLServer中執行
- publicvoidDoTran()
- {
- file://建立連接并打開
- SqlConnectionmyConn=GetConn();myConn.Open();
- SqlCommandmyComm=newSqlCommand();
- try
- {
- myComm.Connection=myConn;
- myComm.CommandText="DECLARE@TranNameVARCHAR(20)";
- myComm.CommandText+="SELECT@TranName='MyTransaction'";
- myComm.CommandText+="BEGINTRANSACTION@TranName";
- myComm.CommandText+="USEpubs";
- myComm.CommandText+="UPDATEroyschedSETroyalty=royalty*1.10WHEREtitle_idLIKE'Pc%'";
- myComm.CommandText+="COMMITTRANSACTIONMyTransaction";
- myComm.ExecuteNonQuery();
- }
- catch(Exceptionerr)
- {
- thrownewApplicationException("事務操作出錯,系統信息:"+err.Message);
- }
- finally
- {
- myConn.Close();
- }
- }
- file://獲取數據連接
- privateSqlConnectionGetConn()
- {
- stringstrSql="DataSource=localhost;IntegratedSecurity=SSPI;userid=sa;password=";
- SqlConnectionmyConn=newSqlConnection(strSql);
- returnmyConn;
- }
- }
- publicclassTest
- {
- publicstaticvoidMain()
- {
- DbTranSqltranTest=newDbTranSql();
- tranTest.DoTran();
- Console.WriteLine("事務處理已經成功完成。");
- Console.ReadLine();
- }
- }
- }
注意到其中的SqlCommand對象myComm,它的CommandText屬性僅僅是前面SQL代碼字符串連接起來即可,當然,其中的"GO"語句已經全部去掉了。這個語句就像普通的查詢一樣,程序將SQL文本事實上提交給DBMS去處理了,然后接收返回的結果(如果有結果返回的話)。
很自然,我們最后看到了輸出"事務處理已經成功完成",再用企業管理器查看pubs數據庫的roysched表,所有title_id字段以"PC"開頭的書籍的royalty字段的值都增加了0.1倍。
這里,我們并沒有使用ADO.net的事務處理機制,而是簡單地將執行事務的SQL語句當作普通的查詢來執行,因此,事實上該事務完全沒有用到.net的相關特性。
了解.net中的事務機制
如你所知,在.net框架中主要有兩個命名空間(namespace)用于應用程序同數據庫系統的交互:System.Data.SqlClient和System.Data.OleDb。前者專門用于連接Microsoft公司自己的SQL Server數據庫,而后者可以適應多種不同的數據庫。這兩個命名空間中都包含有專門用于管理數據庫事務的類,分別是System.Data.SqlClient.SqlTranscation類和System.Data.OleDb.OleDbTranscation類。
就像它們的名字一樣,這兩個類大部分功能是一樣的,二者之間的主要差別在于它們的連接機制,前者提供一組直接調用C# SQL Server 的對象,而后者使用本機 OLE DB 啟用數據訪問。 事實上,ADO.net 事務完全在數據庫的內部處理,且不受 Microsoft 分布式事務處理協調器 (DTC) 或任何其他事務性機制的支持。本文將主要介紹System.Data.SqlClient.SqlTranscation類,下面的段落中,除了特別注明,都將使用System.Data.SqlClient.SqlTranscation類。
【編輯推薦】