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

在 VB.NET 中：

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

第 5 步

使用 OracleCommand 對象的 ExecuteNonQuery() 方法運行 INSERT 語句。

在 C# 中：

myOracleCommand.ExecuteNonQuery();

在 VB.NET 中：

myOracleCommand.ExecuteNonQuery()

第 6 和第 7 步

將 OracleCommand 對象的 CommandText 屬性設為向表 Products 中添加一行的第二條 INSERT 語句，并運行它。

在 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 對象的 Commit() 方法提交數(shù)據(jù)庫中的事務。

在 C# 中：

myOracleTransaction.Commit();

在 VB.NET 中：

myOracleTransaction.Commit()

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

第 9 步

使用 Close() 方法關(guān)閉 OracleConnection 對象。

在 C# 中：

myOracleConnection.Close();

在 VB.NET 中：

myOracleConnection.Close()

編譯并運行示例程序

要編譯 C# 示例程序，您可以使用 csc 命令運行 C# 編譯器。因為程序使用 Oracle Data Access DLL，所以您應使用 /r 選項指定該 DLL 的完整路徑，例如：

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

注意：您需要用您計算機上的相應路徑來替換該 DLL 的路徑。此外，如果您的計算機找不到 csc 編譯器，那么您可能需要運行 Microsoft sdkvars.bat 腳本來首先設置 .NET SDK 的環(huán)境變量；您可以在安裝 .NET SDK 的 bin 目錄中找到該腳本。

如果您遇到以下錯誤：

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)設置的信息，請參閱 John Paul Cook 的技術(shù)文章“在 Oracle 數(shù)據(jù)庫上構(gòu)建 .NET 應用程序”。）

下面是用于編譯 VB.NET 程序的等價命令：

vbc TransExample1.vb /r:C:\oracle\product\10.1.0\
Client_1\bin\Oracle.DataAccess.dll /r:system.dll /r:system.data.dll

接下來，輸入以下命令，運行示例：

TransExample1

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

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

這說明 OracleConnection 對象的連接字符串中的 Data Source 的設置不正確。您應當咨詢您的 DBA 或查閱 Oracle Net 文檔以獲得更多詳細信息。

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

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

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

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

當您運行完 C# 或 VB .NET 程序時，您可以在 SQL*Plus 中使用以下 SELECT 語句查看事務的結(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

接下來，您將了解如何設置事務保存點。

在 .NET 程序中設置事務保存點

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

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

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

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

第 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() 方法設置一個名為 SaveProduct 的保存點。

在 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 步中設置的 SaveProduct 保存點。

在 C# 中：

myOracleTransaction.Rollback("SaveProduct");

在 VB.NET 中：

myOracleTransaction.Rollback("SaveProduct")

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

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

用于 Microsoft Transaction Server 的 Oracle 事務服務的快速說明

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

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

結(jié)論

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