javax.sql.rowset.spi

インタフェース SyncResolver

すべてのスーパーインタフェース:

AutoCloseable、ResultSet、RowSet、Wrapper

public interface SyncResolver
extends RowSet

アプリケーションが、手動の意志決定ツリーを使って同期競合が発生したときの対処方法を決定できるようにするフレームワークを定義します。アプリケーションが同期競合を手動で解決することは必須ではありませんが、このフレームワークは競合が発生したときにアプリケーションに委譲する手段を提供します。

競合とは、RowSet オブジェクトの元の行の値がデータソース内の値と一致しない状態であり、前回の同期以降にデータソース行が変更されたことを示します。RowSet オブジェクトの元の値は、前回の同期の直前の値であり、必ずしも初期値ではありません。

SyncResolver オブジェクトの説明

SyncResolver オブジェクトは、SyncResolver インタフェースを実装する特殊な RowSet オブジェクトです。これは接続された RowSet オブジェクト (JdbcRowSet インタフェースの実装) または未接続の RowSet オブジェクト (CachedRowSet インタフェースまたはそのサブインタフェースの実装) として動作できます。サブインタフェースについては、javax.sql.rowset パッケージの説明を参照してください。SyncResolver のリファレンス実装は CachedRowSet インタフェースを実装しますが、ほかの実装では、JdbcRowSet インタフェースを実装して、特定の必要を満たすことができます。

アプリケーションが (CachedRowSet の acceptChanges メソッドを呼び出して) RowSet オブジェクトとデータソースを同期させようとした後、いくつかの競合が発見されると、行セットの SyncProvider オブジェクトは SyncResolverのインスタンスを作成します。この新しい SyncResolver オブジェクトは同期を試みた RowSet オブジェクトと同じ行数および列数になります。SyncResolver オブジェクトには、競合が発生したデータソースの値が格納され、ほかのすべての値には null が格納されます。さらに、各競合の情報も格納されます。

SyncResolver オブジェクトの取得と使用

acceptChanges メソッドが競合を検出すると、SyncProvider オブジェクトは SyncProviderException オブジェクトを作成し、それに新しい SyncResolver オブジェクトを設定します。acceptChanges メソッドはこの例外をスローし、それをアプリケーションがキャッチし、格納されている SyncResolver オブジェクトの取得に使用します。次のコード部分では、SyncProviderException の getSyncResolver メソッドを使用して、SyncResolver オブジェクト resolver を取得します。

     } catch (SyncProviderException spe) {
         SyncResolver resolver = spe.getSyncResolver();
     ...
     }
 

アプリケーションは、resolver を使って、そこに含まれる競合 (複数可) の情報を取得できます。resolver などの SyncResolver オブジェクトは、競合がある各行で、その競合を追跡します。また、行セットのコマンドの影響を受けるテーブル (複数可) にロックを適用して、現在の競合が解決されるまで新たに競合が発生しないようにします。

SyncResolver オブジェクトから取得可能な情報は、次のとおりです。

競合の発生時に試行していた操作
SyncProvider インタフェースは、発生する可能性のある状態について説明する 4 つの定数を定義します。3 つの定数は、競合が検出されたとき RowSet オブジェクトが試行していた操作の種類 (更新、削除、または挿入) を表し、4 番目は競合がないことを表します。SyncResolver オブジェクトが getStatus メソッドを呼び出したとき、これらの定数が戻り値として返される可能性のあるものです。

     int operation = resolver.getStatus();
 

データソース内の競合の原因となった値
RowSet オブジェクトによって値が変更され、データソースに書き込まれるとき、書き込み先のデータソース内の値が前回同期処理を行なった時点とは異なっていた場合、競合が発生したことを表します。SyncResolver オブジェクトの値がデータソースの競合値であるため、アプリケーションは SyncResolver の getConflictValue メソッドを呼び出して、競合の原因となったデータソース内の値を取り出すことができます。

     java.lang.Object conflictValue = resolver.getConflictValue(2);
 

resolver の列は、上のコード例のように列番号で指定できます。列名で指定することもできます。

