
在vb點(diǎn)虐 中握轎要定義一個(gè)事務(wù),需要使用Begin tran命令,在這一命令之后的任何語句都慶裂將被認(rèn)為是事務(wù)的一部分。命令Commit用來完成VB.NET處理,并使事務(wù)對(duì)數(shù)據(jù)庫所作的修改成為永久的。Rollback命令用譽(yù)皮閉來取消一個(gè)事務(wù),并還原事務(wù)對(duì)數(shù)據(jù)庫所作的修改。

黃埔網(wǎng)站制作公司哪家好,找成都創(chuàng)新互聯(lián)公司!從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、成都響應(yīng)式網(wǎng)站建設(shè)公司等網(wǎng)站項(xiàng)目制作,到程序開發(fā),運(yùn)營維護(hù)。成都創(chuàng)新互聯(lián)公司從2013年創(chuàng)立到現(xiàn)在10年的時(shí)間,我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn),來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選成都創(chuàng)新互聯(lián)公司。
事務(wù)處理是在數(shù)據(jù)處理時(shí)經(jīng)常遇到的問題,經(jīng)常用到的方法有以下3種總結(jié)整理如下:
方法1:直接寫入到sql?中
在存儲(chǔ)過程中使用?BEGIN?TRANS,?COMMIT?TRANS,?ROLLBACK?TRANS?實(shí)現(xiàn)
begin?trans
declare?@orderDetailsError?int,@procuntError?int
delete?from?[order?details]?where?productid=42
select?@orderDetailsError?=@@error
delete?from?products?where?productid=42
select?@procuntError=@@error
if(@orderDetailsError?=0?and?@procuntError=0)
COMMIT?TRANS
else
ROLLBACK?TRANS
優(yōu)點(diǎn):
所有事務(wù)邏輯包含在一個(gè)單獨(dú)的調(diào)用中
擁有運(yùn)行一個(gè)事務(wù)的最佳性能
獨(dú)立于應(yīng)用程序
限制:
事務(wù)上下文僅存在于數(shù)據(jù)庫調(diào)用中
數(shù)據(jù)庫代碼與數(shù)據(jù)庫系統(tǒng)有關(guān)
方法2?:使用ADO.NET?實(shí)現(xiàn)?
使用ADO.NET?實(shí)現(xiàn),使用這種方式的優(yōu)點(diǎn)是可以在中間層來管理事務(wù),當(dāng)然你也可以選擇在數(shù)據(jù)層來實(shí)現(xiàn)。
SqlConnection?和OleDbConnection??對(duì)象有一個(gè)?BeginTransaction?方法,它可以返回?SqlTransaction
或者OleDbTransaction?對(duì)象。而且這個(gè)對(duì)象有?Commit?和?Rollback?方法來管理事務(wù)
SqlConnection?sqlConnection?=?new?SqlConnection("workstation?id=WEIXIAOPING;packet?size=4096;user?id=sa;initial?catalog=Northwind;persist?security?info=False");
sqlConnection.Open();
SqlTransaction??myTrans?=?sqlConnection.BeginTransaction();
SqlCommand?sqlInsertCommand?=?new?SqlCommand();
sqlInsertCommand.Connection?=?sqlConnection
sqlInsertCommand.Transaction=myTrans;
try{
sqlInsertCommand.CommandText="insert?into?tbTree(Context,ParentID)?values('北京',1)";
sqlInsertCommand.ExecuteNonQuery();
sqlInsertCommand.CommandText="insert?into?tbTree(Context,ParentID)?values('上海',1)";
sqlInsertCommand.ExecuteNonQuery();
myTrans.Commit();
}catch(Exception?ex)
{
myTrans.Rollback();
}
finally
{
sqlConnection.Close();
}
優(yōu)點(diǎn):
簡單性
和數(shù)據(jù)據(jù)事務(wù)差不多的快
獨(dú)立于數(shù)據(jù)庫,不同數(shù)據(jù)庫的專有代碼被隱藏了
缺點(diǎn):
事務(wù)不能跨越多個(gè)數(shù)據(jù)庫連接
事務(wù)執(zhí)行在數(shù)據(jù)庫連接層上,所以需要在銀山仿事務(wù)過程中維護(hù)一個(gè)數(shù)據(jù)庫連接
ADO.NET分布事務(wù)也唯基可以跨越多個(gè)數(shù)據(jù)庫,但是其中一個(gè)SQL?SERVER?數(shù)據(jù)庫的話,通過用SQL?SERVER連接服務(wù)器連接到別的數(shù)據(jù)庫,但是如果是在DB2和Orcal之間就不可以。
以上兩種事務(wù)是經(jīng)常用到的事務(wù)處理方法。
方法3??COM+事務(wù)(分布式事務(wù))
.NET?Framework?依靠?MTS/COM+?服務(wù)鋒纖來支持自動(dòng)事務(wù)。COM+?使用?Microsoft?Distributed?Transaction?Coordinator?(DTC)?作為事務(wù)管理器和事務(wù)協(xié)調(diào)器在分布式環(huán)境中運(yùn)行事務(wù)。
這樣可使?.NET?應(yīng)用程序運(yùn)行跨多個(gè)資源結(jié)合不同操作(例如,將定單插入?SQL?Server?數(shù)據(jù)庫、將消息寫入?Microsoft?消息隊(duì)列?(MSMQ)?隊(duì)列、以及從?Oracle?數(shù)據(jù)庫檢索數(shù)據(jù))
的事務(wù)。
COM+事務(wù)處理的類必須繼承System.EnterpriseServices.ServicedComponent,其實(shí)web?service就是繼承System.EnterpriseServices.ServicedComponent,所以web?service也支持
COM+事務(wù)。
定義一個(gè)COM+事務(wù)處理的類
[Transaction(TransactionOption.Required)]
public?class?DataAccess:System.EnterpriseServices.ServicedComponent
{
}
TransactionOption枚舉類型支持5個(gè)COM+值(Disabled,NotSupported,Required,RequiresNew,Supported)
Disabled??????忽略當(dāng)前上下文中的任何事務(wù)。
NotSupported??使用非受控事務(wù)在上下文中創(chuàng)建組件。
Required??????如果事務(wù)存在則共享事務(wù),并且如有必要?jiǎng)t創(chuàng)建新事務(wù)。
RequiresNew???使用新事務(wù)創(chuàng)建組件,而與當(dāng)前上下文的狀態(tài)無關(guān)。
Supported?????如果事務(wù)存在,則共享該事務(wù)。
一般來說COM+中的組件需要Required?或Supported。當(dāng)組件用于記錄或查帳時(shí)RequiresNew?很有用,因?yàn)榻M件應(yīng)該與活動(dòng)中其他事務(wù)處理的提交或回滾隔離開來。
派生類可以重載基類的任意屬性。如DataAccess選用Required,派生類仍然可以重載并指定RequiresNew或其他值。
COM+事務(wù)有手動(dòng)處理和自動(dòng)處理,自動(dòng)處理就是在所需要自動(dòng)處理的方法前加上[AutoComplete],根據(jù)方法的正常或拋出異常決定提交或回滾。
手動(dòng)處理就是調(diào)用ContextUtil類中EnableCommit,SetComplete,SetAbort方法。
public?string??testTransaction()
{
try
{
ContextUtil.EnableCommit();
InsertARecord1();
InsertARecord2();
ContextUtil.SetComplete();
return?"succeed!";
}
catch(Exception?ex)
{
ContextUtil.SetAbort();
return?"failed!";
}
}
public?void?InsertARecord1()
{
string?strconn="workstation?id=WEIXIAOPING;packet?size=4096;user?id=sa;initial?catalog=Northwind;persist?security?info=False";
SqlConnection?conn=new?SqlConnection(strconn);
conn.Open();
SqlCommand?command=new?SqlCommand("insert?into?tbTree(Context,ParentID)?values('北京',1)",conn);
command.ExecuteNonQuery();
conn.Close();
}
public?void?InsertARecord2()
{
string?strconn="workstation?id=WEIXIAOPING;packet?size=4096;user?id=sa;initial?catalog=Northwind;persist?security?info=False";
SqlConnection?conn=new?SqlConnection(strconn);
conn.Open();
SqlCommand?command=new?SqlCommand("insert?into?tbTree(Context,ParentID)?values('上海',1)",conn);
command.ExecuteNonQuery();
conn.Close();
}
在需要事務(wù)跨?MSMQ?和其他可識(shí)別事務(wù)的資源(例如,SQL?Server?數(shù)據(jù)庫)運(yùn)行的系統(tǒng)中,只能使用?DTC?或?COM+?事務(wù),除此之外沒有其他選擇。DTC?協(xié)調(diào)參與分布式事務(wù)的所有資源管理器, ?也管理與事務(wù)相關(guān)的操作。
這種做法的缺點(diǎn)是,由于存在?DTC?和?COM?互操作性開銷,導(dǎo)致性能降低。
COM+事務(wù)處理的類必須強(qiáng)命名。
Oracle.DataAccess.Client 命名空間是 ODP.NET 的一部分,它包含許多類,其中有OracleConnection、OracleCommand 和 OracleTransaction。示例程序用到了這些類。 VB.NET使用ORACLR第 1 步創(chuàng)建一個(gè) OracleConnection 對(duì)象連接到 Oracle 數(shù)據(jù)庫,然后打開該連接。
在C# 中:OracleConnection myOracleConnection =new OracleConnection( "User Id=store;Password=store;Data Source=ORCL" ); myOracleConnection.Open(); 在VB.NET 中:Dim myOracleConnection As New OracleConnection( _ "User Id=store;Password=store;Data Source=ORCL") myOracleConnection.Open() User Id 和 Password 屬性指定了您所要連接到的模式的數(shù)據(jù)庫用戶和口令。Data Source 屬性指定了數(shù)據(jù)庫的 Oracle Net 服務(wù)名稱;初始數(shù)據(jù)庫的默認(rèn)服務(wù)名稱為 ORCL。如果您使用的不是初始數(shù)據(jù)庫,或者您的服務(wù)名稱不同,那么您需要在程序中修改 Data Source 屬性的設(shè)置。 VB.NET使用ORACLR第 2 步創(chuàng)建一個(gè) OracleTransaction 對(duì)象,然后調(diào)用 OracleConnection 對(duì)象的 BeginTransaction() 方法啟動(dòng)事務(wù)。 在C# 中:OracleTransaction myOracleTransaction = myOracleConnection.BeginTransaction(); In VB.NET: Dim myOracleTransaction As OracleTransaction = _ myOracleConnection.BeginTransaction() VB.NET使用ORACLR第3 步創(chuàng)建一個(gè) OracleCommand 對(duì)象,用于存儲(chǔ) SQL 語句。 在C# 中:OracleCommand myOracleCommand = myOracleConnection.CreateCommand(); 在VB.NET 中:Dim myOracleCommand As OracleCommand = myOracleConnection.CreateCommand 因?yàn)镺racleCommand 對(duì)象使用 OracleConnection 對(duì)象的 CreateCommand() 方法創(chuàng)建的,所以它伍散自動(dòng)使用在第 2 步中為 OracleConnection 對(duì)象設(shè)置的事務(wù)。 VB.NET使用ORACLR第 4 步將OracleCommand 對(duì)象的 CommandText 屬性設(shè)為向表 product_types 中添加一行的第一條 INSERT 語句。
在C# 中:myOracleCommand.CommandText = "INSERT INTO product_types ("兄橘襪 + " product_type_id, name" + ") VALUES (" + " 3, 'Magazine'" + ")"; 在VB.NET 中:myOracleCommand.CommandText = _ "INSERT INTO product_types (" _ " product_type_id, name" _ ") VALUES (" _ " 3, 'Magazine'"羨激 _ ")" VB.NET使用ORACLR第 5 步
使用OracleCommand 對(duì)象的 ExecuteNonQuery() 方法運(yùn)行 INSERT 語句。
在C# 中:myOracleCommand.ExecuteNonQuery(); 在VB.NET 中:myOracleCommand.ExecuteNonQuery(); VB.NET使用ORACLR第 6 和第 7 步將OracleCommand 對(duì)象的 CommandText 屬性設(shè)為向表 Products 中添加一行的第二條 INSERT 語句,并運(yùn)行它。
在C# 中:myOracleCommand.CommandText = "INSERT INTO products (" + " product_id, product_type_id, name, description, price" + ") VALUES (" + " 5, 3, 'Oracle Magazine', 'Magazine about Oracle', 4.99" + ")"; myOracleCommand.ExecuteNonQuery(); 在VB.NET 中:myOracleCommand.CommandText = _ "INSERT INTO products (" _ " product_id, product_type_id, name, description, price" _ ") VALUES (" _ " 5, 3, 'Oracle Magazine', 'Magazine about Oracle', 4.99" _ ")" myOracleCommand.ExecuteNonQuery() VB.NET使用ORACLR第 8 步使用OracleTransaction 對(duì)象的 Commit() 方法提交數(shù)據(jù)庫中的事務(wù)。
在C# 中:myOracleTransaction.Commit(); 在VB.NET 中:myOracleTransaction.Commit() 在完成 Commit() 方法之后,由 INSERT 語句添加的兩行將在數(shù)據(jù)庫中永久記錄。 VB.NET使用ORACLR第 9 步使用Close() 方法關(guān)閉 OracleConnection 對(duì)象。在C# 中:myOracleConnection.Close(); 在VB.NET 中: myOracleConnection.Close() 編譯并運(yùn)行示例程序要編譯 C# 示例程序,您可以使用 csc 命令運(yùn)行 C# 編譯器。因?yàn)槌绦蚴褂?Oracle Data Access DLL,所以您應(yīng)使用 /r 選項(xiàng)指定該 DLL 的完整路徑,例如:注意:您需要用您計(jì)算機(jī)上的相應(yīng)路徑來替換該 DLL 的路徑。此外,如果您的計(jì)算機(jī)找不到 csc 編譯器,那么您可能需要運(yùn)行 Microsoft sdkvars.bat 腳本來首先設(shè)置 .NET SDK 的環(huán)境變量;您可以在安裝 .NET SDK 的 bin 目錄中找到該腳本。 如果您遇到以下錯(cuò)誤:Example1.cs(10,7):error CS0246:The type or namespace name 'Oracle' could not be found (are you missing a using directive or an assembly reference?) 這說明您沒有在編譯命令中正確指定 Oracle Data Access DLL。(有關(guān)設(shè)置的信息,請(qǐng)參閱 John Paul Cook 的技術(shù)文章“在 Oracle 數(shù)據(jù)庫上構(gòu)建 .NET 應(yīng)用程序”。) 下面是用于編譯 VB.NET 程序的等價(jià)命令:vbc TransExample1.vb /r:C:\oracle\product\10.1.0\ Client_1\bin\Oracle.DataAccess.dll /r:system.dll /r:system.data.dll 接下來,輸入以下命令,運(yùn)行示例: An exception was thrown Message = ORA-12514:TNS:listener does not currently know of service requested in connect descriptor 您將看到程序的輸出。不過,如果您遇到類似以下的異常這說明 OracleConnection 對(duì)象的連接字符串中的 Data Source 的設(shè)置不正確。您應(yīng)當(dāng)咨詢您的 DBA 或查閱 Oracle Net 文檔以獲得更多詳細(xì)信息。 如果您使用的是 VS .NET,那么您可以遵循以下指示來編譯和運(yùn)行 C# 程序 TransExample1.cs:
創(chuàng)建一個(gè)新的 C# 控制臺(tái)應(yīng)用程序。FileNew Project,然后選擇 Visual C# Projects,Console Application。