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

シンプルなシナリオ：データの読み書き

読み取り、変更、書き込み (RMW) 操作を実行するには、次の 2 つの方法があります。各方法には特定の制限があります。

• 条件付き更新：一度に単一の行を対象とするリクエストのみを処理します。この方法を使用して、複数のデータ行を含むリクエストや、複数の書き込み操作を含むリクエストを処理することはできません。詳細については、「条件付き更新」をご参照ください。

• アトミックカウンター：一度に単一の行を対象とするリクエストのみを処理し、列値のインクリメントのみをサポートします。詳細については、「アトミックカウンター機能の使用」をご参照ください。

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

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

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

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

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

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

複雑なシナリオ：メールボックスシナリオ

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

ローカル トランザクション機能を正しく使用するには、データテーブルに 2 つのインデックス テーブルを作成する必要があります。次の表は、これらのテーブルのプライマリキー列を示しています。この表では、Type 列がデータテーブルとインデックス テーブルを区別します。各インデックス行は IndexField 列を使用して特定の意味を持つフィールドを格納しますが、データテーブルには IndexField 列は含まれません。

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

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

次の例では、テーブルの指定されたパーティションキー値に対してローカル トランザクションを作成し、ローカル トランザクション内に行を書き込みます。

String tableName = "local_tx_demo";

// 1. 指定したパーティションキー値でローカル トランザクションを開始し、トランザクション ID を取得します。
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. トランザクション内で行を書き込みます。完全なプライマリキーを指定し、トランザクション ID を設定する必要があります。
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

RowPutChange rowPutChange = new RowPutChange(tableName, rowKey);
rowPutChange.addColumn(new Column("col1", ColumnValue.fromString("colvalue")));
rowPutChange.addColumn(new Column("col2", ColumnValue.fromLong(10)));

PutRowRequest putRequest = new PutRowRequest(rowPutChange);
putRequest.setTransactionId(txnId);
client.putRow(putRequest);

// 3. トランザクションをコミットして、すべての書き込みを有効にします。変更を破棄するには、代わりに abortTransaction() を呼び出します。
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

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

次の例では、テーブルの指定されたパーティションキー値に対してローカル トランザクションを作成し、ローカル トランザクション内で行を読み取ります。

String tableName = "local_tx_demo";

// 1. 指定したパーティションキー値でローカル トランザクションを開始します。
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. トランザクション内で行を読み取ります。完全なプライマリキーを指定し、トランザクション ID を設定する必要があります。
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, rowKey);
criteria.setMaxVersions(1);

GetRowRequest getRequest = new GetRowRequest(criteria);
getRequest.setTransactionId(txnId);
GetRowResponse getResponse = client.getRow(getRequest);

// 3. トランザクションをコミットまたはアボートします。読み取り専用トランザクションの場合、どちらも同じ効果になり、トランザクションを解放します。
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

Row row = getResponse.getRow();
System.out.println(row);