このトピックでは、Tablestore SDK for Java を使用して Tablestore テーブルに単一行のデータを書き込む方法について説明します。
前提条件
クライアントが初期化されていること。 詳細については、「Tablestore クライアントの初期化」をご参照ください。
メソッド
public PutRowResponse putRow(PutRowRequest putRowRequest) throws TableStoreException, ClientExceptionサンプルコード
次のサンプルコードは、test_table テーブルに行データを書き込みます。 この行のプライマリキー値は row1 です。
public static void putRowExample(SyncClient client) {
// プライマリキーを構築します。
PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("row1"));
PrimaryKey primaryKey = primaryKeyBuilder.build();
// 書き込む行データを構築します。
RowPutChange rowPutChange = new RowPutChange("test_table", primaryKey);
// putRow メソッドを呼び出して、行データを書き込みます。
PutRowRequest putRowRequest = new PutRowRequest(rowPutChange);
PutRowResponse putRowResponse = client.putRow(putRowRequest);
// 結果を返します。
System.out.println("* RequestId: " + putRowResponse.getRequestId());
System.out.println("* Read CU Cost: " + putRowResponse.getConsumedCapacity().getCapacityUnit().getReadCapacityUnit());
System.out.println("* Write CU Cost: " + putRowResponse.getConsumedCapacity().getCapacityUnit().getWriteCapacityUnit());
}属性列を追加します。
rowPutChange.addColumn("col1", ColumnValue.fromString("val1"));バージョン番号を指定します。 属性列ごとに個別のバージョン番号を指定できます。
// 現在のタイムスタンプをバージョン番号として使用します。 rowPutChange.addColumn("col1", ColumnValue.fromString("val1"), System.currentTimeMillis());