Tablestore:アトミックカウンターの使用

前提条件

Tablestore SDK for Java をインストールし、クライアントを初期化します。

説明

increment(Column) を呼び出して、指定した整数列をアトミックに更新します。正の値でインクリメント、負の値でデクリメントが行われます。Tablestore は行レベルの原子性を保証し、更新後に新しいデータバージョンを書き込みます。同一リクエスト内で更新後の値を返すには、addReturnColumn(String) を呼び出し、returnType を RT_AFTER_MODIFY に設定します。

public UpdateRowResponse updateRow(UpdateRowRequest updateRowRequest) throws TableStoreException, ClientException
public RowUpdateChange increment(Column column)
public void addReturnColumn(String columnName)
public void setReturnType(ReturnType returnType)

次の例では、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("Updated price: " + row.getLatestColumn("price").getValue().asLong());

パラメーター

応答

制限事項

• アトミックカウンター操作は整数型の列のみをサポートします。列が存在するものの整数型でない場合、操作は OTSParameterInvalid エラーを返します。

• アトミックカウンター操作は最新バージョンにのみ適用され、ユーザー指定のタイムスタンプは受け付けません。

• 単一の更新リクエスト内では、同じ列に対してアトミックカウンター操作と他の操作 (上書きや削除など) を組み合わせることはできません。

• BatchWriteRow リクエストでは、アトミックカウンター操作を含む行は 1 回のみ指定できます。