CommittableTransaction を使用した明示的なトランザクションの実装

  • [アーティクル]

CommittableTransaction クラスは、TransactionScope クラスが暗黙的に使用されるのと対照的に、アプリケーションがトランザクションを明示的に使用する方法を提供します。これは、複数の関数呼び出しまたは複数のスレッド呼び出しで同じトランザクションを使用するアプリケーションで役立ちます。TransactionScope クラスとは異なり、アプリケーション作成者はトランザクションをコミットまたは中止するために、具体的に Commit メソッドまたは Rollback メソッドを呼び出す必要があります。

CommittableTransaction クラスの概要

CommittableTransaction クラスは、Transaction クラスから派生するため、後者のすべての機能を提供します。特に有用なのは、Transaction クラスの Rollback メソッドで、これは CommittableTransaction オブジェクトのロールバックにも使用できます。

Transaction クラスは CommittableTransaction クラスに類似していますが、Commit メソッドは提供しません。これにより、トランザクションのコミット時に制御を継続しながら、トランザクション オブジェクト (またはその複製) を他のメソッド (他のスレッド上に存在する可能性もあり) に渡すことができます。呼び出されたコードでは、トランザクションの参加や処理の選択を行えますが、トランザクションをコミットできるのは CommittableTransaction オブジェクトの作成者のみです。

CommittableTransaction クラスを使用する場合には、次のことに注意する必要があります。

  • CommittableTransaction トランザクションを作成しても、アンビエント トランザクションは設定されません。リソース マネージャが必要に応じて正しいトランザクション コンテキストで動作することを保証するには、アンビエント トランザクションを具体的に設定およびリセットする必要があります。現在のアンビエント トランザクションを設定するには、グローバルな Transaction オブジェクトの静的な Current プロパティを設定します。

  • CommittableTransaction オブジェクトは再利用できません。CommittableTransaction オブジェクトがコミットまたはロールバックされると、トランザクションで再び使用することはできません。つまり、現在のアンビエント トランザクション コンテキストとして設定することはできません。

CommittableTransaction の作成

新しい CommittableTransaction を作成してコミットする例を次に示します。

tx = New CommittableTransaction

Dim myConnection As New SqlConnection("server=(local)\SQLExpress;Integrated Security=SSPI;database=northwind")
Dim myCommand As New SqlCommand()

'Open the SQL connection
myConnection.Open()

'Give the transaction to SQL to enlist with
myConnection.EnlistTransaction(tx)

myCommand.Connection = myConnection

'Restore database to near it's original condition so sample will work correctly.
myCommand.CommandText = "DELETE FROM Region WHERE (RegionID = 100) OR (RegionID = 101)"
myCommand.ExecuteNonQuery()

'Insert the first record.
myCommand.CommandText = "Insert into Region (RegionID, RegionDescription) VALUES (100, 'MidWestern')"
myCommand.ExecuteNonQuery()

'Insert the second record.
myCommand.CommandText = "Insert into Region (RegionID, RegionDescription) VALUES (101, 'MidEastern')"
myCommand.ExecuteNonQuery()

'Commit or rollback the transaction
Dim c As ConsoleKeyInfo
While (True)
    Console.Write("Commit or Rollback? [C|R] ")
    c = Console.ReadKey()
    Console.WriteLine()

    If (c.KeyChar = "C") Or (c.KeyChar = "c") Then
        tx.Commit()
        Exit While
    ElseIf ((c.KeyChar = "R") Or (c.KeyChar = "r")) Then
        tx.Rollback()
        Exit While
    End If
End While

myConnection.Close()
tx = Nothing

//Create a committable transaction
tx = new CommittableTransaction();

SqlConnection myConnection = new SqlConnection("server=(local)\\SQLExpress;Integrated Security=SSPI;database=northwind");
SqlCommand myCommand = new SqlCommand();

//Open the SQL connection
myConnection.Open();

//Give the transaction to SQL to enlist with
myConnection.EnlistTransaction(tx);

myCommand.Connection = myConnection;

// Restore database to near it's original condition so sample will work correctly.
myCommand.CommandText = "DELETE FROM Region WHERE (RegionID = 100) OR (RegionID = 101)";
myCommand.ExecuteNonQuery();

// Insert the first record.
myCommand.CommandText = "Insert into Region (RegionID, RegionDescription) VALUES (100, 'MidWestern')";
myCommand.ExecuteNonQuery();

