Tablestore入门手册-条件更新








功能说明


条件更新功能只有在满足条件时才对表中的数据进行更改,当不满足条件时更新失败。


比如有如下场景,初始化数据,当数据字段A为-1时,将A的值更新为指定的内容。比如更新为12;如果不是-1则更新失败。



条件更新支持两个维度。分别是行的存在性检查和列值的条件判断。


第一个维度是行的条件检查,包括如下三种条件:



  • IGNORE:忽略,不做存在性检查;比如我们PutRow一行数据,PK为ABC,设置IGNORE之后,不管表中是否已经存在了ABC这一行数据,PutRow都可以写入成功。写入成功之后新写入的行将覆盖老的行。
  • EXPECT_EXIST:期望行存在;示例如上,同样是写入一行数据ABC,此次写入是期望表中已经存在ABC这一行数据,如果存在,写入成功,新的行覆盖老的行;如果不存在,此次写入也将失败。
  • EXPECT_NOT_EXIST:期望行不存在;也是写入一行数据ABC,此时希望表中不存在ABC这一行;如果表中存在这一行数据,写入失败;如果这行数据不存在,那么写入ABC。


第二个维度是列条件更新检查,目前支持单条件(SingleColumnValueCondition)和多条件(CompositeColumnValueCondition) 列值判断;列条件判断还支持算术运算(=、!=、>、>=、<、<=)和逻辑运算(NOT、AND、OR)。



比如,我们要更新人员信息,更新国家为中国的数据,伪代码如下


SQL样例: where 国家='中国'





# 伪代码
SingleColumnValueCondition(国家=中国)

# 因为只有一个条件,所以使用SingleColumnValueCondition
# 列名为“中国”,算数运算符为‘=’,只为‘中国’





在限定必须小于20岁,变成了多条件检查,


SQL样例: where 国家='中国' and age<20






# 伪代码如下
cond = CompositeColumnValueCondition(AND)
cond.addCondtition(SingleColumnValueCondition(国家=中国))
cond.addCondtition(SingleColumnValueCondition(age<20))

# 两个条件,所以使用CompositeColumnValueCondition
# 同时两个条件色‘且’的语义,使用AND
# 第一个条件同上,第二个使用了‘<’运算符





嵌套的方式,比如条件如下,比如中国为20岁一下,美国18岁一下


SQL样例:where (国家='中国' and age<20) or (国家='美国' and age<18)






# 伪代码如下
cond = CompositeColumnValueCondition(OR)

subCond1 = CompositeColumnValueCondition(AND)
subCond1.addCondtition(SingleColumnValueCondition(国家=中国))
subCond1.addCondtition(SingleColumnValueCondition(age<20))

subCond2 = CompositeColumnValueCondition(AND)
subCond2.addCondtition(SingleColumnValueCondition(国家=美国))
subCond2.addCondtition(SingleColumnValueCondition(age<18))

cond.addCondtition(subCond1)
cond.addCondtition(subCond2)

# 因为是嵌套条件,所以最外层使用CompositeColumnValueCondition,
# 由于只要满足一个条件即可,所以外围的CompositeColumnValueCondition为‘或’的语义,所以使用OR
# 子条件可以参考之前的描述方式
# 最后将子条件添加到最外层的条件检查中





限制条件



  • 列条件最多 10 个条件的组合。
  • 行和列的条件有效范围,都只能针对当前正在操作的这一行,不支持跨行条件检查。


支持的API



  • PutRow
  • UpdateRow
  • DeleteRow
  • BatchWriteRow


费用计算


如果写入数据或者更新数据删除数据,CU的计算规则和平时调用API的计费规则一致。如果是条件检查失败,会分别消耗1单位的读CU和1单位的写CU。



功能与示例


背景:小明是公司HR,每月会对薪酬表(remuneration)进行定期的调整,薪酬表中记录了相关人员的薪资信息;我们定义了各种不同的更新方式,全方位的展示条件更新的使用方式。



部门(主键)

人员数目

人员HC数目

奖金池

薪资池

技术部门

10

30

32

12034

财务部门

2

2

0

0

行政部门

3

5

3

12

销售部门

0

30

30

35



以下代码使用Java代码演示



场景一:新增一个部门“运营部门”,未来进行招聘,当前录入部门薪酬信息





# 由于是新增部门,我们期望表中不会存在该部门的信息,所以使用 行存在性 的检查,期望这一行
# 不存在(EXPECT_NOT_EXIST), 当原有表中不存在这行数据时,写入成功,否则写入失败。