アプリケーションは、getStatus メソッドおよび getConflictValue メソッドから取得された情報を使って、データソース内に保持すべき値を決定できます。続いて、SyncResolver の setResolvedValue メソッドを呼び出して、RowSet オブジェクトおよびデータソースに保持する値を設定します。

     resolver.setResolvedValue("DEPT", 8390426);
 

上のコード例では、列名によって、指定の値を設定される RowSet オブジェクト内の列を指定しています。列番号で列を指定することもできます。

アプリケーションは現在の競合する行のすべての競合を解決したら、setResolvedValue メソッドを呼び出し、SyncResolver オブジェクトの競合する行ごとにこの手順を繰り返します。

SyncResolver オブジェクトのナビゲート

SyncResolver オブジェクトは RowSet オブジェクトであるため、アプリケーションはすべての RowSet メソッドを使用して、カーソルを動かし、SyncResolver オブジェクトをナビゲートできます。たとえば、アプリケーションは RowSet の next メソッドを使用して、各行に移動し、SyncResolver の getStatus メソッドを呼び出して、行に競合が含まれるかどうかを確認できます。競合を含む行では、アプリケーションは列で繰り返し処理を行い、null 以外の値を見つけることができます。この値は競合のあるデータソースの値になります。

SyncResolver オブジェクトのナビゲートを簡単にするには、特に大半の行に競合がない場合に、SyncResolver インタフェースで nextConflict メソッドおよび previousConflict メソッドを定義します。これらのメソッドは、少なくとも 1 つの競合値を含む行のみを移動します。続いてアプリケーションで列番号を指定して、SyncResolver の getConflictValue メソッドを呼び出し、競合値自体を取得します。次のセクションのコードの抜粋に例を示します。

コード例

次のコードの抜粋は、未接続の RowSet オブジェクト crs が自身を配下のデータソースと同期することで、競合を解決する方法を示しています。try ブロックで、crs は acceptChanges メソッドを呼び出し、Connection オブジェクト con を渡しています。競合がない場合は、単に crs の変更がデータソースに書き込まれます。しかし、競合がある場合は、acceptChanges メソッドが SyncProviderException オブジェクトをスローし、catch ブロックが有効になります。この例では、SyncResolver オブジェクトを使用した多くの方法のうちの 1 つを説明しており、SyncResolver の nextConflict メソッドを while ループで使用しています。nextConflict が false を返す (SyncResolver オブジェクト resolver に競合する行がなくなる) とループが終了します。この特定のコードの抜粋では、resolver は競合を更新した行 (SyncResolver.UPDATE_ROW_CONFLICT のステータスの行) を検索し、このコードの抜粋の残りの部分は、crs が更新を試みたために競合が発生した行に対してのみ実行されます。

resolver のカーソルが更新競合のある次の競合する行に移動した後、getRow メソッドは現在の行を示し、CachedRowSet オブジェクト crs のカーソルは crs の比較可能な行に移動します。resolver と crs の両方の行の列で繰り返し処理を行うことによって、競合している値を取得し、比較して、保持する値を決定します。このコードの抜粋では、crs の値が解決済みの値として設定された値であり、これを使用して、データソースの競合する値が上書きされることを意味します。

     try {

         crs.acceptChanges(con);

     } catch (SyncProviderException spe) {

         SyncResolver resolver = spe.getSyncResolver();

         Object crsValue;  // value in the RowSet object
         Object resolverValue:  // value in the SyncResolver object
         Object resolvedValue:  // value to be persisted

         while(resolver.nextConflict())  {
             if(resolver.getStatus() == SyncResolver.UPDATE_ROW_CONFLICT)  {
                 int row = resolver.getRow();
                 crs.absolute(row);

                 int colCount = crs.getMetaData().getColumnCount();
                 for(int j = 1; j <= colCount; j++) {
                     if (resolver.getConflictValue(j) != null)  {
                         crsValue = crs.getObject(j);
                         resolverValue = resolver.getConflictValue(j);
                         . . .
                         // compare crsValue and resolverValue to determine
                         // which should be the resolved value (the value to persist)
                         resolvedValue = crsValue;

                         resolver.setResolvedValue(j, resolvedValue);
                      }
                  }
              }
          }
      }