Tablestore:ローカル トランザクション

単純なシナリオ: データの読み取りと書き込み

次の 2 つの方法を使用して、読み取り、変更、書き込み (RMW) 操作を実行できます。2 つの方法にはそれぞれ特定の制限があります。

• 条件付き更新: 一度に 1 つの行を含む 1 つのリクエストのみを処理します。このメソッドを使用して、複数のデータ行を含むリクエストや、複数の書き込み操作を含むリクエストを処理することはできません。詳細については、条件付き更新を参照してください。

• アトミック カウンター: 一度に 1 つの行を含む 1 つのリクエストのみを処理し、列値のインクリメントのみをサポートします。詳細については、アトミック カウンター機能の使用を参照してください。

前述の問題を解決するには、ローカル トランザクションを作成して、パーティションキー値で指定された範囲内のデータに対して RMW 操作を実行します。

1. StartLocalTransaction 操作を呼び出して、指定したパーティションキー値に基づいてローカル トランザクションを作成し、ローカル トランザクション ID を取得します。

2. GetRow または GetRange 操作を呼び出してデータを読み取ります。リクエストにはローカル トランザクション ID が含まれている必要があります。

3. クライアントでデータを変更します。

4. PutRow、UpdateRow、DeleteRow、または BatchWriteRow 操作を呼び出して、変更されたデータを書き戻します。リクエストにはローカル トランザクション ID が含まれている必要があります。

5. CommitTransaction 操作を呼び出して、ローカル トランザクションをコミットします。

複雑なシナリオ: メール管理

ローカル トランザクションを作成して、特定のユーザーのメールに対してアトミック操作を実行できます。

ローカル トランザクション機能を使用するには、データテーブルに 2 つのインデックステーブルを含めます。次の表は、データテーブルとインデックステーブルのプライマリキー列を示しています。[タイプ] 列は、データテーブルの行とインデックステーブルの行を識別するために使用されます。[IndexField] 列には、Folder インデックステーブルの $Folder フィールドと、SendTime インデックステーブルの $SendTime フィールドが格納されます。データテーブルの [IndexField] 列は空です。

具体的には、ローカル トランザクション機能を使用して、メールに対して次の操作を実行できます。

ローカル トランザクション機能を使用してデータ行を書き込む

次のサンプルコードは、テーブル内の指定されたパーティションキー値に基づいてローカル トランザクションを作成する方法と、ローカル トランザクションにデータ行を書き込む方法を示しています。

private static void transactionPutRow(SyncClient client) {
    // データテーブルの名前を指定します。
    String tableName="<TABLE_NAME>";
    // 指定したパーティションキー値に基づいてローカル トランザクションを作成します。 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // パーティションキーの列名、データ型、および列値を指定します。
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // ローカル トランザクションを作成するためのリクエストを構築します。
    StartLocalTransactionRequest request = new StartLocalTransactionRequest(tableName, primaryKey);
    // ローカル トランザクションを作成するリクエストを開始し、ローカル トランザクション ID を取得します。
    String txnId = client.startLocalTransaction(request).getTransactionID();
    
    // ローカル トランザクションにデータ行を書き込みます。
    // 行のプライマリキー情報を構成します。
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // プライマリキーの列名、データ型、および列値を指定します。テーブルのプライマリキーが複数のプライマリキー列で構成されている場合は、プライマリキー列に関する情報を順番に構成します。
    primaryKeyBuilder1.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    primaryKeyBuilder1.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
    PrimaryKey primaryKey1 = primaryKeyBuilder1.build();
    // 行の属性列を構成します。
    RowPutChange rowPutChange = new RowPutChange(tableName, primaryKey1);
    // 各属性列の列名、データ型、および列値を指定します。必要に応じて、さらに属性列を追加します。
    rowPutChange.addColumn(new Column("col1", ColumnValue.fromString("colvalue")));
    rowPutChange.addColumn(new Column("col2", ColumnValue.fromLong(10)));
    PutRowRequest request1 = new PutRowRequest(rowPutChange);
    // リクエストにローカル トランザクション ID を渡します。
    request1.setTransactionId(txnId);
    client.putRow(request1);
    
    // ローカル トランザクションをコミットまたは中止します。 
    // ローカル トランザクションをコミットして、ローカル トランザクション内のすべてのデータ変更を有効にします。
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // ローカル トランザクションを中止して、ローカル トランザクション内のすべてのデータ変更を無効にします。
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
}

ローカル トランザクション機能を使用してデータ行を読み取る

次のサンプルコードは、テーブル内の指定されたパーティションキー値に基づいてローカル トランザクションを作成する方法と、ローカル トランザクションでデータ行を読み取る方法を示しています。

private static void transactionGetRow(SyncClient client) {
    // データテーブルの名前を指定します。
    String tableName="exampletabled";
    // 指定したパーティションキー値に基づいてローカル トランザクションを作成します。
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // パーティションキーの列名、データ型、および列値を指定します。
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("111"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // ローカル トランザクションを作成するためのリクエストを構築します。
    StartLocalTransactionRequest request = new StartLocalTransactionRequest(tableName, primaryKey);
    // ローカル トランザクションを作成するリクエストを開始し、ローカル トランザクション ID を取得します。
    String txnId = client.startLocalTransaction(request).getTransactionID();

    // ローカル トランザクションでデータ行を読み取ります。
    // 行のプライマリキー情報を構成します。
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // プライマリキーの列名、データ型、および列値を指定します。テーブルのプライマリキーが複数のプライマリキー列で構成されている場合は、プライマリキー列に関する情報を順番に構成します。
    primaryKeyBuilder1.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("111"));
    primaryKeyBuilder1.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
    PrimaryKey primaryKey1 = primaryKeyBuilder1.build();
    SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, primaryKey1);
    // 最新バージョンのデータを読み取ります。
    criteria.setMaxVersions(1);
    GetRowRequest request1 = new GetRowRequest(criteria);
    // リクエストにローカル トランザクション ID を渡します。
    request1.setTransactionId(txnId);
    GetRowResponse getRowResponse = client.getRow(request1);
  
    // ローカル トランザクションをコミットまたは中止します。読み取り操作の場合、ローカル トランザクションのコミットと中止は同じ効果があります。
    // ローカル トランザクションをコミットして、ローカル トランザクション内のすべてのデータ変更を有効にします。
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // ローカル トランザクションを中止して、ローカル トランザクション内のすべてのデータ変更を無効にします。
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
    
    // データ行を取得して表示します。
    Row row = getRowResponse.getRow();
    System.out.println("データ行が読み取られ、次のように表示されます:");
    System.out.println(row);
}