在.NET 中使用Oracle數(shù)據(jù)庫(kù)事務(wù)

在 VB.NET 中：

myOracleCommand.CommandText = _
"INSERT INTO product_types (" & _
"  product_type_id, name" & _
") VALUES (" & _
"  3, 'Magazine'" & _
  ")"

第 5 步

使用 OracleCommand 對(duì)象的 ExecuteNonQuery() 方法運(yùn)行 INSERT 語(yǔ)句。

在 C# 中：

myOracleCommand.ExecuteNonQuery();

在 VB.NET 中：

myOracleCommand.ExecuteNonQuery()

第 6 和第 7 步

將 OracleCommand 對(duì)象的 CommandText 屬性設(shè)為向表 Products 中添加一行的第二條 INSERT 語(yǔ)句，并運(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()

第 8 步

使用 OracleTransaction 對(duì)象的 Commit() 方法提交數(shù)據(jù)庫(kù)中的事務(wù)。

在 C# 中：

myOracleTransaction.Commit();

在 VB.NET 中：

myOracleTransaction.Commit()

在完成 Commit() 方法之后，由 INSERT 語(yǔ)句添加的兩行將在數(shù)據(jù)庫(kù)中永久記錄。

第 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 的完整路徑，例如：

 
csc TransExample1.cs /r:C:\oracle\product\10.1.0\
Client_1\bin\Oracle.DataAccess.dll

注意：您需要用您計(jì)算機(jī)上的相應(yīng)路徑來(lái)替換該 DLL 的路徑。此外，如果您的計(jì)算機(jī)找不到 csc 編譯器，那么您可能需要運(yùn)行 Microsoft sdkvars.bat 腳本來(lái)首先設(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?)

這說(shuō)明您沒(méi)有在編譯命令中正確指定 Oracle Data Access DLL。（有關(guān)設(shè)置的信息，請(qǐng)參閱 John Paul Cook 的技術(shù)文章“在 Oracle 數(shù)據(jù)庫(kù)上構(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

接下來(lái)，輸入以下命令，運(yùn)行示例：

TransExample1

您將看到程序的輸出。不過(guò)，如果您遇到類似以下的異常：

An exception was thrown
Message = ORA-12514:TNS:listener does not currently know 
of service requested in connect descriptor

這說(shuō)明 OracleConnection 對(duì)象的連接字符串中的 Data Source 的設(shè)置不正確。您應(yīng)當(dāng)咨詢您的 DBA 或查閱 Oracle Net 文檔以獲得更多詳細(xì)信息。

如果您使用的是 VS .NET，那么您可以遵循以下指示來(lái)編譯和運(yùn)行 C# 程序 TransExample1.cs：

1. 創(chuàng)建一個(gè)新的 C# 控制臺(tái)應(yīng)用程序。File>New Project，然后選擇 Visual C# Projects，Console Application。
2. 將項(xiàng)目命名為 TransExample1。
3. 用 TransExample1.cs 中的代碼替換 VS .NET 生成的所有代碼。
4. 選擇 Project>Add Reference 添加對(duì) Oracle.DataAccess.dll 的引用，然后瀏覽至您安裝 ODP.NET 的目錄（在我的計(jì)算機(jī)上，它是 C:\oracle\product\10.1.0\Client_1\bin\Oracle.DataAccess.dll），然后雙擊 Oracle.DataAccess.dll。
5. 選擇 Debug>Start without Debugging 運(yùn)行該程序。

要編譯和運(yùn)行 TransExample1.vb，您可以執(zhí)行類似的一系列步驟，但第 1 步應(yīng)選擇一個(gè) Visual Basic 控制臺(tái)應(yīng)用程序，并在第 3 步用 TransExample1.vb 中的代碼替換生成的代碼。

查看程序的運(yùn)行結(jié)果

當(dāng)您運(yùn)行完 C# 或 VB .NET 程序時(shí)，您可以在 SQL*Plus 中使用以下 SELECT 語(yǔ)句查看事務(wù)的結(jié)果：

SELECT p.product_id, p.product_type_id, pt. name, p.name, p.description, p.price
FROM products p, product_types pt
WHERE p.product_type_id = pt.product_type_id
AND p.product_id = 5;

您將看到以下結(jié)果：

PRODUCT_ID PRODUCT_TYPE_ID NAME       NAME
---------- --------------- ---------- -----------------------
DESCRIPTION                                             PRICE
-------------------------------------------------- ----------
5               3 Magazine   Oracle Magazine
Magazine about Oracle                                    4.99

接下來(lái)，您將了解如何設(shè)置事務(wù)保存點(diǎn)。

在 .NET 程序中設(shè)置事務(wù)保存點(diǎn)

正如本文前面所提到的那樣，您可以設(shè)置一個(gè)保存點(diǎn)，以便將事務(wù)回滾至該特定的點(diǎn)，同時(shí)保持事務(wù)中的其他語(yǔ)句原封不動(dòng)。您可以使用 OracleTransaction 類的 Save() 方法在事務(wù)中設(shè)置保存點(diǎn)。

如果您有一個(gè)非常長(zhǎng)的事務(wù)并且希望能夠僅回滾到某個(gè)特定的時(shí)間點(diǎn)，那么您可能要使用保存點(diǎn)。例如，您可能想對(duì) 10 個(gè)產(chǎn)品做一些更改，然后設(shè)置一個(gè)保存點(diǎn)，然后再對(duì)另 10 個(gè)產(chǎn)品做更改；如果您在進(jìn)行第二批更改時(shí)出現(xiàn)了錯(cuò)誤，那么您可以回滾至保存點(diǎn)，使您的第一批更改原封不動(dòng)。

我將帶您逐步完成演示如何使用保存點(diǎn)的 C# (TransExample2.cs) 示例程序和 VB.NET (TransExample2.vb) 示例程序中的相關(guān)新步驟。這些程序向表 products 中添加一行，設(shè)置一個(gè)保存點(diǎn)，向表 products 中添加另一行，回滾至保存點(diǎn)，然后從表 products 中讀取這些行。在回滾至保存點(diǎn)后，只有添加到表 products 中的第一行保留了下來(lái)：第二行將已被刪除。

第 1 到第 3 步與“在 C# 和 VB.NET 中使用數(shù)據(jù)庫(kù)事務(wù)”部分中所示的步驟相同，因此在這里將其省略。

第 4 步

向表 products 中添加一行，該行的產(chǎn)品 ID 為 6。

在 C# 中：

myOracleCommand.CommandText =
"INSERT INTO products (" +
"  product_id, product_type_id, name, description, price" +
") VALUES (" +
"  6, 2, 'Man from Another World', 'Man from Venus lands on Earth', 24.99" +
  ")";
myOracleCommand.ExecuteNonQuery();

在 VB.NET 中：

myOracleCommand.CommandText = _
"INSERT INTO products (" & _
"  product_id, product_type_id, name, description, price" & _
") VALUES (" & _
"  6, 2, 'Man from Another World', 'Man from Venus lands on Earth', 24.99" & _
  ")"
myOracleCommand.ExecuteNonQuery()

第 5 步

使用 OracleTransaction 的 Save() 方法設(shè)置一個(gè)名為 SaveProduct 的保存點(diǎn)。

在 C# 中：

myOracleTransaction.Save("SaveProduct");

在 VB.NET 中：

myOracleTransaction.Save("SaveProduct")

第 6 步

向表 products 中添加另一行，該行的產(chǎn)品 ID 為 7。

在 C# 中：

myOracleCommand.CommandText =
"INSERT INTO products (" +
"  product_id, product_type_id, name, description, price" +
") VALUES (" +
"  7, 2, 'Z-Files', 'Mysterious stories', 14.99" +
  ")";
myOracleCommand.ExecuteNonQuery();

在 VB.NET 中：

myOracleCommand.CommandText = _
"INSERT INTO products (" & _
"  product_id, product_type_id, name, description, price" & _
") VALUES (" & _
"  7, 2, 'Z-Files', 'Mysterious stories', 14.99" & _
  ")"
myOracleCommand.ExecuteNonQuery() 

第 7 步

回滾到先前在第 5 步中設(shè)置的 SaveProduct 保存點(diǎn)。

在 C# 中：

myOracleTransaction.Rollback("SaveProduct");

在 VB.NET 中：

myOracleTransaction.Rollback("SaveProduct")

完成回滾后，在第 6 步中添加的第二行已被刪除，而在第 4 步中添加的第一行保留了下來(lái)。

TransExample2.cs 和 TransExample2.vb 中剩下的步驟顯示表 products 的內(nèi)容，回滾整個(gè)事務(wù)并從數(shù)據(jù)庫(kù)斷開(kāi)。

用于 Microsoft Transaction Server 的 Oracle 事務(wù)服務(wù)的快速說(shuō)明

Microsoft Transaction Server 是一個(gè)運(yùn)行在互聯(lián)網(wǎng)或網(wǎng)絡(luò)服務(wù)器上的專有事務(wù)處理系統(tǒng)。Microsoft Transaction Server 為客戶端計(jì)算機(jī)部署和管理應(yīng)用程序和數(shù)據(jù)庫(kù)事務(wù)請(qǐng)求。

Microsoft Transaction Server 是以服務(wù)器為中心的三層體系結(jié)構(gòu)模型的一個(gè)組件。這種方法實(shí)現(xiàn)了將應(yīng)用程序的表示、業(yè)務(wù)邏輯和數(shù)據(jù)元素清晰地分布到在一個(gè)網(wǎng)絡(luò)中連接的不同計(jì)算機(jī)上。無(wú)需專門(mén)集成，您就可以在與 Oracle 數(shù)據(jù)庫(kù)服務(wù)器 8.0.6 版或更高版本連接的 Microsoft Transaction Server 中部署一個(gè)組件，但首先您必須安裝 Oracle Services for Microsoft Transaction Server。

結(jié)論

在本文中，您系統(tǒng)學(xué)習(xí)了在 .NET 程序中使用數(shù)據(jù)庫(kù)事務(wù)。您了解了如何創(chuàng)建 OracleTransaction 對(duì)象并用它們將事務(wù)提交給數(shù)據(jù)庫(kù)，如何使用保存點(diǎn)部分回滾一個(gè)事務(wù)，以及 Oracle 數(shù)據(jù)庫(kù)如何分離并發(fā)事務(wù)。