共用方式為


與 SQL Server 進行 System.Transactions 整合 (ADO.NET)

.NET Framework 2.0 版導入了新的交易架構,可透過 System.Transactions 命名空間 (Namespace) 進行存取。 此架構以完全整合到 .NET Framework (包括 ADO.NET) 中的方式來公開交易。

除了增強程式設計之外,在處理交易時,System.Transactions 還會與 ADO.NET 一起運作協調出最佳效能。 可提升的交易是可視需要自動提升為完全分散式交易的輕量型 (本機) 交易。

從 ADO.NET 2.0 開始,System.Data.SqlClient 便支援在您使用 SQL Server 2005 時進行可提升交易。 除非需要已加入的負荷,否則可提升交易不會叫用分散式交易的已加入負荷。 可提升交易是自動作業,無需開發人員從中操作。

只有 .NET Framework Data Provider for SQL Server (SqlClient) 與 SQL Server 2005 搭配使用時,才能使用可提升交易。

建立可提升交易

.NET Framework Provider for SQL Server 支援可提升交易,可透過 .NET Framework System.Transactions 命名空間中的類別來處理這些交易。 可提升交易藉由直到需要時才建立分散式交易的方式,來最佳化分散式交易。 如果只需要一個資源管理員,則不會發生分散式交易。

注意事項注意事項

在部分信任案例中,當某筆交易提升至分散式交易時,DistributedTransactionPermission 就是必要項目。如需詳細資訊,請參閱Transaction Management Escalation

可提升交易案例

分散式交易通常要耗用大量的系統資源,並由「Microsoft 分散式交易協調器 (MS DTC)」進行管理,其整合了交易中會存取的所有資源管理者。 可提升交易是 System.Transactions 交易的特殊形式,可有效地委派工作給簡單的 SQL Server 2005 交易。 System.TransactionsSystem.Data.SqlClient 及 SQL Server 2005 會協調處理交易時所涉及的工作,並視需要將其提升為完全分散式交易。

使用可提升交易的好處是:當以作用中的 TransactionScope 交易開啟連接,且未開啟其他連接時,會將交易認可為輕量型交易,不會產生完全分散式交易的額外負擔。

連接字串關鍵字

ConnectionString 屬性支援關鍵字 Enlist,它表示 System.Data.SqlClient 是否會偵測到交易內容,並自動在分散式交易中登記連接。 如果 Enlist=true,則會在開啟之執行緒的目前交易內容中自動登記連接。 如果 Enlist=false,則 SqlClient 連接將不會與分散式交易進行互動。 Enlist 的預設值為 True。 如果未在連接字串中指定 Enlist,則若在開啟連接時偵測到連接,便會自動在分散式交易中登記該連接。

SqlConnection 連接字串中的 Transaction Binding 關鍵字會控制連接與已登記 System.Transactions 交易之間的關聯。 這也可以透過 SqlConnectionStringBuilderTransactionBinding 屬性取得。

下表說明可能出現的值。

關鍵字

描述

Implicit Unbind

預設值。 結束時,連接會與交易中斷連結,並切換回自動認可模式。

Explicit Unbind

連接會維持附加至交易的狀態,直到交易關閉為止。 如果相關聯的交易並非使用中或與 Current 不符,連接將會失敗。

如需詳細資訊,請參閱Implementing An Implicit Transaction Using Transaction Scope

使用 TransactionScope

TransactionScope 類別可藉由在分散式交易中隱含地登記連接,來使程式碼區塊可進行交易。 離開區塊之前,您必須呼叫 TransactionScope 區塊結尾的 Complete 方法。 離開區塊會叫用 Dispose 方法。 如果已擲回造成程式碼離開範圍的例外狀況,則會將交易視為中止。

建議您使用 using 區塊,以確保結束 using 區塊時,會在 TransactionScope 物件上呼叫 Dispose。 無法認可或復原暫止的交易會嚴重損害效能,因為 default time-out for the TransactionScope 的預設逾時是 1 分鐘。 如果您不使用 using 陳述式,則必須在 Try 區塊中執行所有工作,並明確呼叫 Finally 區塊中的 Dispose 方法。

