Tablestore:自動インクリメントプライマリキー列の使用

自動インクリメントプライマリキー列の設定

テーブルを作成する際に AddPrimaryKeyColumnOption を呼び出し、プライマリキーのオプションを AUTO_INCREMENT に設定します。

次のサンプルでは、example_table テーブルを作成します。user_id 列がパーティションキーで、record_id 列が自動インクリメントプライマリキー列です。

tableMeta := &tablestore.TableMeta{TableName: "example_table"}
tableMeta.AddPrimaryKeyColumn("user_id", tablestore.PrimaryKeyType_STRING)
tableMeta.AddPrimaryKeyColumnOption(
    "record_id",
    tablestore.PrimaryKeyType_INTEGER,
    tablestore.AUTO_INCREMENT,
)

request := &tablestore.CreateTableRequest{
    TableMeta:          tableMeta,
    TableOption:        &tablestore.TableOption{TimeToAlive: -1, MaxVersion: 1},
    ReservedThroughput: &tablestore.ReservedThroughput{},
}

_, err := client.CreateTable(request)
if err != nil {
    log.Fatal(err)
}

データを書き込む前に、テーブルがロードされるまで待機してください。

データの書き込みと生成値の取得

データを書き込む際は、AddPrimaryKeyColumnWithAutoIncrement を呼び出してプレースホルダーを設定し、SetReturnPk を呼び出して生成値を含む完全なプライマリキーを返すようにします。自動インクリメント書き込みの場合、行の存在条件を RowExistenceExpectation_IGNORE に設定する必要があります。

次のサンプルでは、行を書き込み、サーバー生成の record_id 値を取得します。

primaryKey := &tablestore.PrimaryKey{}
primaryKey.AddPrimaryKeyColumn("user_id", "user-a")
primaryKey.AddPrimaryKeyColumnWithAutoIncrement("record_id")

change := &tablestore.PutRowChange{
    TableName:  "example_table",
    PrimaryKey: primaryKey,
}
change.AddColumn("status", "created")
change.SetCondition(tablestore.RowExistenceExpectation_IGNORE)
change.SetReturnPk()

response, err := client.PutRow(&tablestore.PutRowRequest{PutRowChange: change})
if err != nil {
    log.Fatal(err)
}

fmt.Println(response.PrimaryKey)

自動インクリメントプライマリキー列

PrimaryKeySchema には、自動インクリメントプライマリキー列に関連する次のパラメーターが含まれます。

書き込み設定

PutRowChange には、自動インクリメントプライマリキー列に関連する次のパラメーターが含まれます。