表格存储的 SDK 提供了 CreateTable、ListTable、DeleteTable、UpdateTable 和 DescribeTable 等表级别的操作接口。

创建表(CreateTable)

根据给定的表的结构信息创建相应的表。

创建表格存储的表时必须指定表的主键。主键包含 1~4 个主键列,每一个主键列都有名字和类型。

接口

    // 说明:根据表信息创建表。
    // request 是CreateTableRequest类的实例,它包含tablemeta 和 TableOption 以及 ReservedThroughput
   // 请参考TableMeta类的文档。当创建了一个表之后,通常要等待1分钟时间使partition load
   // 完成,才能进行各种操作。
   // 返回:CreateTableResponse。
		CreateTable(request *CreateTableRequest) (*CreateTableResponse, error)
说明 表格存储的表在被创建之后需要几秒钟进行加载,创建成功后需要等待几秒钟后再做其他操作。

示例

创建一个含有 2 个主键列,预留读/写吞吐量为 (0,0) 的表。

        //创建主键列的schema,包括PK的个数,名称和类型
        //第一个PK列为整数,名称是pk0,这个同时也是分片列
        //第二个PK列为整数,名称是pk1

        tableMeta := new(tablestore.TableMeta)
        tableMeta.TableName = tableName
        tableMeta.AddPrimaryKeyColumn("pk0", tablestore.PrimaryKeyType_INTEGER)
        tableMeta.AddPrimaryKeyColumn("pk1", tablestore.PrimaryKeyType_STRING)
        tableOption := new(tablestore.TableOption)
        tableOption.TimeToAlive = -1
        tableOption.MaxVersion = 3
        reservedThroughput := new(tablestore.ReservedThroughput)
        reservedThroughput.Readcap = 0
        reservedThroughput.Writecap = 0
        createtableRequest.TableMeta = tableMeta
        createtableRequest.TableOption = tableOption
        createtableRequest.ReservedThroughput = reservedThroughput
        response, err = client.CreateTable(createtableRequest)
        if (err != nil) {
            fmt.Println("Failed to create table with error:", err)
        } else {
           fmt.Println("Create table finished")
        }
说明 详细代码可在 createTable@GitHub 获取。

列出表名称(ListTable)

获取当前实例下已创建的所有表的表名。

接口

	// 列出所有的表,如果操作成功,将返回所有表的名称。
	ListTable() (*ListTableResponse, error)

示例

获取实例下的所有表名。

	tables, err := client.ListTable()
	if err != nil {
		fmt.Println("Failed to list table")
	} else {
		fmt.Println("List table result is")
		for _, table := range (tables.TableNames) {
			fmt.Println("TableName: ", table)
		}
	}
说明 详细代码可在 listTable@GitHub 获取。

更新表(UpdateTable)

更新指定表的预留读吞吐量或预留写吞吐量的设置。

接口

	// 更改表的tableoptions和reservedthroughput
	UpdateTable(request *UpdateTableRequest) (*UpdateTableResponse, error)

示例

更新表的最大版本数为5。

	updateTableReq := new(tablestore.UpdateTableRequest)
	updateTableReq.TableName = tableName
	updateTableReq.TableOption = new(tablestore.TableOption)
	updateTableReq.TableOption.TimeToAlive = -1
	updateTableReq.TableOption.MaxVersion = 5

	_, err := client.UpdateTable(updateTableReq)

	if (err != nil) {
		fmt.Println("failed to update table with error:", err)
	} else {
		fmt.Println("update finished")
	}
说明 详细代码可在 updateTable@GitHub 获取。

查询表描述信息(DescribeTable)

查询指定表的结构信息和预留读/写吞吐量的设置信息。

接口

// 通过表名查询表描述信息
DescribeTable(request *DescribeTableRequest) (*DescribeTableResponse, error)

示例

	describeTableReq := new(tablestore.DescribeTableRequest)
	describeTableReq.TableName = tableName
	describ, err := client.DescribeTable(describeTableReq)
	if err != nil {
		fmt.Println("failed to update table with error:", err)
	} else {
		fmt.Println("DescribeTableSample finished. Table meta:", describ.TableOption.MaxVersion, describ.TableOption.TimeToAlive)
	}

说明 详细代码可在 describeTable@GitHub 获取。

删除表(DeleteTable)

删除本实例下指定的表。

接口

DeleteTable(request *DeleteTableRequest) (*DeleteTableResponse, error)

示例

删除表。

	deleteReq := new(tablestore.DeleteTableRequest)
	deleteReq.TableName = tableName
	_, err := client.DeleteTable(deleteReq)
	if (err != nil) {
		fmt.Println("Failed to delete table with error:", err)
	} else {
		fmt.Println("Delete table finished")
	}
说明 详细代码可在 deleteTable@GitHub 获取。