創(chuàng)建表時(shí)不帶索引

以下示例用于創(chuàng)建數(shù)據(jù)表。該表的主鍵為pk（String類(lèi)型），屬性列值最多保留3個(gè)版本數(shù)據(jù)以及數(shù)據(jù)永不過(guò)期。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //為數(shù)據(jù)表添加主鍵列。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk", PrimaryKeyType.STRING)); 
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示永不過(guò)期。帶索引表的數(shù)據(jù)表數(shù)據(jù)生命周期必須設(shè)置為-1。
    int timeToLive = -1; 
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。帶索引表的數(shù)據(jù)表最大版本數(shù)必須設(shè)置為1。
    int maxVersions = 3; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);
        
    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
    request.setReservedThroughput(new ReservedThroughput(new CapacityUnit(0, 0))); //設(shè)置預(yù)留讀寫(xiě)吞吐量，容量型實(shí)例中的數(shù)據(jù)表只能設(shè)置為0，高性能實(shí)例中的數(shù)據(jù)表可以設(shè)置為非零值。
    client.createTable(request);
}

創(chuàng)建表時(shí)配置全局二級(jí)索引

以下示例用于同時(shí)創(chuàng)建數(shù)據(jù)表和全局二級(jí)索引。該表包含pk1（String類(lèi)型）和pk2（Integer類(lèi)型）兩列主鍵且包含defcol1（String類(lèi)型）和defcol2（Integer類(lèi)型）兩個(gè)預(yù)定義列，屬性列值只保留最新版本數(shù)據(jù)以及數(shù)據(jù)永不過(guò)期。該全局二級(jí)索引的主鍵列為defcol1、pk1和pk2，屬性列為defcol2。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //為數(shù)據(jù)表添加主鍵列。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk1", PrimaryKeyType.STRING)); 
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk2", PrimaryKeyType.INTEGER)); 
    //為數(shù)據(jù)表添加預(yù)定義列。
    tableMeta.addDefinedColumn(new DefinedColumnSchema("defcol1", DefinedColumnType.STRING)); 
    tableMeta.addDefinedColumn(new DefinedColumnSchema("defcol2", DefinedColumnType.INTEGER)); 
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示永不過(guò)期。帶索引表的數(shù)據(jù)表數(shù)據(jù)生命周期必須設(shè)置為-1。
    int timeToLive = -1; 
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。帶索引表的數(shù)據(jù)表最大版本數(shù)必須設(shè)置為1。
    int maxVersions = 1; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);

    ArrayList<IndexMeta> indexMetas = new ArrayList<IndexMeta>();
    //設(shè)置索引表名稱(chēng)。
    IndexMeta indexMeta = new IndexMeta("<INDEX_NAME>");
    //為索引表添加主鍵列。
    indexMeta.addPrimaryKeyColumn("defcol1"); 
    //為索引表添加屬性列。
    indexMeta.addDefinedColumn("defcol2"); 
    indexMetas.add(indexMeta);

    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions, indexMetas); //創(chuàng)建數(shù)據(jù)表的同時(shí)創(chuàng)建索引表。

    client.createTable(request);
}

創(chuàng)建表時(shí)配置本地二級(jí)索引

以下示例用于同時(shí)創(chuàng)建數(shù)據(jù)表和本地二級(jí)索引。該表的主鍵為pk1（String類(lèi)型）和pk2（Integer類(lèi)型）且包括defcol1（String類(lèi)型）和defcol2（Integer類(lèi)型）兩個(gè)預(yù)定義列，屬性列值只保留最新版本數(shù)據(jù)以及數(shù)據(jù)永不過(guò)期。該本地二級(jí)索引的主鍵列為pk1、defcol1和pk2，屬性列為defcol2。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //為數(shù)據(jù)表添加主鍵列。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk1", PrimaryKeyType.STRING)); 
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk2", PrimaryKeyType.INTEGER)); 
    //為數(shù)據(jù)表添加預(yù)定義列。
    tableMeta.addDefinedColumn(new DefinedColumnSchema("defcol1", DefinedColumnType.STRING)); 
    tableMeta.addDefinedColumn(new DefinedColumnSchema("defcol2", DefinedColumnType.INTEGER)); 
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示永不過(guò)期。帶索引表的數(shù)據(jù)表數(shù)據(jù)生命周期必須設(shè)置為-1。
    int timeToLive = -1; 
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。帶索引表的數(shù)據(jù)表最大版本數(shù)必須設(shè)置為1。
    int maxVersions = 1; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);

    ArrayList<IndexMeta> indexMetas = new ArrayList<IndexMeta>();
    //設(shè)置索引表名稱(chēng)。
    IndexMeta indexMeta = new IndexMeta("<INDEX_NAME>");
    //設(shè)置索引類(lèi)型為本地二級(jí)索引（IT_LOCAL_INDEX）。
    indexMeta.setIndexType(IT_LOCAL_INDEX); 
    //設(shè)置索引更新模式為同步更新（IUM_SYNC_INDEX）。當(dāng)索引類(lèi)型為本地二級(jí)索引時(shí)，索引更新模式必須為同步更新。
    indexMeta.setIndexUpdateMode(IUM_SYNC_INDEX);  
    //為索引表添加主鍵列。索引表的第一列主鍵必須與數(shù)據(jù)表的第一列主鍵相同。
    indexMeta.addPrimaryKeyColumn("pk1"); 
    //為索引表添加主鍵列。
    indexMeta.addPrimaryKeyColumn("defcol1"); 
    //為索引表添加屬性列。
    indexMeta.addDefinedColumn("defcol2"); 
    indexMetas.add(indexMeta);

    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions, indexMetas); //創(chuàng)建數(shù)據(jù)表的同時(shí)創(chuàng)建索引表。

    client.createTable(request);
}