如果 TransactionScope 中發生例外狀況,則會將交易標記為不一致並放棄。 處置 TransactionScope 時,則會復原該交易。 如果沒有發生任何例外狀況,則會認可參與的交易。

注意事項注意事項

根據預設,TransactionScope 類別會建立其 IsolationLevel 為 Serializable 的交易。根據應用程式,您可能會考慮降低隔離等級,以避免應用程式中發生劇烈的爭用現象。

注意事項注意事項

建議您在分散式交易內僅執行更新、插入及刪除作業,因為它們會耗用大量的資料庫資源。SELECT 陳述式可能會不必要地鎖定資料庫資源,而在某些案例中,您可能需要使用交易而不是選取。除非涉及其他已交易的資源管理者,否則所有非資料庫工作都應在交易範圍外執行。雖然交易範圍內的例外狀況會防止認可交易,但 TransactionScope 類別不支援針對在交易本身範圍外所做的任何程式碼變更進行復原。如果在復原交易時需要採取某些動作,則必須撰寫您自己的 IEnlistmentNotification 介面實作,並在交易中明確登記。

範例

您需要參考 System.Transactions.dll,才能使用 System.Transactions

下列函式示範如何針對由兩個不同的 SqlConnection 物件表示,並包裝於 TransactionScope 區塊中的兩個不同 SQL Server 執行個體,建立可提升交易。 程式碼會使用 using 陳述式來建立 TransactionScope 區塊,並開啟第一個連接,這樣會自動在 TransactionScope 中登記它。 一開始交易登記為輕量型交易,而不是完全分散式交易。 只有當第一個連接中的命令沒有擲回例外狀況時,第二個連接才會登記於 TransactionScope 中。 開啟第二個連接時,交易會自動提升為完全分散式交易。 此時,系統會叫用 Complete 方法,但是它只有在沒有擲回任何例外狀況時才會認可交易。 如果在 TransactionScope 區塊中的任何一點擲回例外狀況,便不會呼叫 Complete,且分散式交易會在 using 區塊結束並處置 TransactionScope 時復原。

' This function takes arguments for the 2 connection strings and commands in order
' to create a transaction involving two SQL Servers. It returns a value > 0 if the
' transaction committed, 0 if the transaction rolled back. To test this code, you can 
' connect to two different databases on the same server by altering the connection string,
' or to another RDBMS such as Oracle by altering the code in the connection2 code block.
Public Function CreateTransactionScope( _
  ByVal connectString1 As String, ByVal connectString2 As String, _
  ByVal commandText1 As String, ByVal commandText2 As String) As Integer

    ' Initialize the return value to zero and create a StringWriter to display results.
    Dim returnValue As Integer = 0
    Dim writer As System.IO.StringWriter = New System.IO.StringWriter

    ' Create the TransactionScope in which to execute the commands, guaranteeing
    ' that both commands will commit or roll back as a single unit of work.
    Using scope As New TransactionScope()
        Using connection1 As New SqlConnection(connectString1)
            Try
                ' Opening the connection automatically enlists it in the 
                ' TransactionScope as a lightweight transaction.
                connection1.Open()

                ' Create the SqlCommand object and execute the first command.
                Dim command1 As SqlCommand = New SqlCommand(commandText1, connection1)
                returnValue = command1.ExecuteNonQuery()
                writer.WriteLine("Rows to be affected by command1: {0}", returnValue)

                ' If you get here, this means that command1 succeeded. By nesting
                ' the Using block for connection2 inside that of connection1, you
                ' conserve server and network resources by opening connection2 
                ' only when there is a chance that the transaction can commit.   
                Using connection2 As New SqlConnection(connectString2)
                    Try
                        ' The transaction is promoted to a full distributed
                        ' transaction when connection2 is opened.
                        connection2.Open()

                        ' Execute the second command in the second database.
                        returnValue = 0
                        Dim command2 As SqlCommand = New SqlCommand(commandText2, connection2)
                        returnValue = command2.ExecuteNonQuery()
                        writer.WriteLine("Rows to be affected by command2: {0}", returnValue)

                    Catch ex As Exception
                        ' Display information that command2 failed.
                        writer.WriteLine("returnValue for command2: {0}", returnValue)
                        writer.WriteLine("Exception Message2: {0}", ex.Message)
                    End Try
                End Using

            Catch ex As Exception
                ' Display information that command1 failed.
                writer.WriteLine("returnValue for command1: {0}", returnValue)
                writer.WriteLine("Exception Message1: {0}", ex.Message)
            End Try
        End Using

        ' If an exception has been thrown, Complete will 
        ' not be called and the transaction is rolled back.
        scope.Complete()
    End Using

    ' The returnValue is greater than 0 if the transaction committed.
    If returnValue > 0 Then
        writer.WriteLine("Transaction was committed.")
    Else
        ' You could write additional business logic here, notify the caller by
        ' throwing a TransactionAbortedException, or log the failure.
       writer.WriteLine("Transaction rolled back.")
     End If

    ' Display messages.
    Console.WriteLine(writer.ToString())

    Return returnValue
