Tablestore:Create a data table

Basic usage

The following example creates a data table named test_table with one primary key column of the String type.

After creating a data table, wait for the table to load before performing data operations. Loading typically takes a few seconds.

package org.example.ots;

import com.alicloud.openservices.tablestore.SyncClient;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.core.auth.V4Credentials;
import com.alicloud.openservices.tablestore.model.*;

public class CreateTable {
    
    public static void main(String[] args) {

        // Obtain access credentials from environment variables. You must configure TABLESTORE_ACCESS_KEY_ID and TABLESTORE_ACCESS_KEY_SECRET.
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // TODO: Modify the following configurations based on your instance information.
        final String region = "yourRegion"; // The ID of the region where your instance is located. Example: "cn-hangzhou".
        final String instanceName = "yourInstanceName"; // The name of your instance.
        final String endpoint = "yourEndpoint"; // The endpoint of your instance.

        SyncClient client = null;
        try {
            // Create credentials.
            DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
            V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
            CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

            // Create a client instance.
            client = new SyncClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

            // Define the table schema.
            TableMeta tableMeta = new TableMeta("test_table"); // TODO: Modify the table name as needed.
            // You must add at least one primary key column to create a table.
            tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("id", PrimaryKeyType.STRING)); // TODO: Modify the table primary key as needed.

            // Configure the table.
            TableOptions tableOptions = new TableOptions();
            // You must specify the max versions when you create a data table.
            tableOptions.setMaxVersions(1);
            // You must specify the time to live (TTL) when you create a data table. A value of -1 means the data never expires.
            tableOptions.setTimeToLive(-1);

            // Create and send the request.
            CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
            client.createTable(request);

            System.out.println("The data table is created.");
        } catch (Exception e) {
            System.err.println("Failed to create the data table. Details:");
            e.printStackTrace();
        } finally {
            // Shut down the client.
            if (client != null) {
                client.shutdown();
            }
        }
    }
}

Add primary keys

Add primary keys by using the addPrimaryKeyColumn or addPrimaryKeyColumns method. The following example uses addPrimaryKeyColumn.

tableMeta.addPrimaryKeyColumn("name", PrimaryKeyType.STRING);

Add predefined columns

Add predefined columns by using the addDefinedColumn or addDefinedColumns method. The following example uses addDefinedColumn.

tableMeta.addDefinedColumn("age", DefinedColumnType.INTEGER);

Set the max version offset

Set the max version offset by using the setMaxTimeDeviation method.

tableOptions.setMaxTimeDeviation(86400);

Configure update permissions

Use the setAllowUpdate method to specify whether to allow data updates in the table.

tableOptions.setAllowUpdate(false);

Add a secondary index

Add a secondary index by specifying the indexMetas parameter when creating the request.

// Create a list of secondary indexes.
ArrayList<IndexMeta> indexMetas = new ArrayList<IndexMeta>();
// Create a secondary index.
IndexMeta indexMeta = new IndexMeta("test_table_idx");
// Set the primary key of the index.
indexMeta.addPrimaryKeyColumn("id");
// To add more primary key columns, first define the corresponding primary keys or predefined columns in the data table.
// indexMeta.addPrimaryKeyColumn("additional_column");

// Set the index type.
indexMeta.setIndexType(IndexType.IT_LOCAL_INDEX);
// Set the index update mode.
indexMeta.setIndexUpdateMode(IndexUpdateMode.IUM_SYNC_INDEX);
// Add the secondary index.
indexMetas.add(indexMeta);

// Create the request.
CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions, indexMetas);

Set stream information

Set stream information by using the setStreamSpecification method of the request.

StreamSpecification streamSpecification = new StreamSpecification(true, 168);
request.setStreamSpecification(streamSpecification);

Enable local transactions

Enable local transactions by using the setLocalTxnEnabled method of the request.

request.setLocalTxnEnabled(true);

Set the reserved read/write throughput

Set the reserved read/write throughput by using the setReservedThroughput method of the request.

// Set the reserved read throughput to 10000 and the reserved write throughput to 5000.
ReservedThroughput reservedThroughput = new ReservedThroughput(10000, 5000);
request.setReservedThroughput(reservedThroughput);

Set data table encryption

Set the encryption method by using the setSseSpecification method of the request.

• KMS encryption

  SSESpecification sseSpecification = new SSESpecification(true, SSEKeyType.SSE_KMS_SERVICE);
  request.setSseSpecification(sseSpecification);

• BYOK encryption

  Note

  Before running the code, obtain the customer master key (CMK) ID and the RAM role ARN. For more information, see BYOK encryption.

  String keyId = "key-hzz6*****************";
  String roleArn = "acs:ram::1705************:role/tabletorebyok";
  SSESpecification sseSpecification = new SSESpecification(true, SSEKeyType.SSE_BYOK, keyId, roleArn);
  request.setSseSpecification(sseSpecification);