在数据表上创建索引表后，可根据需要读取索引表中的数据或者删除数据表上指定的索引表。

前提条件

  • 已初始化Client，详情请参见初始化。
  • 已创建数据表，且数据表的数据生命周期（TimeToLive）必须为-1，最大版本数（MaxVersions）必须为1。
  • 数据表已设置预定义列。

创建索引表（CreateIndex）

使用CreateIndex接口在已存在的数据表上创建索引表。
说明 您也可以使用CreateTable接口在创建数据表的同时创建一个或者多个索引表，详情请参见 创建表。
  • 参数
    参数 说明
    MainTableName 数据表名称。
    IndexMeta 索引表的结构信息，包括如下内容：
    • IndexName：索引表名称。
    • PrimaryKey：索引表的索引列，索引列为数据表主键和预定义列的任意组合。
    • DefinedColumns：索引表的属性列，索引表属性列为数据表的预定义列的组合。
    • IndexType：索引表类型，当前只支持IT_GLOBAL_INDEX。
    IncludeBaseData 索引表中是否包含数据表中已存在的数据。

    当设置IncludeBaseData为true时，表示包含存量数据；设置IncludeBaseData为false时，表示不包含存量数据。
  • 示例
    func CreateGlobalIndexSample(client *tablestore.TableStoreClient, tableName string) {
    indexMeta := new(tablestore.IndexMeta) //新建索引表Meta。
    indexMeta.AddPrimaryKeyColumn("definedcol1") //设置数据表的DEFINED_COL_NAME_1列作为索引表的主键。
    indexMeta.AddDefinedColumn("definedcol2") //设置数据表的definedcol2列作为索引表的属性列。
    indexMeta.IndexName = "indexSample"
    indexReq := &tablestore.CreateIndexRequest{
        MainTableName:tableName, //添加索引表到数据表。
        IndexMeta: indexMeta,
        IncludeBaseData: true, //包含存量数据。
    }
    /**
      通过将IncludeBaseData参数设置为true，创建索引表后会开启数据表中存量数据的同步，然后可以通过索引表查询全部数据，
      同步时间跟数据量的大小有一定的关系。
    */  
    resp, err := client.CreateIndex(indexReq)
    if err != nil {
        fmt.Println("Failed to create table with error:", err)
    } else {
        fmt.Println("Create index finished", resp)
    }
}

读取索引表中数据

从索引表中单行或者范围读取数据，当返回的属性列在索引表中时，可以直接读取索引表获取数据，否则请自行反查数据表获取数据。

  • 单行读取索引表中数据

    详情请参见单行数据操作。

    使用GetRow接口读取索引表中数据时有如下注意事项：
    • TableName需要设置为索引表名称。
    • 由于系统会自动将未出现在索引列中的数据表主键补齐到索引表主键中，所以行的主键时，需要同时设置索引表索引列和补齐的数据表主键。
  • 范围读索引表中数据

    详情请参见多行数据操作。

    • 参数
      使用GetRange接口读取索引表中数据时有如下注意事项：
      • TableName需要设置为索引表名称。
      • 由于系统会自动将未出现在索引列中的数据表主键补齐到索引表主键中，所以设置起始主键和结束主键时，需要同时设置索引表索引列和补齐的数据表主键。
    • 示例
      func GetRangeFromIndex(client *tablestore.TableStoreClient, indexName string) {
    getRangeRequest := &tablestore.GetRangeRequest{}
    rangeRowQueryCriteria := &tablestore.RangeRowQueryCriteria{}
    rangeRowQueryCriteria.TableName = indexName

    startPK := new(tablestore.PrimaryKey)
    startPK.AddPrimaryKeyColumnWithMinValue("pk1") //索引表的第一主键列。
    startPK.AddPrimaryKeyColumnWithMinValue("pk2") //索引表的第二主键列。
    startPK.AddPrimaryKeyColumnWithMinValue("pk3") //索引表的第三主键列。
    endPK := new(tablestore.PrimaryKey)
    endPK.AddPrimaryKeyColumnWithMaxValue("pk1")
    endPK.AddPrimaryKeyColumnWithMaxValue("pk2")
    endPK.AddPrimaryKeyColumnWithMaxValue("pk3")
    rangeRowQueryCriteria.StartPrimaryKey = startPK
    rangeRowQueryCriteria.EndPrimaryKey = endPK
    rangeRowQueryCriteria.Direction = tablestore.FORWARD
    rangeRowQueryCriteria.MaxVersion = 1
    rangeRowQueryCriteria.Limit = 10
    getRangeRequest.RangeRowQueryCriteria = rangeRowQueryCriteria

    getRangeResp, err := client.GetRange(getRangeRequest)

    fmt.Println("get range result is ", getRangeResp)

    for {
        if err != nil {
            fmt.Println("get range failed with error:", err)
        }
        if len(getRangeResp.Rows) > 0 {
            for _, row := range getRangeResp.Rows {
                fmt.Println("range get row with key", row.PrimaryKey.PrimaryKeys[0].Value, row.PrimaryKey.PrimaryKeys[1].Value, row.PrimaryKey.PrimaryKeys[2].Value)
            }
            if getRangeResp.NextStartPrimaryKey == nil {
                break
            } else {
                fmt.Println("next pk is :", getRangeResp.NextStartPrimaryKey.PrimaryKeys[0].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[1].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[2].Value)
                getRangeRequest.RangeRowQueryCriteria.StartPrimaryKey = getRangeResp.NextStartPrimaryKey
                getRangeResp, err = client.GetRange(getRangeRequest)
            }
        } else {
            break
        }

        fmt.Println("continue to query rows")
    }
    fmt.Println("putrow finished")
}

删除索引表（DeleteIndex）

使用DeleteIndex接口删除数据表上指定的索引表。

  • 参数
    参数 说明
    MainTableName 数据表名称。
    IndexName 索引表名称。
  • 示例
    func DeleteIndex(client *tablestore.TableStoreClient, tableName string， indexName string) { 
    deleteIndex := &tablestore.DeleteIndexRequest{ MainTableName:tableName, IndexName: indexName }
    resp, err := client.DeleteIndex(deleteIndex)

    if err != nil {
        fmt.Println("Failed to delete index:", err)
    } else {
        fmt.Println("drop index finished", resp)
    }