Tablestore:Create a data table

Usage notes

After you create a data table, wait until the data table is loaded before you perform operations on data. Otherwise, the operations will fail. This process typically takes several seconds.

Prerequisites

Initialize a Tablestore client.

Method description

func (tableStoreClient *TableStoreClient) CreateTable(request *CreateTableRequest) (*CreateTableResponse, error)

Sample code

The following sample code creates a data table named test_table that contains one primary key column of the string type.

func CreateTableSample(client *tablestore.TableStoreClient) {
    // Construct the schema information of the data table
    tableMeta := new(tablestore.TableMeta)
    tableMeta.TableName = "test_table"
    // At least one primary key column is required to create a data table
    tableMeta.AddPrimaryKeyColumn("id", tablestore.PrimaryKeyType_STRING)

    // Construct the configuration information of the data table
    tableOption := new(tablestore.TableOption)
    // You must specify the maximum number of versions when you create a data table
    tableOption.MaxVersion = 1
    // You must specify the TTL when you create a data table. A value of -1 indicates that the data never expires
    tableOption.TimeToAlive = -1

    // You must set the reserved read and write throughput when you create a data table. The default value is 0 (Only high-performance instances in CU mode support setting the reserved read and write throughput of a data table to a non-zero value)
    reservedThroughput := new(tablestore.ReservedThroughput)
    reservedThroughput.Readcap = 0
    reservedThroughput.Writecap = 0

    // Construct the request and send it
    createTableRequest := new(tablestore.CreateTableRequest)
    createTableRequest.TableMeta = tableMeta
    createTableRequest.TableOption = tableOption
    createTableRequest.ReservedThroughput = reservedThroughput
    _, err := client.CreateTable(createTableRequest)
    if err != nil {
        fmt.Println("Failed to create table with error:", err)
    } else {
        fmt.Println("Create table finished.")
    }
}

Refer to the following sample code to configure additional settings when creating a data table.

• Add predefined columns

  tableMeta.AddDefinedColumn("name", tablestore.DefinedColumn_STRING)

• Set the maximum version offset

  tableOption.DeviationCellVersionInSec = 86400

• Set whether to allow updates

  tableOption.AllowUpdate = proto.Bool(false)

• Add a secondary index

  // Construct a secondary index
  indexMeta := new(tablestore.IndexMeta)
  indexMeta.IndexName = "test_table_index"
  // Set the primary key columns of the index
  indexMeta.AddPrimaryKeyColumn("id")
  indexMeta.AddPrimaryKeyColumn("name")
  // Set the index type
  indexMeta.IndexType = tablestore.IT_LOCAL_INDEX
  // Add the secondary index
  createTableRequest.AddIndexMeta(indexMeta)

• Configure Stream settings

  streamSpec := new(tablestore.StreamSpecification)
  streamSpec.EnableStream = true
  streamSpec.ExpirationTime = 168
  createTableRequest.StreamSpec = streamSpec

• Set whether to enable local transactions

  enableLocalTxn := proto.Bool(true)
  createTableRequest.EnableLocalTxn = enableLocalTxn

• Set the data encryption type

  • KMS-based encryption

    sseSpec := new(tablestore.SSESpecification)
    sseSpec.SetEnable(true)
    sseSpec.SetKeyType(tablestore.SSE_KMS_SERVICE)
    createTableRequest.SSESpecification = sseSpec

  • BYOK encryption

    Note

    Before running the code, obtain the CMK ID and the ARN of the RAM role. For more information, see BYOK encryption.

    sseSpec := new(tablestore.SSESpecification)
    sseSpec.SetEnable(true)
    sseSpec.SetKeyType(tablestore.SSE_BYOK)
    sseSpec.SetKeyId("key-hzz65****************")
    sseSpec.SetRoleArn("acs:ram::1705************:role/tabletorebyok")
    createTableRequest.SSESpecification = sseSpec

References

• Wide table model

• Data versions and TTL

• Create a time series table