本文主要为您介绍排序方式以及翻页方式。

索引预排序(IndexSort)

多元索引默认会按照索引中配置的IndexSort进行排序(含有NESTED类型的索引不支持IndexSort,没有预排序),默认的IndexSort为主键排序,用户可以在创建索引时自定义预排序方式。IndexSort决定了多元索引查询时默认的返回顺序,若用户未自定义IndexSort,即按照主键顺序返回。

查询时指定排序方式

在每次查询时,用户也可以指定排序方式,多元索引支持以下四种排序方式(Sorter)。用户也可以使用多个Sorter,实现先按照某种方式排序,再按照某种方式排序的需求。

ScoreSort

按照分数进行排序,应用在全文索引等有相关性的场景下。需要注意的时,必须手动设置ScoreSort,才能按照相关性打分进行排序,否则会按照索引设置的IndexSort进行排序返回。

    searchQuery := search.NewSearchQuery()
    searchQuery.SetSort(&search.Sort{
        []search.Sorter{
            &search.ScoreSort{
                Order: search.SortOrder_DESC.Enum(), //从得分高到低
            },
        },
    })
PrimaryKeySort

按照主键排序。

searchQuery := search.NewSearchQuery()
    searchQuery.SetSort(&search.Sort{
        []search.Sorter{
            &search.PrimaryKeySort{
                Order: search.SortOrder_ASC.Enum(),
            },
        },
    })
FieldSort

按照某列进行排序。

    // 设置按照Col_Long这一列逆序排序
    searchQuery.SetSort(&search.Sort{
        []search.Sorter{
            &search.FieldSort{
                FieldName: "Col_Long",
                Order:     search.SortOrder_DESC.Enum(),
            },
        },
    })

先按照某列排序,再按照另一列排序。

searchQuery.SetSort(&search.Sort{
        []search.Sorter{
            &search.FieldSort{
                FieldName: "col1",
                Order:     search.SortOrder_ASC.Enum(),
            },
            &search.FieldSort{
                FieldName: "col2",
                Order:     search.SortOrder_DESC.Enum(),
            },
        },
    })
GeoDistanceSort

根据地理点距离进行排序。

    searchQuery.SetSort(&search.Sort{
        []search.Sorter{
            &search.GeoDistanceSort{
                FieldName: "location",   // 设置Geo点的字段名
                Points:    []string{"40,-70"}, // 设置中心点
            },
        },
    })

翻页方式

使用limit和offset

当需要获取的总条数小于2000行时,可以通过limit和offset进行翻页,limit+offset <= 2000。

searchQuery := search.NewSearchQuery()
searchQuery.SetLimit(10)
searchQuery.SetOffset(10) 
使用token进行翻页

如果符合查询条件的数据没有读完,服务端会返回NextToken,用户可以使用NextToken继续读取后面的数据。使用Token后排序方式会跟上一次请求一致(不管是系统默认采用IndexSort排序还是用户自定义排序),因此设置了Token不能再设置Sort。\u0008另外,使用Token后不能设置Offset,只能一次一次往后读,即无法跳页。

/**
 * 使用Token进行翻页读取。
 * 如果SearchResponse返回了NextToken,可以使用这个Token发起下一次查询,
 * 直到NextToken为空(nil),此时代表所有符合条件的数据已经读完。
 */
func QueryRowsWithToken(client *tablestore.TableStoreClient, tableName string, indexName string) {
    querys := []search.Query{
        &search.MatchAllQuery{},
        &search.TermQuery{
            FieldName: "Col_Keyword",
            Term:      "tablestore",
        },
    }
    for _, query := range querys {
        fmt.Printf("Test query: %#v\n", query)
        searchRequest := &tablestore.SearchRequest{}
        searchRequest.SetTableName(tableName)
        searchRequest.SetIndexName(indexName)
        searchQuery := search.NewSearchQuery()
        searchQuery.SetQuery(query)
        searchQuery.SetLimit(10)
        searchQuery.SetGetTotalCount(true)
        searchRequest.SetSearchQuery(searchQuery)
        searchResponse, err := client.Search(searchRequest)
        if err != nil {
            fmt.Printf("%#v", err)
            return
        }
        rows := searchResponse.Rows
        requestCount := 1
        for searchResponse.NextToken != nil {
            searchQuery.SetToken(searchResponse.NextToken)
            searchResponse, err = client.Search(searchRequest)
            if err != nil {
                fmt.Printf("%#v", err)
                return
            }
            requestCount++
            for _, r := range searchResponse.Rows {
                rows = append(rows, r)
            }
        }
        fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess)
        fmt.Println("TotalCount: ", searchResponse.TotalCount)
        fmt.Println("RowsSize: ", len(rows))
        fmt.Println("RequestCount: ", requestCount)
    }
}