// Insert the second record.
myCommand.CommandText = "Insert into Region (RegionID, RegionDescription) VALUES (101, 'MidEastern')";
myCommand.ExecuteNonQuery();

// Commit or rollback the transaction
while (true)
{
    Console.Write("Commit or Rollback? [C|R] ");
    ConsoleKeyInfo c = Console.ReadKey();
    Console.WriteLine();

    if ((c.KeyChar == 'C') || (c.KeyChar == 'c'))
    {
        tx.Commit();
        break;
    }
    else if ((c.KeyChar == 'R') || (c.KeyChar == 'r'))
    {
        tx.Rollback();
        break;
    }
}
myConnection.Close();
tx = null;

CommittableTransaction のインスタンスを作成しても、アンビエント トランザクション コンテキストは自動的に設定されません。したがって、リソース マネージャに対する操作は、そのトランザクションの一部に含まれません。アンビエントトランザクションを設定または取得するには、グローバル Transaction オブジェクトの静的な Current プロパティを使用します。アプリケーションでは、リソース マネージャがトランザクションに参加できるようにするために、手動でこのプロパティを設定する必要があります。古いアンビエント トランザクションを保存し、CommittableTransaction オブジェクトの使用が終了したら復元することをお勧めします。

トランザクションをコミットするには、Commit メソッドを明示的に呼び出す必要があります。トランザクションをロールバックするには、Rollback メソッドを呼び出す必要があります。CommittableTransaction がコミットまたはロールバックされるまで、そのトランザクションに関連するすべてのリソースはロックされたままであることに注意してください。

CommittableTransaction オブジェクトは、複数の関数呼び出しおよびスレッドにわたって使用できます。ただし、例外を処理し、特に障害発生時に Rollback メソッドを呼び出すことはアプリケーション開発者の責任です。

非同期コミット

CommittableTransaction クラスは、トランザクションを非同期にコミットするための機構も提供します。トランザクションのコミットは、複数回のデータベース アクセスや潜在的なネットワーク待機時間が含まれる場合、かなりの時間を要することがあります。高いスループットのアプリケーションでデッドロックを回避するため、非同期コミットを使用してできるだけ早期にトランザクションの処理を完了し、バックグラウンド タスクとしてコミット処理を実行できます。このために、CommittableTransaction クラスの BeginCommit メソッドおよび EndCommit メソッドを使用できます。

BeginCommit を呼び出すことで、スレッド プールからのスレッドにコミット ホールドアップをディスパッチできます。また、EndCommit を呼び出して、トランザクションが実際にコミットされたかどうかを判断することもできます。なんらかの理由でトランザクションがコミットされなかった場合、EndCommit はトランザクションの例外を発生させます。EndCommit が呼び出された時点でトランザクションがまだコミットされていない場合、トランザクションがコミットまたは中止されるまで、呼び出し元がブロックされます。

非同期のコミットを行う最も簡単な方法は、コミットの完了時に呼び出されるコールバック メソッドを提供することです。ただし、呼び出しを実行するために使用する元の CommittableTransaction オブジェクトに対して EndCommit メソッドを呼び出す必要があります。このオブジェクトを取得するため、コールバック メソッドの IAsyncResult パラメータをダウンキャストできます。これは、CommittableTransaction クラスが IAsyncResult クラスを実装しているためです。

次の例は、非同期コミットの実行方法を示しています。

public void DoTransactionalWork()
{
     Transaction oldAmbient = Transaction.Current;
     CommittableTransaction committableTransaction = new CommittableTransaction();
     Transaction.Current = committableTransaction;

     try
     {
          /* Perform transactional work here */
          // No errors - commit transaction asynchronously
          committableTransaction.BeginCommit(OnCommitted,null);
     }
     finally
     {
          //Restore the ambient transaction 
          Transaction.Current = oldAmbient;
     }
}
void OnCommitted(IAsyncResult asyncResult)
{
     CommittableTransaction committableTransaction;
     committableTransaction = asyncResult as CommittableTransaction;   
     Debug.Assert(committableTransaction != null);
     try
     {
          using(committableTransaction)
          {
               committableTransaction.EndCommit(asyncResult);
          }
     }
     catch(TransactionException e)
     {
          //Handle the failure to commit
     }
}

関連項目

概念

トランザクション スコープを使用した暗黙的なトランザクションの実装

その他の技術情報

トランザクション処理

Footer image

Copyright © 2007 by Microsoft Corporation.All rights reserved.