使用多元索引查詢數據時,通過預先定義排序方式或者查詢時指定排序方式,您可以按照指定排列方式獲取到返回數據。當返回結果行數較多時,通過使用跳轉翻頁或者連續翻頁可以快速定位到所需數據。
使用場景
分類 | 使用方式 | 功能 | 使用場景 |
排序 | 創建時指定排序方式 | 多元索引默認按照設置的索引預排序(IndexSort)方式進行排序,用于確定數據的默認返回順序。 | |
查詢時指定排序方式 | 按照查詢結果的相關性(BM25算法)分數進行排序,適用于有相關性的場景,例如全文檢索等。 | ||
按照主鍵進行排序,適用于按照事物標識排序的場景。 | |||
按照字段值進行排序,適用于電商、社交媒資等按照事物屬性排序的場景,例如商品銷量、瀏覽量等。 | |||
根據地理點距離進行排序,適用于地圖、物流等按照距離排序事物的場景,例如某個位置周邊餐廳按距離排序等。 | |||
翻頁 | 查詢時指定翻頁方式 | 返回結果行數小于100000行時用于跳轉翻頁。 | |
用于連續翻頁,默認只能向后翻頁。由于在一次查詢的翻頁過程中Token長期有效,您可以通過緩存并使用之前的Token實現向前翻頁。 |
索引預排序
多元索引默認按照設置的索引預排序(IndexSort)方式進行排序,使用多元索引查詢數據時,IndexSort決定了數據的默認返回順序。
在創建多元索引時,您可以自定義IndexSort,如果未自定義IndexSort,則IndexSort默認為主鍵排序。
索引預排序只支持PrimaryKeySort (按照主鍵排序)和FieldSort(按照字段值排序)兩種方式。
含有Nested類型字段的多元索引不支持索引預排序。
創建多元索引后,如果要修改多元索引的IndexSort,您可以使用動態修改schema功能實現。具體操作,請參見動態修改schema。
查詢時排序
只有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翻頁
當需要獲取的返回結果行數小于100000行時,可以通過Limit和Offset進行翻頁,即Limit+Offset<=100000,其中Limit的最大值為100。
如果需要提高Limit的上限,請參見如何將多元索引 Search 接口查詢數據的 limit 提高到 1000。
如果使用此方式進行翻頁時未設置Limit和Offset,則Limit的默認值為10,Offset的默認值為0。
searchQuery := search.NewSearchQuery()
searchQuery.SetLimit(10)
searchQuery.SetOffset(10)
使用Token翻頁
由于使用Token進行翻頁時翻頁深度無限制,當需要進行深度翻頁時,推薦使用Token進行翻頁。
當符合查詢條件的數據未讀取完時,服務端會返回NextToken,此時可以使用NextToken繼續讀取后面的數據。
使用Token進行翻頁時默認只能向后翻頁。由于在一次查詢的翻頁過程中Token長期有效,您可以通過緩存并使用之前的Token實現向前翻頁。
如果需要持久化NextToken或者傳輸NextToken給前端頁面,您可以使用Base64編碼將NextToken編碼為String進行保存和傳輸。Token本身不是字符串,直接使用string(NextToken)
將Token編碼為String會造成Token信息丟失。
使用Token翻頁后的排序方式和上一次請求的一致,無論是系統默認使用IndexSort還是自定義排序,因此設置了Token不能再設置Sort。另外使用Token后不能設置Offset,只能依次往后讀取,即無法跳頁。
由于含有Nested類型字段的多元索引不支持索引預排序,如果使用含有Nested類型字段的多元索引查詢數據且需要翻頁,則必須在查詢條件中指定數據返回的排序方式,否則當符合查詢條件的數據未讀取完時,服務端不會返回NextToken。
/**
* 使用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 {
{
// 如果需要持久化NextToken或者傳輸NextToken給前端頁面,您可以使用Base64編碼將NextToken編碼為String進行保存和傳輸。
// Token本身不是字符串,直接使用string(NextToken)將Token編碼為String會造成Token信息丟失。
tokenAsString := base64.StdEncoding.EncodeToString(searchResponse.NextToken)
// 將String解碼為byte。
tokenAsByte, err := base64.StdEncoding.DecodeString(tokenAsString)
if err != nil {
fmt.Printf("len:%d, %#v",len(tokenAsByte), err)
return
}
}
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)
}
}