使用 Tablestore Java SDK 的多词精确查询可匹配指定字段中与任一查询值完全一致的字段值或分词词条,并返回匹配行或匹配总行数。
前提条件
安装Tablestore Java SDK并初始化客户端。
功能说明
多词精确查询用于在指定字段中同时匹配多个查询值,任一查询值满足精确匹配条件时即可返回该行。对于 Keyword、Long 等非文本字段,字段值必须与其中一个查询值完全一致,这种组合语义类似于 SQL 的 IN 条件;对于 Text 类型字段(字段说明请参见字符串类型),只要分词后的任一词条与其中一个查询词完全一致即可匹配,查询词本身不会被分词。
Text 字段的分词结果可能随分词器配置、算法迭代和语言变化而变化,不建议使用多词精确查询匹配 Text 字段的完整字符串。此类场景可先通过虚拟列将源字段映射为 Keyword 类型,再查询虚拟列。
调用 search 方法时,将查询类型设置为 TermsQuery,并通过 SearchQuery 配置返回数量、总行数统计和其他通用查询行为。
SearchResponse search(SearchRequest request)
以下示例查询 category 字段值与 books 或 games 完全一致的数据,返回最多 10 行数据及匹配总行数。
String tableName = "example_table";
String indexName = "example_index";
TermsQuery termsQuery = new TermsQuery();
termsQuery.setFieldName("category");
termsQuery.addTerm(ColumnValue.fromString("books"));
termsQuery.addTerm(ColumnValue.fromString("games"));
SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(termsQuery);
searchQuery.setLimit(10);
searchQuery.setTrackTotalCount(SearchQuery.TRACK_TOTAL_COUNT);
SearchRequest request = new SearchRequest(tableName, indexName, searchQuery);
SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
columnsToGet.setReturnAll(true);
request.setColumnsToGet(columnsToGet);
SearchResponse response = client.search(request);
System.out.println(response.getTotalCount());
System.out.println(response.getRows());
参数说明
查询请求
request 的类型为 SearchRequest,包含以下参数。
|
名称 |
类型 |
说明 |
|
tableName(必选) |
String |
数据表名称。 |
|
indexName(必选) |
String |
多元索引名称。 |
|
searchQuery(必选) |
SearchQuery |
查询条件和通用查询配置。 |
|
columnsToGet(可选) |
SearchRequest.ColumnsToGet |
返回列配置。未设置时只返回主键列。 |
|
timeoutInMillisecond(可选) |
int |
请求级查询超时时间,单位为毫秒。默认值为 |
|
routingValues(可选) |
|
自定义路由字段对应的主键值列表。未配置自定义路由时无需设置。 |
查询配置
request.searchQuery 的类型为 SearchQuery,包含以下参数。
|
名称 |
类型 |
说明 |
|
query(必选) |
Query |
查询条件。多词精确查询设置为 |
|
offset(可选) |
Integer |
本次查询的起始位置。 |
|
limit(可选) |
Integer |
本次查询返回的最大行数。设置为 |
|
highlight(可选) |
Highlight |
Text 字段的摘要与高亮配置。有关配置方法,请参见摘要与高亮。 |
|
collapse(可选) |
Collapse |
结果折叠配置,用于按指定列对返回结果去重。有关配置方法,请参见折叠(去重)。 |
|
sort(可选) |
Sort |
返回结果的排序方式。有关配置方法,请参见排序和翻页。 |
|
trackTotalCount(可选) |
int |
期望统计的最大匹配行数。默认值为 |
|
filter(可选) |
SearchFilter |
对 |
|
aggregationList(可选) |
|
统计聚合配置。有关配置方法,请参见统计聚合。 |
|
groupByList(可选) |
|
分组配置。有关配置方法,请参见统计聚合。 |
|
token(可选) |
byte[] |
翻页凭证。将上一次响应的 |
查询条件
request.searchQuery.query 的类型为 TermsQuery,包含以下参数。
|
名称 |
类型 |
说明 |
|
fieldName(必选) |
String |
要查询的索引字段名称。 |
|
terms(必选) |
|
查询值列表,最多包含 1,024 个值。任一查询值满足精确匹配条件时即可匹配;对于 Text 字段,每个查询值均作为一个完整词条参与匹配,不会被分词。 |
|
weight(可选) |
float |
查询条件的相关性权重,必须为正浮点数。值越大,该查询条件对 BM25 相关性评分的贡献越高。该参数不影响匹配结果和返回行数,仅在使用 |
返回列
request.columnsToGet 的类型为 SearchRequest.ColumnsToGet,包含以下参数。
|
名称 |
类型 |
说明 |
|
columns(可选) |
|
要返回的属性列名称。仅 |
|
returnAll(可选) |
boolean |
是否返回数据表中的全部属性列。默认值为 |
|
returnAllFromIndex(可选) |
boolean |
是否返回已建立索引的全部属性列。默认值为 |
返回值
search 方法返回 SearchResponse。核心字段如下。
|
名称 |
类型 |
说明 |
|
totalCount |
long |
匹配行数,通过 |
|
rows |
|
本次查询返回的行数据,通过 |
|
searchHits |
|
查询命中结果,通过 |
|
nextToken |
byte[] |
下一页凭证,通过 |
|
isAllSuccess |
boolean |
是否已成功查询全部索引分区,通过 |