只有当数据满足列判断条件时，才能对数据表中的数据进行更新；当数据不满足列判断条件时，数据更新失败。
前提条件
已初始化OTSClient。具体操作，请参见初始化Tablestore Client。
已创建数据表并写入数据。
使用方法
在通过PutRow、UpdateRow、DeleteRow和BatchWriteRow接口操作表中数据时，您可以使用条件更新检查行存在性条件和列条件。只有当数据满足列判断条件时，才能对数据表中的数据进行更新。
条件更新中的列判断条件包括列条件和行存在性条件。
列条件
目前支持SingleColumnValueCondition和CompositeColumnValueCondition，是基于某一列或者某些列的列值进行条件判断，与过滤器Filter中的条件类似。
列条件中支持使用关系运算（=、!=、>、>=、<、<=）和逻辑运算（NOT、AND、OR），单个更新条件中最多支持设置10个列条件。
SingleColumnValueCondition支持一列和一个常量比较。不支持两列或者两个常量相比较。
CompositeColumnValueCondition的内节点为逻辑运算，子条件可以是SingleColumnValueCondition或CompositeColumnValueCondition。
行存在性条件
对数据表进行更改操作时，系统会先检查行存在性条件，如果不满足行存在性条件，则更改失败并给用户报错。
行存在性条件包括IGNORE（忽略）、EXPECT_EXIST（期望存在）和EXPECT_NOT_EXIST（期望不存在）三种类型。
参数
参数 | 说明 |
RowExistenceExpectation | 对数据表进行更改操作时，系统会先检查行存在性条件，如果不满足行存在性条件，则更改失败并给用户报错。 行存在性条件包括IGNORE、EXPECT_EXIST和EXPECT_NOT_EXIST。
|
ColumnName | 列的名称。 |
ColumnValue | 列的对比值。 |
CompareOperator | 对列值进行比较的关系运算符。关于类型的更多信息，请参见ComparatorType。 关系运算符包括EQUAL（=）、NOT_EQUAL（!=）、GREATER_THAN（>）、GREATER_EQUAL（>=）、LESS_THAN（<）和LESS_EQUAL（<=）。 |
LogicOperator | 对多个条件进行组合的逻辑运算符。关于类型的更多信息，请参见LogicalOperator。 逻辑运算符包括NOT、AND和OR。逻辑运算符不同可以添加的子条件个数不同。
|
PassIfMissing | 当列在某行中不存在时，条件检查是否通过。类型为bool值，默认值为true，表示如果列在某行中不存在，则条件检查通过，即该行满足更新条件。 当设置PassIfMissing为false时，如果列在某行中不存在，则条件检查不通过，即该行不满足更新条件。 |
LatestVersionsOnly | 当列存在多个版本的数据时，是否只使用最新版本的值做比较。类型为bool值，默认值为true，表示如果列存在多个版本的数据，则只使用该列最新版本的值进行比较。 当设置LatestVersionsOnly为false时，如果列存在多个版本的数据，则会使用该列的所有版本的值进行比较，此时只要有一个版本的值满足条件，就表示条件检查通过，即该行满足更新条件。 |
示例
请根据实际选择使用列判断条件更新数据以及使用乐观锁更新数据。
使用列判断条件更新数据
构造SingleColumnValueCondition。
以下示例用于当数据满足
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 == 0且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()); } }
使用乐观锁更新数据
通过Condition实现乐观锁机制，递增一列。
以下示例用于读取表中一行的Col0列值后比较当前Col0列值与读取到的Col0列值是否相等，如果当前Col0列值等于读取到的Col0列值，则更新Col0列值。
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());
}
}