End Function
// This function takes arguments for the 2 connection strings and commands in order
// to create a transaction involving two SQL Servers. It returns a value > 0 if the
// transaction committed, 0 if the transaction rolled back. To test this code, you can 
// connect to two different databases on the same server by altering the connection string,
// or to another RDBMS such as Oracle by altering the code in the connection2 code block.
static public int CreateTransactionScope(
    string connectString1, string connectString2,
    string commandText1, string commandText2)
{
    // Initialize the return value to zero and create a StringWriter to display results.
    int returnValue = 0;
    System.IO.StringWriter writer = new System.IO.StringWriter();

    // Create the TransactionScope in which to execute the commands, guaranteeing
    // that both commands will commit or roll back as a single unit of work.
    using (TransactionScope scope = new TransactionScope())
    {
        using (SqlConnection connection1 = new SqlConnection(connectString1))
        {
            try
            {
                // Opening the connection automatically enlists it in the 
                // TransactionScope as a lightweight transaction.
                connection1.Open();

                // Create the SqlCommand object and execute the first command.
                SqlCommand command1 = new SqlCommand(commandText1, connection1);
                returnValue = command1.ExecuteNonQuery();
                writer.WriteLine("Rows to be affected by command1: {0}", returnValue);

                // if you get here, this means that command1 succeeded. By nesting
                // the using block for connection2 inside that of connection1, you
                // conserve server and network resources by opening connection2 
                // only when there is a chance that the transaction can commit.   
                using (SqlConnection connection2 = new SqlConnection(connectString2))
                    try
                    {
                        // The transaction is promoted to a full distributed
                        // transaction when connection2 is opened.
                        connection2.Open();

                        // Execute the second command in the second database.
                        returnValue = 0;
                        SqlCommand command2 = new SqlCommand(commandText2, connection2);
                        returnValue = command2.ExecuteNonQuery();
                        writer.WriteLine("Rows to be affected by command2: {0}", returnValue);
                    }
                    catch (Exception ex)
                    {
                        // Display information that command2 failed.
                        writer.WriteLine("returnValue for command2: {0}", returnValue);
                        writer.WriteLine("Exception Message2: {0}", ex.Message);
                    }
            }
            catch (Exception ex)
            {
                // Display information that command1 failed.
                writer.WriteLine("returnValue for command1: {0}", returnValue);
                writer.WriteLine("Exception Message1: {0}", ex.Message);
            }
        }

        // If an exception has been thrown, Complete will not 
        // be called and the transaction is rolled back.
        scope.Complete();
    }

    // The returnValue is greater than 0 if the transaction committed.
    if (returnValue > 0)
    {
        writer.WriteLine("Transaction was committed.");
    }
    else
    {
        // You could write additional business logic here, notify the caller by
        // throwing a TransactionAbortedException, or log the failure.
        writer.WriteLine("Transaction rolled back.");
    }

    // Display messages.
    Console.WriteLine(writer.ToString());

    return returnValue;
}

請參閱

其他資源

交易和並行 (ADO.NET)

Features Provided By System.Transactions