トランザクションとロック

トランザクションの制御

ここで説明したメソッドは、標準の JDBC トランザクション・モデルに代わるメソッドです。トランザクションおよび並行処理の制御用の Native SDK モデルは ObjectScript メソッドに基づいており、JDBC モデルと互換性はありません。トランザクションに Native SDK メソッド呼び出しが含まれる場合は、Native SDK モデルを使用する必要があります。

ObjectScript トランザクション・モデルの詳細は、"ObjectScript の使用法" の “トランザクション処理” を参照してください。

Native SDK for Java には、トランザクションを制御する以下のメソッドが用意されています。

• IRIS.tCommit() — 1 レベルのトランザクションをコミットします。

• IRIS.tStart() — トランザクションを開始します (このトランザクションは入れ子になっている場合あり)。

• IRIS.getTLevel() — 現在のトランザクション・レベルを示す int 値 (トランザクション内でない場合は 0) を返します。

• IRIS..tRollback() — セッション内の開いているトランザクションすべてをロールバックします。

• IRIS..tRollbackOne() — 現在のレベルのトランザクションのみをロールバックします。入れ子になったトランザクションである場合、それより上のレベルのトランザクションはロールバックされません。

以下の例では、3 レベルの入れ子のトランザクションを開始し、各トランザクション・レベルに異なるノードの値を設定します。3 つのノードはすべて出力され、それらに値があることが証明されます。その後、この例では、2 番目と 3 番目のレベルがロールバックされ、最初のレベルがコミットされます。3 つのノードはすべて再び出力され、依然として値があるのは最初のノードのみであることが証明されます。

トランザクションの制御 ： 3 レベルの入れ子トランザクションの使用法

  String globalName = "myGlobal";
  irisjv.tStart();

  // getTLevel() is 1: create myGlobal(1) = "firstValue"
  irisjv.set("firstValue", globalName, irisjv.getTLevel());

  irisjv.tStart();
  // getTLevel() is 2: create myGlobal(2) = "secondValue"
  irisjv.set("secondValue", globalName, irisjv.getTLevel());

  irisjv.tStart();
  // getTLevel() is 3: create myGlobal(3) = "thirdValue"
  irisjv.set("thirdValue", globalName, irisjv.getTLevel());

  System.out.println("Node values before rollback and commit:");
  for (int ii=1;ii<4;ii++) {
    System.out.print(globalName + "(" + ii + ") = ");
    if (irisjv.isDefined(globalName,ii) > 1) System.out.println(irisjv.getString(globalName,ii));
    else System.out.println("<valueless>");
  }
// prints: Node values before rollback and commit:
//         myGlobal(1) = firstValue
//         myGlobal(2) = secondValue
//         myGlobal(3) = thirdValue

  irisjv.tRollbackOne();
  irisjv.tRollbackOne();  // roll back 2 levels to getTLevel 1
  irisjv.tCommit();  // getTLevel() after commit will be 0
  System.out.println("Node values after the transaction is committed:");
  for (int ii=1;ii<4;ii++) {
    System.out.print(globalName + "(" + ii + ") = ");
    if (irisjv.isDefined(globalName,ii) > 1) System.out.println(irisjv.getString(globalName,ii));
    else System.out.println("<valueless>");
  }
// prints: Node values after the transaction is committed:
//         myGlobal(1) = firstValue
//         myGlobal(2) = <valueless>
//         myGlobal(3) = <valueless>

並行処理の制御

並行処理の制御は、InterSystems IRIS などのマルチプロセス・システムのきわめて重要な機能です。この機能により、データの特定の要素をロックして、複数のプロセスが同じ要素を同時に変更することによって起きるデータ破損を防ぐことができます。Native SDK トランザクション・モデルは、ObjectScript コマンドに対応する一連のロック・メソッドを提供します。これらのメソッドは、JDBC/SQL トランザクション・モデルで使用することはできません (詳細は、この章の冒頭にある警告を参照)。

クラス IRIS の以下のメソッドを使用して、ロックを取得および解放します。どちらのメソッドも、ロックが共有であるか排他であるかを指定する lockMode 引数を取ります。

   lock (String lockMode, Integer timeout, String globalName, String... subscripts)
   unlock (String lockMode, String globalName, String... subscripts)

• IRIS.lock() — lockMode、timeout、globalName、および subscripts 引数を取り、ノードをロックします。lockMode 引数は、前に保持されたロックを解放するかどうかを指定します。このメソッドは、ロックを取得できない場合、事前に定義した間隔が経過するとタイムアウトします。

• IRIS.unlock() — lockMode、globalName、および subscripts 引数を取り、ノードのロックを解放します。

以下の引数値を使用できます。

• lockMode — 共有ロックを表す S という文字、エスカレート・ロックを表す E という文字、または共有およびエスカレート・ロックを表す SE という文字の組み合わせ。既定値は空の文字列 (排他の非エスカレート) です。

• timeout — ロックの取得を試行するときに待機する秒数。

現在保持されているロックをすべて解放するには、2 つの方法があります。

• IRIS.releaseAllLocks() — この接続で現在保持されているロックをすべて解放します。

• 接続オブジェクトの close() メソッドが呼び出されると、すべてのロックおよびその他の接続リソースが解放されます。