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

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

以下の 2 つの方法を用いて、読み取り・変更・書き込み（RMW）操作を実行できます。各方法には特定の制限があります。

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

• アトミックカウンター：1 回のリクエストにつき、単一の行のみを処理でき、列値の増分のみをサポートします。詳細については、「アトミックカウンター機能の使用」をご参照ください。

上記の制限を解消するには、指定されたパーティションキー値の範囲内で RMW 操作を実行できるよう、ローカルトランザクションを作成します。

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

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

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

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

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

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

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

ローカルトランザクション機能を正しく使用するには、データテーブル上に 2 つのインデックステーブルを作成する必要があります。以下の表に、これらのテーブルのプライマリキー列を示します。表中の「Type」列は、データテーブルとインデックステーブルを区別します。各インデックス行では、「IndexField」列を使用して特定の意味を持つフィールドを格納しますが、データテーブルには「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);
}