949      阿裏雲

使用條件更新__最佳實踐_表格存儲-阿裏雲

條件更新功能隻有在滿足條件時才對表中的數據進行更改，當不滿足條件時更新失敗。該功能支持算術運算（=、!=、>、>=、<、<=）和邏輯運算（NOT、AND、OR），支持最多 10 個條件的組合，可用於 PutRow、UpdateRow、DeleteRow 和 BatchWriteRow 中。

列判斷條件包括“行存在性條件”和“列條件”：

• “行存在性條件”分為 IGNORE、EXPECT_EXIS 和 EXPECT_NOT_EXIST，分別代表忽略、期望存在和期望不存在。在對表進行更改操作時，會首先檢查行存在性條件，若不滿足，則更改失敗，對用戶拋錯。

• “列條件”目前支持 SingleColumnValueCondition 和 CompositeColumnValueCondition，是基於某一列或者某些列的列值進行條件判斷，與過濾器 Filter 中的條件非常類似。

基於條件更新可以實現樂觀鎖的功能，即在更新某行時，先獲取某列的值，假設為列 A，值為 1，然後設置條件“列 A＝1”，更新該行同時使“列 A＝2”。若更新失敗，代表有其他客戶端已經成功更新了該行。

使用說明

1. 構造 SingleColumnValueCondition。

    // 設置條件為 Col0==0。
    SingleColumnValueCondition singleColumnValueCondition = new SingleColumnValueCondition("Col0",
            SingleColumnValueCondition.CompareOperator.EQUAL, ColumnValue.fromLong(0));
    // 如果不存在 Col0 這一列, 條件檢查不通過。
    singleColumnValueCondition.setPassIfMissing(false);
    // 隻判斷最新版本。
    singleColumnValueCondition.setLatestVersionsOnly(true);

2. 構造 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);     

3. 通過 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());
        }
    }

使用場景示例

在網頁計數和遊戲這種高並發的應用上，需要保證計數器更新的原子性，即如下操作：

    // 取回當前值
    old_value = Read();
    // 對當前值進行計算，比如加 1 操作
    new_value = func(old_value);
    // 使用最新值進行更新
    Update(new_value)；