使用 Tablestore Go SDK 的嵌套类型查询匹配 Nested 字段中同一子行内满足条件的数据。
前提条件
安装Tablestore Go SDK并初始化客户端。
功能说明
Nested 字段中的每个子行作为独立的嵌套文档建立索引。嵌套类型查询用于确保多个子字段条件在同一子行内匹配,避免普通组合查询跨不同子行误匹配。
func (client *tablestore.TableStoreClient) Search(request *tablestore.SearchRequest) (*tablestore.SearchResponse, error)
以下示例查询数据并返回最多 10 行数据及匹配总行数。
tableName := "example_table"
indexName := "example_index"
query := &search.NestedQuery{Path: "items", Query: &search.TermQuery{FieldName: "items.name", Term: "alice"}, ScoreMode: search.ScoreMode_Avg}
searchQuery := search.NewSearchQuery().
SetQuery(query).
SetLimit(10).
SetGetTotalCount(true)
response, err := client.Search(&tablestore.SearchRequest{
TableName: tableName,
IndexName: indexName,
SearchQuery: searchQuery,
ColumnsToGet: &tablestore.ColumnsToGet{
ReturnAllFromIndex: true,
},
})
if err != nil {
log.Fatal(err)
}
fmt.Println(response.TotalCount)
fmt.Println(response.Rows)
参数说明
查询请求
request 的类型为 tablestore.SearchRequest,包含以下参数。
|
名称 |
类型 |
说明 |
|
TableName(必选) |
string |
数据表名称。 |
|
IndexName(必选) |
string |
多元索引名称。 |
|
SearchQuery(必选) |
search.SearchQuery |
查询条件和通用查询配置。 |
|
ColumnsToGet(可选) |
*tablestore.ColumnsToGet |
返回列配置。未设置时只返回主键列。 |
|
RoutingValues(可选) |
[]*tablestore.PrimaryKey |
自定义路由字段对应的主键值列表。未配置自定义路由时无需设置。 |
|
TimeoutMs(可选) |
*int32 |
请求级超时时间,单位为毫秒。 |
查询配置
通过 search.NewSearchQuery() 创建查询配置,并使用以下方法设置参数。
|
名称 |
类型 |
说明 |
|
SetQuery(必选) |
search.Query |
设置查询条件。 |
|
SetOffset(可选) |
int32 |
设置本次查询的起始位置,默认值为 0。使用 Offset 翻页时,Offset + Limit 不能超过 100000。 |
|
SetLimit(可选) |
int32 |
设置本次查询返回的最大行数,默认值为 10,最大值为 100。设置为 0 时不返回具体行。 |
|
SetCollapse(可选) |
*search.Collapse |
设置结果折叠。配置方法请参见折叠(去重)。 |
|
SetSort(可选) |
*search.Sort |
设置返回结果的排序方式。配置方法请参见排序和翻页。 |
|
SetGetTotalCount(可选) |
bool |
是否统计匹配总行数,默认值为 false。 |
|
SetToken(可选) |
[]byte |
设置上一次响应返回的 NextToken,以继续读取后续数据。调用该方法会清除 Sort,因为 Token 已包含上一页的排序条件。使用 Token 翻页时不能设置 Offset。 |
|
SetSearchFilter(可选) |
*search.SearchFilter |
对查询结果执行后过滤。配置方法请参见查询后过滤。 |
|
Aggregation(可选) |
...search.Aggregation |
设置统计聚合。配置方法请参见统计聚合。 |
|
GroupBy(可选) |
...search.GroupBy |
设置分组。配置方法请参见统计聚合。 |
查询条件
查询类型为 search.NestedQuery,包含以下参数。
|
名称 |
类型 |
说明 |
|
Path(必选) |
string |
Nested 字段路径。 |
|
Query(必选) |
search.Query |
对子字段执行的查询条件。子字段名称使用完整路径,例如 |
|
ScoreMode(可选) |
search.ScoreMode |
子查询评分合并方式。 |
|
InnerHits(可选) |
*search.InnerHits |
返回匹配的嵌套子行,并可为子行设置分页、排序和摘要与高亮。 |
内部命中配置
InnerHits 包含以下参数。
|
名称 |
类型 |
说明 |
|
Offset(可选) |
*int32 |
匹配子行的返回起始位置。 |
|
Limit(可选) |
*int32 |
返回的匹配子行数量,默认值为 3。 |
|
Sort(可选) |
*search.Sort |
匹配子行的排序方式。 |
|
Highlight(可选) |
*search.Highlight |
Nested 子字段的摘要与高亮配置。具体操作请参见摘要与高亮。 |
返回列
request.ColumnsToGet 的类型为 tablestore.ColumnsToGet,包含以下参数。
|
名称 |
类型 |
说明 |
|
Columns(可选) |
[]string |
要返回的属性列名称。仅 ReturnAll 和 ReturnAllFromIndex 均为 false 时生效。 |
|
ReturnAll(可选) |
bool |
是否返回数据表中的全部属性列,默认值为 false。 |
|
ReturnAllFromIndex(可选) |
bool |
是否返回已建立索引的全部属性列,默认值为 false。不能与 ReturnAll 同时设置为 true。 |
返回值
Search 方法返回 tablestore.SearchResponse。核心业务字段如下。
|
名称 |
类型 |
说明 |
|
TotalCount |
int64 |
匹配总行数。返回值取决于 SetGetTotalCount 配置。 |
|
Rows |
[]*tablestore.Row |
本次查询返回的行数据,数量不超过 SetLimit 指定的值。 |
|
SearchHits |
[]*tablestore.SearchHit |
查询命中结果。配置摘要与高亮、嵌套 InnerHits 或需要相关性评分时,从该字段读取结果。 |
|
NextToken |
[]byte |
下一页凭证。值非空时,将其传入下一次查询继续读取。 |
|
IsAllSuccess |
bool |
是否已成功查询全部索引分区。值为 false 时返回的是部分结果,TotalCount 可能小于实际匹配行数。 |
|
AggregationResults |
search.AggregationResults |
统计聚合结果。 |
|
GroupByResults |
search.GroupByResults |
分组结果。 |