# PutRow的实现方式
{
RowPutChange rowChange = new RowPutChange(TABLE_NAME);
rowChange.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
.addPrimaryKeyColumn(PK, PrimaryKeyValue.fromString("运营部门"))
.build());
rowChange.addColumn("人员数目", ColumnValue.fromLong(0));
rowChange.addColumn("人员HC数目", ColumnValue.fromLong(30));
rowChange.addColumn("奖金池", ColumnValue.fromLong(30));
rowChange.addColumn("薪资池", ColumnValue.fromLong(35));

// 因为“运营部门”是新增,所以期望表中是不存在行的,因此采用行存在性检查:EXPECT_NOT_EXIST
rowChange.setCondition(new Condition(RowExistenceExpectation.EXPECT_NOT_EXIST));
}





场景二:更新行政部门的人员数目,从3更新为5人





# 这里会使用两个条件更新的检查:
# 第一个是行存在性的检查,期望这一行存在;
# 第二个是列的条件检查,期望‘人员数目’是3,则更新,如果不是3则更新失败

# UpdateRow的实现方式
{
RowUpdateChange rowChange = new RowUpdateChange(TABLE_NAME);
rowChange.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
.addPrimaryKeyColumn(PK, PrimaryKeyValue.fromString("行政部门"))
.build());
rowChange.put("人员数目", ColumnValue.fromLong(5));

// 行存在性检查,期望存在
Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);

// 列条件检查,期望 ‘人员数目’ 为 3
SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition(
"人员数目",
SingleColumnValueCondition.CompareOperator.EQUAL,
ColumnValue.fromLong(3)
);
condition.setColumnCondition(singleColumnValueCondition);

rowChange.setCondition(condition);
}





场景三:由于销售部门已经外包给第三方公司,因此决定删除“销售部门”的记录信息





# 这里只需要使用行存在性检查即可,期望“销售部门”的信息存在(EXPECT_EXIST)

# DeleteRow的实现方式
{
RowDeleteChange rowChange = new RowDeleteChange(TABLE_NAME);
rowChange.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
.addPrimaryKeyColumn(PK, PrimaryKeyValue.fromString("销售部门"))
.build());

// 行存在性检查,期望存在
Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
rowChange.setCondition(condition);
}





场景四:增加小团队的HC,小团队人员和HC小于等于5的,每个部门新增2个人头的招聘资源, 比如财务部门就满足这个条件,所以在更新财务部门的HC,更新的过程中使用条件更新检查;





# UpdateRow的实现方式
{
RowUpdateChange rowChange = new RowUpdateChange(TABLE_NAME);
rowChange.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
.addPrimaryKeyColumn(PK, PrimaryKeyValue.fromString("财务部门"))
.build());
rowChange.increment(new Column("人员HC数目", ColumnValue.fromLong(2)));

// 行存在性检查
Condition condition = new Condition(RowExistenceExpectation.IGNORE);

CompositeColumnValueCondition conditions = new CompositeColumnValueCondition(CompositeColumnValueCondition.LogicOperator.OR);

{
// 列条件检查,期望 ‘人员数目’ 小于等于5
SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition(
"人员数目",
SingleColumnValueCondition.CompareOperator.LESS_EQUAL,
ColumnValue.fromLong(5)
);
conditions.addCondition(singleColumnValueCondition);
}

{
// 列条件检查,期望 ‘人员HC数目’ 小于等于5
SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition(
"人员HC数目",
SingleColumnValueCondition.CompareOperator.LESS_EQUAL,
ColumnValue.fromLong(5)
);
conditions.addCondition(singleColumnValueCondition);
}

condition.setColumnCondition(conditions);

rowChange.setCondition(condition);
}





表格存储使用手册


本文结合Java SDK的接口调用代码,介绍了Tablestore在数据管理方面的基本功能与使用方式。代码已开源在Tablestore-Examples项目中,用户可以直接运行使用。基于样例代码与文章,新用户能更简单、更快速地上手Tablestore,欢迎新、老用户使用与建议。



通过对基础使用功能的持续输出,我们将整理出一套完整的使用手册(含可执行样例),敬请期待。



专家服务


如有疑问或者需要更好的在线支持,欢迎加入钉钉群:“表格存储公开交流群”。群内提供免费的在线专家服务,欢迎扫码加入,群号:23307953


Tablestore入门手册-条件更新

























上一篇:【Mockplus教程】帐号和购买


下一篇:药品监管系统架构揭秘:海量溯源数据存储与查询