Tablestore：原子計數器

前提條件

安裝 Tablestore Java SDK並初始化用戶端。

功能說明

// RowUpdateChange 提供以下方法完成原子計數操作
public RowUpdateChange increment(Column column)
public void addReturnColumn(String columnName)
public void setReturnType(ReturnType returnType)

通過以下三個方法在 RowUpdateChange 上完成原子計數操作：

• increment(Column)：對指定整型列執行原子的遞增或遞減操作（正數遞增，負數遞減）。

• addReturnColumn(String)：指定需要在響應中返回更新後列值的列名。

• setReturnType(ReturnType)：設定傳回型別為 ReturnType.RT_AFTER_MODIFY 時返回原子計數列的更新後值。

服務端在行層級對指定列保證原子性，更新完成後插入一個新的資料版本。

以下樣本對資料表 counter_demo 中主鍵 pk0 的行執行 price 列遞增 10 操作，並在同一請求中讀取更新後的值。

PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("pk0"))
        .build();

RowUpdateChange rowUpdateChange = new RowUpdateChange("counter_demo", primaryKey);

// 對 price 列執行遞增操作，加 10（負數表示遞減）
rowUpdateChange.increment(new Column("price", ColumnValue.fromLong(10)));

// 同一請求中返回更新後的列值
rowUpdateChange.addReturnColumn("price");
rowUpdateChange.setReturnType(ReturnType.RT_AFTER_MODIFY);

UpdateRowResponse response = client.updateRow(new UpdateRowRequest(rowUpdateChange));
Row row = response.getRow();
System.out.println("RequestId: " + response.getRequestId());
System.out.println("Updated price: " + row.getLatestColumn("price").getValue().asLong());

參數說明

使用限制

• 只支援對整型列執行原子計數；列不存在時預設值為 0，列已存在但非整型則返回 OTSParameterInvalid 錯誤。

• 增量可正可負，但不能出現計算溢出，溢出時返回 OTSParameterInvalid 錯誤。

• 原子計數操作只作用於最新版本，不支援指定時間戳記；更新後插入一個新的資料版本。

• 單次更新要求中，對同一列不能同時執行原子計數和其他動作（如覆蓋寫、刪除等）。

• BatchWriteRow 請求中，已執行原子計數的行只能在批次中出現一次。