Tablestore:条件付き更新

列ベースの条件に基づいてデータを更新する

• SinglleColumnValueConditionを構築する

  次の例では、Col0列の値がCol0==0の条件を満たす場合、Col0列の値が更新されます。

  private static void updateRowWithSingleColumnValueCondition(SyncClient client, String pkValue){
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
      
      // データの行を読み取ります。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
      long col0Value = row.getLatestColumn("Col0").getValue().asLong();
  
      // データテーブルの名前を指定します。
      RowUpdateChange rowUpdateChange = new RowUpdateChange("<TABLE_NAME>", primaryKey);
  
      // 条件を設定します：Col0==0。
      SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("Col0",
              SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(0));
      // Col0列が存在しない場合、条件チェックは失敗します。
      singleColumnValueCondition.setPassIfMissing(false);
      // 最新バージョンのみを比較に使用するように指定します。
      singleColumnValueCondition.setLatestVersionsOnly(true);
      Condition condition = new Condition();
      condition.setColumnCondition(singleColumnValueCondition);
      rowUpdateChange.setCondition(condition);
      // Col0列の値が列ベースの条件を満たす場合、Col0列の値が1ずつ増加します。
      rowUpdateChange.put(new Column("Col0", ColumnValue.fromLong(col0Value+1)));
      try {
          client.updateRow(new UpdateRowRequest(rowUpdateChange));
          System.out.println("データが更新されました。");
      } catch (TableStoreException ex) {
          System.out.println("データの更新に失敗しました。" + ex.toString());
      }
  }                 

• CompositeColumnValueConditionを構築する

  次の例では、Col0列の値がCol0==0 AND Col1>100およびCol2<=10のいずれかの条件を満たす場合、Col0列の値が更新されます。

  private static void updateRowWithCompositeColumnValueCondition(SyncClient client, String pkValue){
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
          
  		// データの行を読み取ります。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
      long col0Value = row.getLatestColumn("Col0").getValue().asLong();
  
      // データテーブルの名前を指定します。
      RowUpdateChange rowUpdateChange = new RowUpdateChange("<TABLE_NAME>", primaryKey);
  
      // composite1条件を(Col0 == 0) AND (Col1 > 100)に設定します。
      CompositeColumnValueCondition composite1 = new CompositeColumnValueCondition(CompositeColumnValueCondition.LogicOperator.AND);
      SingleColumnValueCondition single1 = new SingleColumnValueCondition("Col0",
              SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(0));
      SingleColumnValueCondition single2 = new SingleColumnValueCondition("Col1",
              SingleColumnValueCondition.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100));
      composite1.addCondition(single1);
      composite1.addCondition(single2);
  
      // composite2条件を((Col0 == 0) AND (Col1 > 100)) OR (Col2 <= 10)に設定します。
      CompositeColumnValueCondition composite2 = new CompositeColumnValueCondition(CompositeColumnValueCondition.LogicOperator.OR);
      SingleColumnValueCondition single3 = new SingleColumnValueCondition("Col2",
              SingleColumnValueCondition.CompareOperator.LESS_EQUAL, ColumnValue.fromLong(10));
      composite2.addCondition(composite1);
      composite2.addCondition(single3);
  
      Condition condition = new Condition();
      condition.setColumnCondition(composite2);
      rowUpdateChange.setCondition(condition);
  		// Col0列の値が列ベースの条件のいずれかを満たす場合、Col0列の値が1ずつ増加します。
      rowUpdateChange.put(new Column("Col0", ColumnValue.fromLong(col0Value+1)));
      try {
          client.updateRow(new UpdateRowRequest(rowUpdateChange));
          System.out.println("データが更新されました。");
      } catch (TableStoreException ex) {
          System.out.println("データの更新に失敗しました。" + ex.toString());
      }
  }

オプティミスティックロックに基づいてデータを更新する

次のサンプルコードは、オプティミスティックロックに基づいて列の値を増やす方法の例を示しています。

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

     // データの行を読み取ります。
     SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
     criteria.setMaxVersions(1);
     GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
     Row row = getRowResponse.getRow();
     long col0Value = row.getLatestColumn("Col0").getValue().asLong();

     // Col0列の値を1ずつ増やすように条件付き更新を構成します。
     RowUpdateChange rowUpdateChange = new RowUpdateChange("<TABLE_NAME>", primaryKey);
     Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
     ColumnCondition columnCondition = new SingleColumnValueCondition("Col0", SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(col0Value));
     condition.setColumnCondition(columnCondition);
     rowUpdateChange.setCondition(condition);
     rowUpdateChange.put(new Column("Col0", ColumnValue.fromLong(col0Value + 1)));

     try {
         client.updateRow(new UpdateRowRequest(rowUpdateChange));
     } catch (TableStoreException ex) {
         System.out.println(ex.toString());
     }
 }