Tablestore入门手册-条件更新

2021-09-15 04:50:55

功能说明

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

比如有如下场景，初始化数据，当数据字段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