如何将使用条件更新

条件更新功能只有在满足条件时才对表中的数据进行更改，当不满足条件时更新失败。该功能支持算术运算（=、!=、>、>=、<、<=）和逻辑运算（NOT、AND、OR），支持最多 10 个条件的组合，可用于 PutRow、 UpdateRow、 DeleteRow 和 BatchWriteRow 中。
列判断条件包括 [backcolor=transparent]行存在性条件 和 [backcolor=transparent]列条件：

• 
  行存在性条件分为 IGNORE、EXPECT_EXIS 和 EXPECT_NOT_EXIST，分别代表忽略、期望存在和期望不存在。对表进行更改操作时，会首先检查行存在性条件，若不满足，则更改失败，对用户抛错。
• 
  列条件目前支持 SingleColumnValueCondition 和 CompositeColumnValueCondition，是基于某一列或者某些列的列值进行条件判断，与过滤器 Filter 中的条件类似。

条件更新可以实现乐观锁的功能，即在更新某行时，先获取某列的值，假设为列 A，值为 1，然后设置条件列 A＝1，更新该行同时使列 A＝2。若更新失败，代表有其他客户端已经成功更新了该行。

使用说明

1. 
   构造 SingleColumnValueCondition。 // 设置条件为 Col0==0。
2. SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("Col0",
3.          SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(0));
4. // 如果不存在 Col0 这一列, 条件检查不通过。
5. singleColumnValueCondition.setPassIfMissing(false);
6. // 只判断最新版本。
7. singleColumnValueCondition.setLatestVersionsOnly(true);

构造 CompositeColumnValueCondition。 // 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);
[backcolor=transparent][font="]    
通过 Condition 实现乐观锁机制, 递增一列。 private static void updateRowWithCondition(SyncClient client, String pkValue) {
     // 构造主键
     PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
     primaryKeyBuilder.addPrimaryKeyColumn(PRIMARY_KEY_NAME, 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());
     }
}


使用场景示例


在网页计数和游戏这种高并发的应用上，需要保证计数器更新的原子性，操作如下： // 取回当前值
    old_value = Read();
    // 对当前值进行计算，比如加 1 操作
    new_value = func(old_value);
    // 使用最新值进行更新
    Update(new_value)；

在高并发的环境下，old_value 可能被其他客户端更新，若使用 Conditional Update，就可以做到 Update (new_value) if value 等于 old_value。

特别说明


在高并发场景下，使用条件更新后会有一定几率的失败，需要一定次数的重试。

费用计算


数据写入或者更新成功，不影响各个接口的 CU 计算规则，如果条件更新失败，则会消耗 1 单位写 CU 和 1 单位读 CU。