使用多元索引时,可以在创建时指定索引预排序和在查询时指定排序方式,在获取返回结果时可以使用Limit和Offset或者使用Token进行翻页。

索引预排序(IndexSort)

多元索引默认会按照索引中设置的IndexSort进行排序,IndexSort决定了多元索引查询时默认的返回顺序,默认的IndexSort为主键排序,在创建索引时可以自定义预排序方式。如果未自定义IndexSort,即按照主键顺序返回。

说明 含有Nested类型的索引不支持IndexSort,没有预排序。

查询时指定排序方式

只有EnableSortAndAgg设置为true的字段才能进行排序。

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

  • ScoreSort
    按照查询结果的相关性(BM25算法)分数进行排序,适用于有相关性的场景,例如全文检索等。
    说明 如果需要按照相关性打分进行排序,必须手动设置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或者使用Token进行翻页。

  • 使用Limit和Offset

    当需要获取的返回结果行数小于10000行时,可以通过Limit和Offset进行翻页,Limit+Offset<=10000。

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

    当符合查询条件的数据未读取完时,服务端会返回NextToken,此时可以使用NextToken继续读取后面的数据。

    使用Token翻页后的排序方式和上一次请求的一致,无论是系统默认使用IndexSort还是自定义排序,因此设置了Token不能再设置Sort。另外使用Token后不能设置Offset,只能依次往后读取,即无法跳页。

    /**
     * 使用Token进行翻页读取。
     * 如果SearchResponse返回了NextToken,可以使用此Token发起下一次查询,直到NextToken为空(nil)。
     * 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)
        }
    }