条件更新 - 表格存储 Tablestore

场景

适用于对高并发的应用进行更新的场景。

在高并发场景下，old_value可能被其他客户端更新，如果使用条件更新，则只有在value等于old_value时，才更新value为new_value。

说明在网页计数和游戏等高并发场景下，使用条件更新后，更新数据可能会失败，此时需要一定次数的重试。

 //获取当前值。
 old_value = Read();
 //对当前值进行运算，例如加1操作。
 new_value = func(old_value);
 //使用最新值进行更新。
 Update(new_value);

接口

条件更新支持关系运算（=、!=、>、>=、<、<=）和逻辑运算（NOT、AND、OR），支持最多10个条件的组合。适用于PutRow、UpdateRow、DeleteRow和BatchWriteRow接口。

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

列判断条件包括列条件和行存在性条件。


列判断条件	说明
列条件	目前支持SingleColumnValueCondition和CompositeColumnValueCondition，是基于某一列或者某些列的列值进行条件判断，与过滤器Filter中的条件类似。
行存在性条件	对数据表进行更改操作时，系统会先检查行存在性条件，如果不满足行存在性条件，则更改失败并给用户报错。行存在性条件包括如下类型。 IGNORE：忽略 EXPECT_EXIST：期望存在 EXPECT_NOT_EXIST：期望不存在通过不同接口操作数据表的数据时的行存在性条件更新规则的更多信息，请参见行存在性条件更新规则。

行存在性条件更新规则

说明 BatchWriteRow操作由多个PutRow、UpdateRow、DeleteRow子操作组成，所以通过BatchWriteRow接口操作数据表中的数据时，请根据操作类型查看对应接口的更新规则。


接口	IGNORE	EXPECT_EXIST	EXPECT_NOT_EXIST
PutRow（已存在行）	成功	成功	失败
PutRow（不存在行）	成功	失败	成功
UpdateRow（已存在行）	成功	成功	失败
UpdateRow（不存在行）	成功	失败	成功
DeleteRow（已存在行）	成功	成功	失败
DeleteRow（不存在行）	成功	失败	成功

使用

您可以使用如下语言的SDK实现条件更新功能。

示例

使用列判断条件和乐观锁的示例代码如下：

构造SingleColumnValueCondition。

 //设置条件为Col0==0。
 SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("Col0",
         SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(0));
 //如果不存在Col0列，条件检查不通过。
 singleColumnValueCondition.setPassIfMissing(false);
 //只判断最新版本。
 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);

通过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());
     }
 }

计费

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