Tablestore:条件付き更新

前提条件

クライアントの初期化

説明

Condition クラスは次のように宣言されています。

public class Condition {
    private RowExistenceExpectation rowExistenceExpectation;
    private ColumnCondition columnCondition;
    
    // メソッド宣言
}

サンプルコード

次のコード例は、updateRow メソッドを使用して条件付き更新を実行する方法を示しています。

public static void setConditionExample(SyncClient client) {
    // 更新データを構築します。
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("row1"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    RowUpdateChange rowUpdateChange = new RowUpdateChange("test_condition", primaryKey);
    rowUpdateChange.put("col1", ColumnValue.fromString("changed_val1"));

    // 更新条件を構築します。
    Condition condition = new Condition();
    // ターゲット行がデータテーブルに存在する場合にのみデータを更新します。
    condition.setRowExistenceExpectation(RowExistenceExpectation.EXPECT_EXIST);
    rowUpdateChange.setCondition(condition);

    // リクエストを構築し、updateRow メソッドを呼び出してデータを更新します。
    UpdateRowRequest updateRowRequest = new UpdateRowRequest(rowUpdateChange);
    UpdateRowResponse updateRowResponse = client.updateRow(updateRowRequest);

    // レスポンスを処理します。
    System.out.println("* RequestId: " + updateRowResponse.getRequestId());
    System.out.println("* Read CU Cost: " + updateRowResponse.getConsumedCapacity().getCapacityUnit().getReadCapacityUnit());
    System.out.println("* Write CU Cost: " + updateRowResponse.getConsumedCapacity().getCapacityUnit().getWriteCapacityUnit());
}

• 単一の属性列の値が指定された条件を満たすかどうかを確認するために、列値条件を設定します。

  // col1 列の値が val1 の場合にのみデータを更新します。
  SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("col1", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromString("val1"));
  condition.setColumnCondition(singleColumnValueCondition);

• 複数のサブ条件を確認するために、列値条件を設定します。

  // 複合条件 1 を設定します。
  CompositeColumnValueCondition compositeColumnValueCondition1 = new CompositeColumnValueCondition(CompositeColumnValueCondition.LogicOperator.AND);
  // サブ条件を追加します。
  SingleColumnValueCondition singleColumnValueCondition1 = new SingleColumnValueCondition("col1", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromString("val1"));
  compositeColumnValueCondition1.addCondition(singleColumnValueCondition1);
  SingleColumnValueCondition singleColumnValueCondition2 = new SingleColumnValueCondition("col2", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromString("val2"));
  compositeColumnValueCondition1.addCondition(singleColumnValueCondition2);
  // 複合条件 2 を設定します。
  CompositeColumnValueCondition compositeColumnValueCondition2 = new CompositeColumnValueCondition(CompositeColumnValueCondition.LogicOperator.OR);
  // サブ条件を追加します。
  compositeColumnValueCondition2.addCondition(compositeColumnValueCondition1);
  SingleColumnValueCondition singleColumnValueCondition3 = new SingleColumnValueCondition("col3", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromString("val3"));
  compositeColumnValueCondition2.addCondition(singleColumnValueCondition3);
  // 複合条件を追加します。条件は (col1 = val1 and col2 = val2) or (col3 = val3) です。
  condition.setColumnCondition(compositeColumnValueCondition2);

ユースケース

次のコードサンプルは、条件付き更新機能を使用して、楽観的ロックの比較とスワップ (CAS) 操作をシミュレートする方法を示しています。

public static void OptimisticLocking(SyncClient client) {
    // プライマリキーを構築します。
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("row1"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();

    // 属性列の元の値を読み取ります。
    SingleRowQueryCriteria singleRowQueryCriteria = new SingleRowQueryCriteria("test_condition", primaryKey);
    singleRowQueryCriteria.setMaxVersions(1);
    GetRowRequest getRowRequest = new GetRowRequest(singleRowQueryCriteria);
    GetRowResponse getRowResponse = client.getRow(getRowRequest);
    String oldValue = getRowResponse.getRow().getLatestColumn("col1").getValue().asString();

    // データを更新します。
    RowUpdateChange rowUpdateChange = new RowUpdateChange("test_condition", primaryKey);
    rowUpdateChange.put("col1", ColumnValue.fromString("changed_val1"));
    // 更新条件を設定します。ターゲット属性列の最新バージョンが期待値 (読み取り値) と等しい場合にのみ更新が実行されます。
    Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
    SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("col1", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromString(oldValue));
    singleColumnValueCondition.setPassIfMissing(false);
    singleColumnValueCondition.setLatestVersionsOnly(true);
    condition.setColumnCondition(singleColumnValueCondition);
    rowUpdateChange.setCondition(condition);

    // リクエストを構築し、updateRow メソッドを呼び出してデータを更新します。
    UpdateRowRequest updateRowRequest = new UpdateRowRequest(rowUpdateChange);
    UpdateRowResponse updateRowResponse = client.updateRow(updateRowRequest);

    // レスポンスを処理します。
    System.out.println("* RequestId: " + updateRowResponse.getRequestId());
    System.out.println("* Read CU Cost: " + updateRowResponse.getConsumedCapacity().getCapacityUnit().getReadCapacityUnit());
    System.out.println("* Write CU Cost: " + updateRowResponse.getConsumedCapacity().getCapacityUnit().getWriteCapacityUnit());
}