Elasticsearch 入门实战(9)--Java API Client 使用二
本文继续上文(Elasticsearch 入门实战(5)--Java API Client 使用一(Index,Document,Ingest,SQL APIs))先容 Java API Client，相关的情况及软件信息如下：CentOS 7.6.1810、Java 1.8.0_341(客户端用)、Elasticsearch 8.13.4、elasticsearch-java 8.13.4。1、Search APIs
1.1、Count API(查询文档数量)
/**
* 查询文档数量
*/
@Test
public void count() throws IOException {
//查询该索引的所有文档数量
CountResponse response = client.count(builder -> builder.index(INDEX_NAME));
log.info("response={}", response);
//通过 Lucene 查询语法指定条件；8.13.4会报错”contains unrecognized parameter: “，因为 API 提交了请求 "{}"，应该时不需要请求体
//response = client.count(builder -> builder.index(INDEX_NAME).q("name:杜甫"));
log.info("response={}", response);
//通过 "Query DSL" 指定条件
response = client.count(builder -> builder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("杜甫")
)
)
);
log.info("response={}", response);
}1.2、Search API(查询文档)
1.2.1、query
1.2.1.1、term/terms 查询
/**
* term/terms 查询，对输入内容不做分词处理
*/
@Test
public void searchTerm() throws IOException {
SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("李白")))
.sort(sortOptionsBuilder -> sortOptionsBuilder
.field(fieldSortBuilder -> fieldSortBuilder
.field("age").order(SortOrder.Asc)))
.source(sourceConfigBuilder -> sourceConfigBuilder
.filter(sourceFilterBuilder -> sourceFilterBuilder
.includes("age", "name")))
.from(0)
.size(10)
, Map.class);
log.info("response={}", response);
List<FieldValue> words = new ArrayList<>();
words.add(new FieldValue.Builder().stringValue("李白").build());
words.add(new FieldValue.Builder().stringValue("杜甫").build());
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.terms(termsQueryBuilder -> termsQueryBuilder
.field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
.source(sourceConfigBuilder -> sourceConfigBuilder
.filter(sourceFilterBuilder -> sourceFilterBuilder
.excludes("about")))
.from(0)
.size(10)
, Poet.class);
log.info("response2={}", response2);
}1.2.1.2、range 查询
/**
* range 查询，范围查询
*/
@Test
public void searchRange() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
, Poet.class);
log.info("response={}", response);
}1.2.1.3、exists 查询
/**
* exists 查询，查询对应字段不为空的数据
*/
@Test
public void exists() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME).query(builder -> builder.exists(builder1 -> builder1.field("poems")))
, Poet.class);
log.info("response={}", response);
}1.2.1.4、match 相关查询
A、match
/**
* match查询，对输入内容先分词再查询
*/
@Test
public void searchMatch() throws IOException {
SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想")))
, Map.class);
log.info("response={}", response);
}B、multi_match
/**
* multi_match 查询，多个字段进行匹配。
*/
@Test
public void searchMultiMatch() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
.fields("about", "success").query("思想")))
, Poet.class);
log.info("response={}", response);
}C、match_phrase
/**
* match_phrase 查询,类似 match，先把查询字符串分词生成一个词列表，查询包含所有这些词且这些词在文档中出现次序一致的数据。
*/
@Test
public void searchMatchPhrase() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder
.field("success").query("伟大作家")))
, Poet.class);
log.info("response={}", response);
}D、match_all
/**
* match_all 查询，查询所有文档
*/
@Test
public void searchMatchAll() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
, Poet.class);
log.info("response={}", response);
//不加请求体，也是一样的效果，查询所有文档。
response = client.search(searchRequestBuilder -> searchRequestBuilder.index(INDEX_NAME), Poet.class);
log.info("response={}", response);
}E、match_none
/**
* match_none 查询，与 match_all 相反，返回 0 个文档。
*/
@Test
public void searchMatchNone() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchNone(matchAllQueryBuilder -> matchAllQueryBuilder))
, Poet.class);
log.info("response={}", response);
}1.2.1.5、query_string 查询
/**
* query_string 查询，可以同时实现多种查询
*/
@Test
public void searchQueryString() throws IOException {
//类似 match
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.defaultField("success").query("古典文学")))
, Poet.class);
log.info("response={}", response);
//类似 mulit_match
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("about", "success").query("古典文学")))
, Poet.class);
log.info("response={}", response);
//类似 match_phrase
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.defaultField("success").query("\"文学作家\"")))
, Poet.class);
log.info(response.toString());
//带运算符查询，运算符两边的词不再分词
//查询同时包含 ”文学“ 和 ”伟大“ 的文档
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("success").query("文学 AND 伟大")))
, Poet.class);
log.info("response={}", response);
//等同上一个查询
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("success").query("文学 伟大").defaultOperator(Operator.And)))
, Poet.class);
log.info("response={}", response);
//查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("name","success").query("(文学 AND 伟大) OR 高度")))
, Poet.class);
log.info("response={}", response);
}1.2.1.6、simple_query_string 查询
/**
* simple_query_string 查询，类似 query_string，主要区别如下：
* 1、不支持 AND OR NOT，会当做字符处理；使用 + 代替 AND，| 代替 OR，- 代替 NOT
* 2、会忽略错误的语法
*/
@Test
public void searchSimpleQueryString() throws IOException {
//查询同时包含 ”文学“ 和 ”伟大“ 的文档
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
.fields("success").query("文学 + 伟大")))
, Poet.class);
log.info("response={}", response);
}3.4.7、fuzzy 查询
/**
* 模糊查询
*/
@Test
public void searchFuzzy() throws IOException {
//全文查询时使用模糊参数，先分词再计算模糊选项。
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思考").fuzziness("1")))
, Poet.class);
log.info(response.toString());
//使用 fuzzy query，对输入不分词，直接计算模糊选项。
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.fuzzy(fuzzyQueryBuilder ->fuzzyQueryBuilder
.field("success").fuzziness("1").value("理想")))
, Poet.class);
log.info(response2.toString());
}1.2.1.8、wildcard 查询
/**
* wildcard 查询，类似 SQL 语句中的 like；? 匹配一个字符，* 匹配多个字符
*/
@Test
public void searchWildcard() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder.wildcard(wildcardQueryBuilder -> wildcardQueryBuilder
.field("name")
.wildcard("李*")))
, Poet.class);
log.info(response.toString());
}1.2.1.9、bool 查询
/**
* bool 查询,组合查询
*/
@Test
public void searchBool() throws IOException {
//查询 success 包含 “思想” 且 age 在 之间的文档
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.must(queryBuilder2 -> queryBuilder2
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想"))
)
.must(queryBuilder2 -> queryBuilder2
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
)
)
)
, Poet.class);
log.info(response.toString());
//过滤出 success 包含 “思想” 且 age 在 之间的文档，不计算得分
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.filter(queryBuilder2 -> queryBuilder2
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想"))
)
.filter(queryBuilder2 -> queryBuilder2
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
)
)
)
, Poet.class);
log.info(response2.toString());
}1.2.2、aggs 查询
/**
* aggs 查询,聚合查询
*/
@Test
public void searchAggs() throws IOException {
//求和，类似 select sum(age) from poet-index
SearchResponse response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_sum", aggregationBuilder -> aggregationBuilder
.sum(sumAggregationBuilder -> sumAggregationBuilder
.field("age")))
, Poet.class);
log.info(response.toString());
//类似 select count distinct(age) from poet-index
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_count", aggregationBuilder -> aggregationBuilder
.cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
, Poet.class);
log.info(response.toString());
//数量、最大、最小、平均、求和
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_stats", aggregationBuilder -> aggregationBuilder
.stats(statsAggregationBuilder -> statsAggregationBuilder
.field("age")))
, Poet.class);
log.info(response.toString());
//select name,count(*) from poet-index group by name
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("name_terms", aggregationBuilder -> aggregationBuilder
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("name")))
, Map.class);
log.info(response.toString());
//select name,age,count(*) from poet-index group by name,age
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("name_terms", aggregationBuilder -> aggregationBuilder
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("name")
)
.aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("age")
))
)
, Poet.class);
log.info(response.toString());
//类似 select avg(age) from poet-index where name='李白'
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.filter(queryBuilder2 -> queryBuilder2
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("李白")))))
.aggregations("ave_age", aggregationBuilder -> aggregationBuilder
.avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
, Poet.class);
log.info(response.toString());
}1.2.3、suggest 查询
/**
* suggest 查询，推荐查询
*/
@Test
public void searchSuggest() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.suggest(suggesterBuilder -> suggesterBuilder
.suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
.text("思考")
.term(termSuggesterBuilder -> termSuggesterBuilder
.field("success")
.suggestMode(SuggestMode.Always)
.minWordLength(2)
)
)
)
, Poet.class);
log.info(response.toString());
}1.2.4、highlight
/**
* 高亮显示
*/
@Test
public void searchHighlight() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想")))
.highlight(highlightBuilder -> highlightBuilder
.preTags("<span color='red'>")
.postTags("</span>")
.fields("success", highlightFieldBuilder -> highlightFieldBuilder))
, Poet.class);
log.info(response.toString());
}2、完整代码
https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gifhttps://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gifpackage com.abc.demo.es;
import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch._types.FieldValue;
import co.elastic.clients.elasticsearch._types.SortOrder;
import co.elastic.clients.elasticsearch._types.SuggestMode;
import co.elastic.clients.elasticsearch._types.query_dsl.Operator;
import co.elastic.clients.elasticsearch.core.*;
import co.elastic.clients.json.JsonData;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@Slf4j
public class ElasticsearchJavaCase2 {
private static final String INDEX_NAME = "poet-index";
private ElasticsearchTransport transport;
private ElasticsearchClient client;
@Before
public void before() {
RestClient restClient = RestClient.builder(
new HttpHost("10.49.196.10", 9200),
new HttpHost("10.49.196.11", 9200),
new HttpHost("10.49.196.12", 9200)).build();
ObjectMapper objectMapper = new ObjectMapper();
transport = new RestClientTransport(restClient, new JacksonJsonpMapper(objectMapper));
client = new ElasticsearchClient(transport);
}
@After
public void after() throws IOException {
transport.close();
}
/**
* 查询文档数量
*/
@Test
public void count() throws IOException {
//查询该索引的所有文档数量
CountResponse response = client.count(builder -> builder.index(INDEX_NAME));
log.info("response={}", response);
//通过 Lucene 查询语法指定条件；8.13.4会报错”contains unrecognized parameter: “，因为 API 提交了请求 "{}"，应该时不需要请求体
//response = client.count(builder -> builder.index(INDEX_NAME).q("name:杜甫"));
log.info("response={}", response);
//通过 "Query DSL" 指定条件
response = client.count(builder -> builder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("杜甫")
)
)
);
log.info("response={}", response);
}
/**
* term/terms查询,对输入内容不做分词处理
*/
@Test
public void searchTerm() throws IOException {
SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("李白")))
.sort(sortOptionsBuilder -> sortOptionsBuilder
.field(fieldSortBuilder -> fieldSortBuilder
.field("age").order(SortOrder.Asc)))
.source(sourceConfigBuilder -> sourceConfigBuilder
.filter(sourceFilterBuilder -> sourceFilterBuilder
.includes("age", "name")))
.from(0)
.size(10)
, Map.class);
log.info("response={}", response);
List<FieldValue> words = new ArrayList<>();
words.add(new FieldValue.Builder().stringValue("李白").build());
words.add(new FieldValue.Builder().stringValue("杜甫").build());
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.terms(termsQueryBuilder -> termsQueryBuilder
.field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
.source(sourceConfigBuilder -> sourceConfigBuilder
.filter(sourceFilterBuilder -> sourceFilterBuilder
.excludes("about")))
.from(0)
.size(10)
, Poet.class);
log.info("response2={}", response2);
}
/**
* range(范围)查询
*/
@Test
public void searchRange() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
, Poet.class);
log.info("response={}", response);
}
/**
* exists 查询，查询对应字段不为空的数据
*/
@Test
public void exists() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME).query(builder -> builder.exists(builder1 -> builder1.field("poems")))
, Poet.class);
log.info("response={}", response);
}
/**
* match查询，对输入内容先分词再查询
*/
@Test
public void searchMatch() throws IOException {
SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想")))
, Map.class);
log.info("response={}", response);
}
/**
* multi_match 查询，多个字段进行匹配。
*/
@Test
public void searchMultiMatch() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
.fields("about", "success").query("思想")))
, Poet.class);
log.info("response={}", response);
}
/**
* match_phrase 查询,类似 match，先把查询字符串分词生成一个词列表，查询包含所有这些词且这些词在文档中出现次序一致的数据。
*/
@Test
public void searchMatchPhrase() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder
.field("success").query("伟大作家")))
, Poet.class);
log.info("response={}", response);
}
/**
* match_all 查询，查询所有文档
*/
@Test
public void searchMatchAll() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
, Poet.class);
log.info("response={}", response);
//不加请求体，也是一样的效果，查询所有文档。
response = client.search(searchRequestBuilder -> searchRequestBuilder.index(INDEX_NAME), Poet.class);
log.info("response={}", response);
}
/**
* match_none 查询，与 match_all 相反，返回 0 个文档。
*/
@Test
public void searchMatchNone() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.matchNone(matchAllQueryBuilder -> matchAllQueryBuilder))
, Poet.class);
log.info("response={}", response);
}
/**
* query_string 查询，可以同时实现多种查询
*/
@Test
public void searchQueryString() throws IOException {
//类似 match
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.defaultField("success").query("古典文学")))
, Poet.class);
log.info("response={}", response);
//类似 mulit_match
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("about", "success").query("古典文学")))
, Poet.class);
log.info("response={}", response);
//类似 match_phrase
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.defaultField("success").query("\"文学作家\"")))
, Poet.class);
log.info(response.toString());
//带运算符查询，运算符两边的词不再分词
//查询同时包含 ”文学“ 和 ”伟大“ 的文档
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("success").query("文学 AND 伟大")))
, Poet.class);
log.info("response={}", response);
//等同上一个查询
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("success").query("文学 伟大").defaultOperator(Operator.And)))
, Poet.class);
log.info("response={}", response);
//查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.queryString(queryStringQueryBuilder -> queryStringQueryBuilder
.fields("name","success").query("(文学 AND 伟大) OR 高度")))
, Poet.class);
log.info("response={}", response);
}
/**
* simple_query_string 查询,类似 query_string，主要区别如下：
* 1、不支持 AND OR NOT，会当做字符处理；使用 + 代替 AND，| 代替 OR，- 代替 NOT
* 2、会忽略错误的语法
*/
@Test
public void searchSimpleQueryString() throws IOException {
//查询同时包含 ”文学“ 和 ”伟大“ 的文档
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
.fields("success").query("文学 + 伟大")))
, Poet.class);
log.info("response={}", response);
}
/**
* 模糊查询
*/
@Test
public void searchFuzzy() throws IOException {
//全文查询时使用模糊参数，先分词再计算模糊选项。
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思考").fuzziness("1")))
, Poet.class);
log.info(response.toString());
//使用 fuzzy query，对输入不分词，直接计算模糊选项。
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.fuzzy(fuzzyQueryBuilder ->fuzzyQueryBuilder
.field("success").fuzziness("1").value("理想")))
, Poet.class);
log.info(response2.toString());
}
/**
* wildcard 查询，类似 SQL 语句中的 like；? 匹配一个字符，* 匹配多个字符
*/
@Test
public void searchWildcard() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder.wildcard(wildcardQueryBuilder -> wildcardQueryBuilder
.field("name")
.wildcard("李*")))
, Poet.class);
log.info(response.toString());
}
/**
* bool 查询,组合查询
*/
@Test
public void searchBool() throws IOException {
//查询 success 包含 “思想” 且 age 在 之间的文档
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.must(queryBuilder2 -> queryBuilder2
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想"))
)
.must(queryBuilder2 -> queryBuilder2
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
)
)
)
, Poet.class);
log.info(response.toString());
//过滤出 success 包含 “思想” 且 age 在 之间的文档，不计算得分
SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.filter(queryBuilder2 -> queryBuilder2
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想"))
)
.filter(queryBuilder2 -> queryBuilder2
.range(rangeQueryBuilder -> rangeQueryBuilder
.field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
)
)
)
, Poet.class);
log.info(response2.toString());
}
/**
* aggs 查询，聚合查询
*/
@Test
public void searchAggs() throws IOException {
//求和，类似 select sum(age) from poet-index
SearchResponse response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_sum", aggregationBuilder -> aggregationBuilder
.sum(sumAggregationBuilder -> sumAggregationBuilder
.field("age")))
, Poet.class);
log.info(response.toString());
//类似 select count distinct(age) from poet-index
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_count", aggregationBuilder -> aggregationBuilder
.cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
, Poet.class);
log.info(response.toString());
//数量、最大、最小、平均、求和
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("age_stats", aggregationBuilder -> aggregationBuilder
.stats(statsAggregationBuilder -> statsAggregationBuilder
.field("age")))
, Poet.class);
log.info(response.toString());
//select name,count(*) from poet-index group by name
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("name_terms", aggregationBuilder -> aggregationBuilder
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("name")))
, Map.class);
log.info(response.toString());
//select name,age,count(*) from poet-index group by name,age
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.aggregations("name_terms", aggregationBuilder -> aggregationBuilder
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("name")
)
.aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
.terms(termsAggregationBuilder -> termsAggregationBuilder
.field("age")
))
)
, Poet.class);
log.info(response.toString());
//类似 select avg(age) from poet-index where name='李白'
response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.bool(boolQueryBuilder -> boolQueryBuilder
.filter(queryBuilder2 -> queryBuilder2
.term(termQueryBuilder -> termQueryBuilder
.field("name").value("李白")))))
.aggregations("ave_age", aggregationBuilder -> aggregationBuilder
.avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
, Poet.class);
log.info(response.toString());
}
/**
* suggest 查询，推荐搜索
*/
@Test
public void searchSuggest() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.suggest(suggesterBuilder -> suggesterBuilder
.suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
.text("思考")
.term(termSuggesterBuilder -> termSuggesterBuilder
.field("success")
.suggestMode(SuggestMode.Always)
.minWordLength(2)
)
)
)
, Poet.class);
log.info(response.toString());
}
/**
* 高亮显示
*/
@Test
public void searchHighlight() throws IOException {
SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
.index(INDEX_NAME)
.query(queryBuilder -> queryBuilder
.match(matchQueryBuilder -> matchQueryBuilder
.field("success").query("思想艺术")))
.highlight(highlightBuilder -> highlightBuilder
.preTags("<span color='red'>")
.postTags("</span>")
.fields("success", highlightFieldBuilder -> highlightFieldBuilder))
, Poet.class);
log.info(response.toString());
}
@Data
@AllArgsConstructor
@NoArgsConstructor
static class Poet {
private Integer age;
private String name;
private String poems;
private String about;
/**成就*/
private String success;
}
}ElasticsearchJavaCase2.java
具体的 Elasticsearch Java API Client 使用说明，请参考官网文档：https://www.elastic.co/guide/en/elasticsearch/client/java-api-client/current/index.html。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]