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入门手册-条件更新

 
 
 
上一篇:Windows 7的VPC虚拟机自动不与主机时间同步的解决办法


下一篇:阿里云首场 Serverless Developer Meetup | 落地云原生【北京 11-14】