創(chuàng)建表時(shí)開(kāi)啟局部事務(wù)

以下示例用于創(chuàng)建數(shù)據(jù)表時(shí)開(kāi)啟局部事務(wù)功能。該表的主鍵為pk1（String類(lèi)型）和pk2（Integer類(lèi)型），屬性列值只保留最新版本數(shù)據(jù)以及數(shù)據(jù)永不過(guò)期。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //為數(shù)據(jù)表添加主鍵列。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk1", PrimaryKeyType.STRING));
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk2", PrimaryKeyType.INTEGER));
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示永不過(guò)期。帶索引表的數(shù)據(jù)表數(shù)據(jù)生命周期必須設(shè)置為-1。
    int timeToLive = -1; 
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。帶索引表的數(shù)據(jù)表最大版本數(shù)必須設(shè)置為1。
    int maxVersions = 1; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);

    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
    //開(kāi)啟局部事務(wù)。當(dāng)為數(shù)據(jù)表配置了主鍵自增列時(shí)，此配置無(wú)效。
    request.setLocalTxnEnabled(true); 

    client.createTable(request);
}

創(chuàng)建基于KMS服務(wù)密鑰加密的表

以下示例用于創(chuàng)建數(shù)據(jù)表時(shí)使用基于KMS服務(wù)密鑰加密表中數(shù)據(jù)。該表的主鍵為pk（String類(lèi)型），屬性列值只保留最新版本數(shù)據(jù)以及數(shù)據(jù)永不過(guò)期。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //如果要配置表加密，需要對(duì)建表請(qǐng)求配置加密相關(guān)參數(shù)，支持KMS服務(wù)密鑰或BYOK自定義密鑰兩種類(lèi)型。此處為使用KMS服務(wù)密鑰。
    SSESpecification sseKms = new SSESpecification(true, SSEKeyType.SSE_KMS_SERVICE);
    //為數(shù)據(jù)表添加主鍵列。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk", PrimaryKeyType.STRING)); 
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示永不過(guò)期。帶索引表的數(shù)據(jù)表數(shù)據(jù)生命周期必須設(shè)置為-1。
    int timeToLive = -1; 
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。帶索引表的數(shù)據(jù)表最大版本數(shù)必須設(shè)置為1。
    int maxVersions = 1; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);
    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
    //設(shè)置預(yù)留讀寫(xiě)吞吐量，容量型實(shí)例中的數(shù)據(jù)表只能設(shè)置為0，高性能實(shí)例中的數(shù)據(jù)表可以設(shè)置為非零值。
    request.setReservedThroughput(new ReservedThroughput(new CapacityUnit(0, 0))); 
    request.setSseSpecification(sseKms);
    client.createTable(request);
}

創(chuàng)建帶有主鍵自增列的表

以下示例用于創(chuàng)建數(shù)據(jù)表時(shí)配置主鍵自增列。該表的主鍵為pk1（String類(lèi)型）和pk2（Integer類(lèi)型），其中pk1主鍵列為分區(qū)鍵，pk2主鍵列為自增列。

private static void createTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    TableMeta tableMeta = new TableMeta("<TABLE_NAME>");
    //為數(shù)據(jù)表添加主鍵列。第一列為分區(qū)鍵。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk1", PrimaryKeyType.STRING));
    //為數(shù)據(jù)表添加主鍵列。第二列為自增列，類(lèi)型為INTEGER，屬性為AUTO_INCREMENT。
    tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("pk2", PrimaryKeyType.INTEGER, PrimaryKeyOption.AUTO_INCREMENT));
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示數(shù)據(jù)永不過(guò)期。
    int timeToLive = -1;  
    //保存的最大版本數(shù)，1表示每列上最多保存一個(gè)版本即保存最新的版本。
    int maxVersions = 1; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);
    CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
    client.createTable(request);
}

列出表名稱(chēng)

以下示例用于列出實(shí)例內(nèi)所有表名稱(chēng)。

private static void listTable(SyncClient client) {
    ListTableResponse response = client.listTable();
    System.out.println("表的列表如下：");
    for (String tableName : response.getTableNames()) {
        System.out.println(tableName);
    }
}

更新表數(shù)據(jù)

以下示例用于更新exampletable數(shù)據(jù)表的最大版本數(shù)為5。

private static void updateTable(SyncClient client) {
    //數(shù)據(jù)的過(guò)期時(shí)間，單位為秒，-1表示數(shù)據(jù)永不過(guò)期。
    int timeToLive = -1;
    //將最大版本數(shù)更新為5。
    int maxVersions = 5; 
    TableOptions tableOptions = new TableOptions(timeToLive, maxVersions);
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    UpdateTableRequest request = new UpdateTableRequest("<TABLE_NAME>");
    request.setTableOptionsForUpdate(tableOptions);
    client.updateTable(request);
}

查詢(xún)表描述信息

以下示例用于查詢(xún)數(shù)據(jù)表的表結(jié)構(gòu)信息、可選配置信息和預(yù)留吞吐量信息。

private static void describeTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    DescribeTableRequest request = new DescribeTableRequest("<TABLE_NAME>");
    DescribeTableResponse response = client.describeTable(request);
    TableMeta tableMeta = response.getTableMeta();
    System.out.println("表的名稱(chēng)：" + tableMeta.getTableName());
    System.out.println("表的主鍵：");
    for (PrimaryKeySchema primaryKeySchema : tableMeta.getPrimaryKeyList()) {
        System.out.println(primaryKeySchema);
    }
    TableOptions tableOptions = response.getTableOptions();
    System.out.println("表的TTL:" + tableOptions.getTimeToLive());
    System.out.println("表的MaxVersions:" + tableOptions.getMaxVersions());
    //只能查看加密表的加密配置信息。非加密表無(wú)此配置項(xiàng)。
    //System.out.println("表的加密配置：" + response.getSseDetails());
    ReservedThroughputDetails reservedThroughputDetails = response.getReservedThroughputDetails();
    System.out.println("表的預(yù)留讀吞吐量："
            + reservedThroughputDetails.getCapacityUnit().getReadCapacityUnit());
    System.out.println("表的預(yù)留寫(xiě)吞吐量："
            + reservedThroughputDetails.getCapacityUnit().getWriteCapacityUnit());
}

管理預(yù)定義列

以下示例用于為數(shù)據(jù)表增加預(yù)定義列，預(yù)定義列分別為definedColumnName01（String類(lèi)型）、definedColumnName02（Integer類(lèi)型）和definedColumnName03（String類(lèi)型）。

public static void addDefinedColumnRequest(SyncClient client) {
    AddDefinedColumnRequest addDefinedColumnRequest = new AddDefinedColumnRequest();
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    addDefinedColumnRequest.setTableName("<TABLE_NAME>");
    //為數(shù)據(jù)表添加預(yù)定義列。
    addDefinedColumnRequest.addDefinedColumn("definedColumnName01",DefinedColumnType.STRING);
    addDefinedColumnRequest.addDefinedColumn("definedColumnName02",DefinedColumnType.INTEGER);
    addDefinedColumnRequest.addDefinedColumn("definedColumnName03",DefinedColumnType.STRING);
    client.addDefinedColumn(addDefinedColumnRequest);
}

如果不再需要某些預(yù)定義列，您可以刪除預(yù)定義列。

以下示例用于刪除數(shù)據(jù)表的預(yù)定義列definedColumnName01和definedColumnName02。

public static void deleteDefinedColumnRequest(SyncClient client){
    DeleteDefinedColumnRequest deleteDefinedColumnRequest = new DeleteDefinedColumnRequest();
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    deleteDefinedColumnRequest.setTableName("<TABLE_NAME>");
    //添加要?jiǎng)h除的預(yù)定義列。
    deleteDefinedColumnRequest.addDefinedColumn("definedColumnName01");
    deleteDefinedColumnRequest.addDefinedColumn("definedColumnName02");
    client.deleteDefinedColumn(deleteDefinedColumnRequest);
}

刪除數(shù)據(jù)表

以下示例用于刪除exampletable數(shù)據(jù)表。

private static void deleteTable(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱(chēng)。
    DeleteTableRequest request = new DeleteTableRequest("<TABLE_NAME>");
    client.deleteTable(request);
}