Elasticsearch 入门实战(9)--Java API Client 使用二

民工心事  金牌会员 | 2024-7-28 19:27:00 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 892|帖子 892|积分 2676

本文继续上文(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(查询文档数量)
  1. /**
  2. * 查询文档数量
  3. */
  4. @Test
  5. public void count() throws IOException {
  6.     //查询该索引的所有文档数量
  7.     CountResponse response = client.count(builder -> builder.index(INDEX_NAME));
  8.     log.info("response={}", response);
  10.     //通过 Lucene 查询语法指定条件；8.13.4会报错”contains unrecognized parameter: [q]“，因为 API 提交了请求 "{}"，应该时不需要请求体
  11.     //response = client.count(builder -> builder.index(INDEX_NAME).q("name:杜甫"));
  12.     log.info("response={}", response);
  14.     //通过 "Query DSL" 指定条件
  15.     response = client.count(builder -> builder
  16.             .index(INDEX_NAME)
  17.             .query(queryBuilder -> queryBuilder
  18.                     .term(termQueryBuilder -> termQueryBuilder
  19.                             .field("name").value("杜甫")
  20.                     )
  21.             )
  22.     );
  23.     log.info("response={}", response);
  24. }
复制代码
1.2、Search API(查询文档)

1.2.1、query

1.2.1.1、term/terms 查询
  1. /**
  2. * term/terms 查询，对输入内容不做分词处理
  3. */
  4. @Test
  5. public void searchTerm() throws IOException {
  6.     SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .term(termQueryBuilder -> termQueryBuilder
  10.                                     .field("name").value("李白")))
  11.                     .sort(sortOptionsBuilder -> sortOptionsBuilder
  12.                             .field(fieldSortBuilder -> fieldSortBuilder
  13.                                     .field("age").order(SortOrder.Asc)))
  14.                     .source(sourceConfigBuilder -> sourceConfigBuilder
  15.                             .filter(sourceFilterBuilder -> sourceFilterBuilder
  16.                                     .includes("age", "name")))
  17.                     .from(0)
  18.                     .size(10)
  19.             , Map.class);
  20.     log.info("response={}", response);
  22.     List<FieldValue> words = new ArrayList<>();
  23.     words.add(new FieldValue.Builder().stringValue("李白").build());
  24.     words.add(new FieldValue.Builder().stringValue("杜甫").build());
  25.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  26.                     .index(INDEX_NAME)
  27.                     .query(queryBuilder -> queryBuilder
  28.                             .terms(termsQueryBuilder -> termsQueryBuilder
  29.                                     .field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
  30.                     .source(sourceConfigBuilder -> sourceConfigBuilder
  31.                             .filter(sourceFilterBuilder -> sourceFilterBuilder
  32.                                     .excludes("about")))
  33.                     .from(0)
  34.                     .size(10)
  35.             , Poet.class);
  36.     log.info("response2={}", response2);
  37. }
复制代码
1.2.1.2、range 查询
  1. /**
  2. * range 查询，范围查询
  3. */
  4. @Test
  5. public void searchRange() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .range(rangeQueryBuilder -> rangeQueryBuilder
  10.                                     .field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
  11.             , Poet.class);
  12.     log.info("response={}", response);
  13. }
复制代码
1.2.1.3、exists 查询
  1. /**
  2. * exists 查询，查询对应字段不为空的数据
  3. */
  4. @Test
  5. public void exists() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME).query(builder -> builder.exists(builder1 -> builder1.field("poems")))
  8.             , Poet.class);
  9.     log.info("response={}", response);
  10. }
复制代码
1.2.1.4、match 相关查询

A、match
  1. /**
  2. * match查询，对输入内容先分词再查询
  3. */
  4. @Test
  5. public void searchMatch() throws IOException {
  6.     SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .match(matchQueryBuilder -> matchQueryBuilder
  10.                                     .field("success").query("思想")))
  11.             , Map.class);
  12.     log.info("response={}", response);
  13. }
复制代码
B、multi_match
  1. /**
  2. * multi_match 查询，多个字段进行匹配。
  3. */
  4. @Test
  5. public void searchMultiMatch() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
  10.                                     .fields("about", "success").query("思想")))
  11.             , Poet.class);
  12.     log.info("response={}", response);
  13. }
复制代码
C、match_phrase
  1. /**
  2. * match_phrase 查询,类似 match，先把查询字符串分词生成一个词列表，查询包含所有这些词且这些词在文档中出现次序一致的数据。
  3. */
  4. @Test
  5. public void searchMatchPhrase() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder
  10.                                     .field("success").query("伟大作家")))
  11.             , Poet.class);
  12.     log.info("response={}", response);
  13. }
复制代码
D、match_all
  1. /**
  2. * match_all 查询，查询所有文档
  3. */
  4. @Test
  5. public void searchMatchAll() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
  10.             , Poet.class);
  11.     log.info("response={}", response);
  13.     //不加请求体，也是一样的效果，查询所有文档。
  14.     response = client.search(searchRequestBuilder -> searchRequestBuilder.index(INDEX_NAME), Poet.class);
  15.     log.info("response={}", response);
  16. }
复制代码
E、match_none
  1. /**
  2. * match_none 查询，与 match_all 相反，返回 0 个文档。
  3. */
  4. @Test
  5. public void searchMatchNone() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .matchNone(matchAllQueryBuilder -> matchAllQueryBuilder))
  10.             , Poet.class);
  11.     log.info("response={}", response);
  12. }
复制代码
1.2.1.5、query_string 查询
  1. /**
  2. * query_string 查询，可以同时实现多种查询
  3. */
  4. @Test
  5. public void searchQueryString() throws IOException {
  6.     //类似 match
  7.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  8.                     .index(INDEX_NAME)
  9.                     .query(queryBuilder -> queryBuilder
  10.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  11.                                     .defaultField("success").query("古典文学")))
  12.             , Poet.class);
  13.     log.info("response={}", response);
  15.     //类似 mulit_match
  16.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  17.                     .index(INDEX_NAME)
  18.                     .query(queryBuilder -> queryBuilder
  19.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  20.                                     .fields("about", "success").query("古典文学")))
  21.             , Poet.class);
  22.     log.info("response={}", response);
  24.     //类似 match_phrase
  25.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  26.                     .index(INDEX_NAME)
  27.                     .query(queryBuilder -> queryBuilder
  28.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  29.                                     .defaultField("success").query(""文学作家"")))
  30.             , Poet.class);
  31.     log.info(response.toString());
  33.     //带运算符查询，运算符两边的词不再分词
  34.     //查询同时包含 ”文学“ 和 ”伟大“ 的文档
  35.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  36.                     .index(INDEX_NAME)
  37.                     .query(queryBuilder -> queryBuilder
  38.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  39.                                     .fields("success").query("文学 AND 伟大")))
  40.             , Poet.class);
  41.     log.info("response={}", response);
  43.     //等同上一个查询
  44.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  45.                     .index(INDEX_NAME)
  46.                     .query(queryBuilder -> queryBuilder
  47.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  48.                                     .fields("success").query("文学 伟大").defaultOperator(Operator.And)))
  49.             , Poet.class);
  50.     log.info("response={}", response);
  52.     //查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
  53.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  54.                     .index(INDEX_NAME)
  55.                     .query(queryBuilder -> queryBuilder
  56.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  57.                                     .fields("name","success").query("(文学 AND 伟大) OR 高度")))
  58.             , Poet.class);
  59.     log.info("response={}", response);
  60. }
复制代码
1.2.1.6、simple_query_string 查询
  1. /**
  2. * simple_query_string 查询，类似 query_string，主要区别如下：
  3. * 1、不支持 AND OR NOT，会当做字符处理；使用 + 代替 AND，| 代替 OR，- 代替 NOT
  4. * 2、会忽略错误的语法
  5. */
  6. @Test
  7. public void searchSimpleQueryString() throws IOException {
  8.     //查询同时包含 ”文学“ 和 ”伟大“ 的文档
  9.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  10.                     .index(INDEX_NAME)
  11.                     .query(queryBuilder -> queryBuilder
  12.                             .simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
  13.                                     .fields("success").query("文学 + 伟大")))
  14.             , Poet.class);
  15.     log.info("response={}", response);
  16. }
复制代码
3.4.7、fuzzy 查询
  1. /**
  2. * 模糊查询
  3. */
  4. @Test
  5. public void searchFuzzy() throws IOException {
  6.     //全文查询时使用模糊参数，先分词再计算模糊选项。
  7.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  8.                     .index(INDEX_NAME)
  9.                     .query(queryBuilder -> queryBuilder
  10.                             .match(matchQueryBuilder -> matchQueryBuilder
  11.                                     .field("success").query("思考").fuzziness("1")))
  12.             , Poet.class);
  13.     log.info(response.toString());
  15.     //使用 fuzzy query，对输入不分词，直接计算模糊选项。
  16.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  17.                     .index(INDEX_NAME)
  18.                     .query(queryBuilder -> queryBuilder
  19.                             .fuzzy(fuzzyQueryBuilder ->  fuzzyQueryBuilder
  20.                                     .field("success").fuzziness("1").value("理想")))
  21.             , Poet.class);
  22.     log.info(response2.toString());
  23. }
复制代码
1.2.1.8、wildcard 查询
  1. /**
  2. * wildcard 查询，类似 SQL 语句中的 like；? 匹配一个字符，* 匹配多个字符
  3. */
  4. @Test
  5. public void searchWildcard() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.             .index(INDEX_NAME)
  8.             .query(queryBuilder -> queryBuilder.wildcard(wildcardQueryBuilder -> wildcardQueryBuilder
  9.                     .field("name")
  10.                     .wildcard("李*")))
  11.             , Poet.class);
  12.     log.info(response.toString());
  13. }
复制代码
1.2.1.9、bool 查询
  1. /**
  2. * bool 查询,组合查询
  3. */
  4. @Test
  5. public void searchBool() throws IOException {
  6.     //查询 success 包含 “思想” 且 age 在 [20-40] 之间的文档
  7.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  8.                     .index(INDEX_NAME)
  9.                     .query(queryBuilder -> queryBuilder
  10.                             .bool(boolQueryBuilder -> boolQueryBuilder
  11.                                     .must(queryBuilder2 -> queryBuilder2
  12.                                             .match(matchQueryBuilder -> matchQueryBuilder
  13.                                                     .field("success").query("思想"))
  14.                                     )
  15.                                     .must(queryBuilder2 -> queryBuilder2
  16.                                             .range(rangeQueryBuilder -> rangeQueryBuilder
  17.                                                     .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
  18.                                     )
  19.                             )
  20.                     )
  21.             , Poet.class);
  22.     log.info(response.toString());
  24.     //过滤出 success 包含 “思想” 且 age 在 [20-40] 之间的文档，不计算得分
  25.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  26.                     .index(INDEX_NAME)
  27.                     .query(queryBuilder -> queryBuilder
  28.                             .bool(boolQueryBuilder -> boolQueryBuilder
  29.                                     .filter(queryBuilder2 -> queryBuilder2
  30.                                             .match(matchQueryBuilder -> matchQueryBuilder
  31.                                                     .field("success").query("思想"))
  32.                                     )
  33.                                     .filter(queryBuilder2 -> queryBuilder2
  34.                                             .range(rangeQueryBuilder -> rangeQueryBuilder
  35.                                                     .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
  36.                                     )
  37.                             )
  38.                     )
  39.             , Poet.class);
  40.     log.info(response2.toString());
  41. }
复制代码
1.2.2、aggs 查询
  1. /**
  2. * aggs 查询,聚合查询
  3. */
  4. @Test
  5. public void searchAggs() throws IOException {
  6.     //求和，类似 select sum(age) from poet-index
  7.     SearchResponse response = client.search(searchRequestBuilder -> searchRequestBuilder
  8.                     .index(INDEX_NAME)
  9.                     .aggregations("age_sum", aggregationBuilder -> aggregationBuilder
  10.                             .sum(sumAggregationBuilder -> sumAggregationBuilder
  11.                                     .field("age")))
  12.             , Poet.class);
  13.     log.info(response.toString());
  15.     //类似 select count distinct(age) from poet-index
  16.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  17.                     .index(INDEX_NAME)
  18.                     .aggregations("age_count", aggregationBuilder -> aggregationBuilder
  19.                             .cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
  20.             , Poet.class);
  21.     log.info(response.toString());
  23.     //数量、最大、最小、平均、求和
  24.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  25.                     .index(INDEX_NAME)
  26.                     .aggregations("age_stats", aggregationBuilder -> aggregationBuilder
  27.                             .stats(statsAggregationBuilder -> statsAggregationBuilder
  28.                                     .field("age")))
  29.             , Poet.class);
  30.     log.info(response.toString());
  32.     //select name,count(*) from poet-index group by name
  33.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  34.                     .index(INDEX_NAME)
  35.                     .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
  36.                             .terms(termsAggregationBuilder -> termsAggregationBuilder
  37.                                     .field("name")))
  38.             , Map.class);
  39.     log.info(response.toString());
  41.     //select name,age,count(*) from poet-index group by name,age
  42.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  43.                     .index(INDEX_NAME)
  44.                     .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
  45.                             .terms(termsAggregationBuilder -> termsAggregationBuilder
  46.                                     .field("name")
  47.                             )
  48.                             .aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
  49.                                     .terms(termsAggregationBuilder -> termsAggregationBuilder
  50.                                             .field("age")
  51.                                     ))
  52.                     )
  53.             , Poet.class);
  54.     log.info(response.toString());
  56.     //类似 select avg(age) from poet-index where name='李白'
  57.     response = client.search(searchRequestBuilder -> searchRequestBuilder
  58.                     .index(INDEX_NAME)
  59.                     .query(queryBuilder -> queryBuilder
  60.                             .bool(boolQueryBuilder -> boolQueryBuilder
  61.                                     .filter(queryBuilder2 -> queryBuilder2
  62.                                             .term(termQueryBuilder -> termQueryBuilder
  63.                                                     .field("name").value("李白")))))
  64.                     .aggregations("ave_age", aggregationBuilder -> aggregationBuilder
  65.                             .avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
  66.             , Poet.class);
  67.     log.info(response.toString());
  68. }
复制代码
1.2.3、suggest 查询
  1. /**
  2. * suggest 查询，推荐查询
  3. */
  4. @Test
  5. public void searchSuggest() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .suggest(suggesterBuilder -> suggesterBuilder
  9.                             .suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
  10.                                     .text("思考")
  11.                                     .term(termSuggesterBuilder -> termSuggesterBuilder
  12.                                             .field("success")
  13.                                             .suggestMode(SuggestMode.Always)
  14.                                             .minWordLength(2)
  15.                                     )
  16.                             )
  17.                     )
  18.             , Poet.class);
  19.     log.info(response.toString());
  20. }
复制代码
1.2.4、highlight
  1. /**
  2. * 高亮显示
  3. */
  4. @Test
  5. public void searchHighlight() throws IOException {
  6.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  7.                     .index(INDEX_NAME)
  8.                     .query(queryBuilder -> queryBuilder
  9.                             .match(matchQueryBuilder -> matchQueryBuilder
  10.                                     .field("success").query("思想")))
  11.                     .highlight(highlightBuilder -> highlightBuilder
  12.                             .preTags("<span color='red'>")
  13.                             .postTags("</span>")
  14.                             .fields("success", highlightFieldBuilder -> highlightFieldBuilder))
  15.             , Poet.class);
  16.     log.info(response.toString());
  17. }
复制代码
2、完整代码

  1. package com.abc.demo.es;
  3. import co.elastic.clients.elasticsearch.ElasticsearchClient;
  4. import co.elastic.clients.elasticsearch._types.FieldValue;
  5. import co.elastic.clients.elasticsearch._types.SortOrder;
  6. import co.elastic.clients.elasticsearch._types.SuggestMode;
  7. import co.elastic.clients.elasticsearch._types.query_dsl.Operator;
  8. import co.elastic.clients.elasticsearch.core.*;
  9. import co.elastic.clients.json.JsonData;
  10. import co.elastic.clients.json.jackson.JacksonJsonpMapper;
  11. import co.elastic.clients.transport.ElasticsearchTransport;
  12. import co.elastic.clients.transport.rest_client.RestClientTransport;
  13. import com.fasterxml.jackson.databind.ObjectMapper;
  14. import lombok.AllArgsConstructor;
  15. import lombok.Data;
  16. import lombok.NoArgsConstructor;
  17. import lombok.extern.slf4j.Slf4j;
  18. import org.apache.http.HttpHost;
  19. import org.elasticsearch.client.RestClient;
  20. import org.junit.After;
  21. import org.junit.Before;
  22. import org.junit.Test;
  24. import java.io.IOException;
  25. import java.util.ArrayList;
  26. import java.util.List;
  27. import java.util.Map;
  29. @Slf4j
  30. public class ElasticsearchJavaCase2 {
  31.     private static final String INDEX_NAME = "poet-index";
  33.     private ElasticsearchTransport transport;
  34.     private ElasticsearchClient client;
  36.     @Before
  37.     public void before() {
  38.         RestClient restClient = RestClient.builder(
  39.                 new HttpHost("10.49.196.10", 9200),
  40.                 new HttpHost("10.49.196.11", 9200),
  41.                 new HttpHost("10.49.196.12", 9200)).build();
  42.         ObjectMapper objectMapper = new ObjectMapper();
  43.         transport = new RestClientTransport(restClient, new JacksonJsonpMapper(objectMapper));
  44.         client = new ElasticsearchClient(transport);
  45.     }
  47.     @After
  48.     public void after() throws IOException {
  49.         transport.close();
  50.     }
  52.     /**
  53.      * 查询文档数量
  54.      */
  55.     @Test
  56.     public void count() throws IOException {
  57.         //查询该索引的所有文档数量
  58.         CountResponse response = client.count(builder -> builder.index(INDEX_NAME));
  59.         log.info("response={}", response);
  61.         //通过 Lucene 查询语法指定条件；8.13.4会报错”contains unrecognized parameter: [q]“，因为 API 提交了请求 "{}"，应该时不需要请求体
  62.         //response = client.count(builder -> builder.index(INDEX_NAME).q("name:杜甫"));
  63.         log.info("response={}", response);
  65.         //通过 "Query DSL" 指定条件
  66.         response = client.count(builder -> builder
  67.                 .index(INDEX_NAME)
  68.                 .query(queryBuilder -> queryBuilder
  69.                         .term(termQueryBuilder -> termQueryBuilder
  70.                                 .field("name").value("杜甫")
  71.                         )
  72.                 )
  73.         );
  74.         log.info("response={}", response);
  75.     }
  77.     /**
  78.      * term/terms查询,对输入内容不做分词处理
  79.      */
  80.     @Test
  81.     public void searchTerm() throws IOException {
  82.         SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
  83.                         .index(INDEX_NAME)
  84.                         .query(queryBuilder -> queryBuilder
  85.                                 .term(termQueryBuilder -> termQueryBuilder
  86.                                         .field("name").value("李白")))
  87.                         .sort(sortOptionsBuilder -> sortOptionsBuilder
  88.                                 .field(fieldSortBuilder -> fieldSortBuilder
  89.                                         .field("age").order(SortOrder.Asc)))
  90.                         .source(sourceConfigBuilder -> sourceConfigBuilder
  91.                                 .filter(sourceFilterBuilder -> sourceFilterBuilder
  92.                                         .includes("age", "name")))
  93.                         .from(0)
  94.                         .size(10)
  95.                 , Map.class);
  96.         log.info("response={}", response);
  98.         List<FieldValue> words = new ArrayList<>();
  99.         words.add(new FieldValue.Builder().stringValue("李白").build());
  100.         words.add(new FieldValue.Builder().stringValue("杜甫").build());
  101.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  102.                         .index(INDEX_NAME)
  103.                         .query(queryBuilder -> queryBuilder
  104.                                 .terms(termsQueryBuilder -> termsQueryBuilder
  105.                                         .field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
  106.                         .source(sourceConfigBuilder -> sourceConfigBuilder
  107.                                 .filter(sourceFilterBuilder -> sourceFilterBuilder
  108.                                         .excludes("about")))
  109.                         .from(0)
  110.                         .size(10)
  111.                 , Poet.class);
  112.         log.info("response2={}", response2);
  113.     }
  115.     /**
  116.      * range(范围)查询
  117.      */
  118.     @Test
  119.     public void searchRange() throws IOException {
  120.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  121.                         .index(INDEX_NAME)
  122.                         .query(queryBuilder -> queryBuilder
  123.                                 .range(rangeQueryBuilder -> rangeQueryBuilder
  124.                                         .field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
  125.                 , Poet.class);
  126.         log.info("response={}", response);
  127.     }
  129.     /**
  130.      * exists 查询，查询对应字段不为空的数据
  131.      */
  132.     @Test
  133.     public void exists() throws IOException {
  134.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  135.                         .index(INDEX_NAME).query(builder -> builder.exists(builder1 -> builder1.field("poems")))
  136.                 , Poet.class);
  137.         log.info("response={}", response);
  138.     }
  140.     /**
  141.      * match查询，对输入内容先分词再查询
  142.      */
  143.     @Test
  144.     public void searchMatch() throws IOException {
  145.         SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
  146.                         .index(INDEX_NAME)
  147.                         .query(queryBuilder -> queryBuilder
  148.                                 .match(matchQueryBuilder -> matchQueryBuilder
  149.                                         .field("success").query("思想")))
  150.                 , Map.class);
  151.         log.info("response={}", response);
  152.     }
  154.     /**
  155.      * multi_match 查询，多个字段进行匹配。
  156.      */
  157.     @Test
  158.     public void searchMultiMatch() throws IOException {
  159.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  160.                         .index(INDEX_NAME)
  161.                         .query(queryBuilder -> queryBuilder
  162.                                 .multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
  163.                                         .fields("about", "success").query("思想")))
  164.                 , Poet.class);
  165.         log.info("response={}", response);
  166.     }
  168.     /**
  169.      * match_phrase 查询,类似 match，先把查询字符串分词生成一个词列表，查询包含所有这些词且这些词在文档中出现次序一致的数据。
  170.      */
  171.     @Test
  172.     public void searchMatchPhrase() throws IOException {
  173.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  174.                         .index(INDEX_NAME)
  175.                         .query(queryBuilder -> queryBuilder
  176.                                 .matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder
  177.                                         .field("success").query("伟大作家")))
  178.                 , Poet.class);
  179.         log.info("response={}", response);
  180.     }
  182.     /**
  183.      * match_all 查询，查询所有文档
  184.      */
  185.     @Test
  186.     public void searchMatchAll() throws IOException {
  187.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  188.                         .index(INDEX_NAME)
  189.                         .query(queryBuilder -> queryBuilder
  190.                                 .matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
  191.                 , Poet.class);
  192.         log.info("response={}", response);
  194.         //不加请求体，也是一样的效果，查询所有文档。
  195.         response = client.search(searchRequestBuilder -> searchRequestBuilder.index(INDEX_NAME), Poet.class);
  196.         log.info("response={}", response);
  197.     }
  199.     /**
  200.      * match_none 查询，与 match_all 相反，返回 0 个文档。
  201.      */
  202.     @Test
  203.     public void searchMatchNone() throws IOException {
  204.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  205.                         .index(INDEX_NAME)
  206.                         .query(queryBuilder -> queryBuilder
  207.                                 .matchNone(matchAllQueryBuilder -> matchAllQueryBuilder))
  208.                 , Poet.class);
  209.         log.info("response={}", response);
  210.     }
  212.     /**
  213.      * query_string 查询，可以同时实现多种查询
  214.      */
  215.     @Test
  216.     public void searchQueryString() throws IOException {
  217.         //类似 match
  218.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  219.                         .index(INDEX_NAME)
  220.                         .query(queryBuilder -> queryBuilder
  221.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  222.                                         .defaultField("success").query("古典文学")))
  223.                 , Poet.class);
  224.         log.info("response={}", response);
  226.         //类似 mulit_match
  227.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  228.                         .index(INDEX_NAME)
  229.                         .query(queryBuilder -> queryBuilder
  230.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  231.                                         .fields("about", "success").query("古典文学")))
  232.                 , Poet.class);
  233.         log.info("response={}", response);
  235.         //类似 match_phrase
  236.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  237.                         .index(INDEX_NAME)
  238.                         .query(queryBuilder -> queryBuilder
  239.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  240.                                         .defaultField("success").query(""文学作家"")))
  241.                 , Poet.class);
  242.         log.info(response.toString());
  244.         //带运算符查询，运算符两边的词不再分词
  245.         //查询同时包含 ”文学“ 和 ”伟大“ 的文档
  246.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  247.                         .index(INDEX_NAME)
  248.                         .query(queryBuilder -> queryBuilder
  249.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  250.                                         .fields("success").query("文学 AND 伟大")))
  251.                 , Poet.class);
  252.         log.info("response={}", response);
  254.         //等同上一个查询
  255.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  256.                         .index(INDEX_NAME)
  257.                         .query(queryBuilder -> queryBuilder
  258.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  259.                                         .fields("success").query("文学 伟大").defaultOperator(Operator.And)))
  260.                 , Poet.class);
  261.         log.info("response={}", response);
  263.         //查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
  264.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  265.                         .index(INDEX_NAME)
  266.                         .query(queryBuilder -> queryBuilder
  267.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
  268.                                         .fields("name","success").query("(文学 AND 伟大) OR 高度")))
  269.                 , Poet.class);
  270.         log.info("response={}", response);
  271.     }
  273.     /**
  274.      * simple_query_string 查询,类似 query_string，主要区别如下：
  275.      * 1、不支持 AND OR NOT，会当做字符处理；使用 + 代替 AND，| 代替 OR，- 代替 NOT
  276.      * 2、会忽略错误的语法
  277.      */
  278.     @Test
  279.     public void searchSimpleQueryString() throws IOException {
  280.         //查询同时包含 ”文学“ 和 ”伟大“ 的文档
  281.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  282.                         .index(INDEX_NAME)
  283.                         .query(queryBuilder -> queryBuilder
  284.                                 .simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
  285.                                         .fields("success").query("文学 + 伟大")))
  286.                 , Poet.class);
  287.         log.info("response={}", response);
  288.     }
  290.     /**
  291.      * 模糊查询
  292.      */
  293.     @Test
  294.     public void searchFuzzy() throws IOException {
  295.         //全文查询时使用模糊参数，先分词再计算模糊选项。
  296.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  297.                         .index(INDEX_NAME)
  298.                         .query(queryBuilder -> queryBuilder
  299.                                 .match(matchQueryBuilder -> matchQueryBuilder
  300.                                         .field("success").query("思考").fuzziness("1")))
  301.                 , Poet.class);
  302.         log.info(response.toString());
  304.         //使用 fuzzy query，对输入不分词，直接计算模糊选项。
  305.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  306.                         .index(INDEX_NAME)
  307.                         .query(queryBuilder -> queryBuilder
  308.                                 .fuzzy(fuzzyQueryBuilder ->  fuzzyQueryBuilder
  309.                                         .field("success").fuzziness("1").value("理想")))
  310.                 , Poet.class);
  311.         log.info(response2.toString());
  312.     }
  314.     /**
  315.      * wildcard 查询，类似 SQL 语句中的 like；? 匹配一个字符，* 匹配多个字符
  316.      */
  317.     @Test
  318.     public void searchWildcard() throws IOException {
  319.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  320.                 .index(INDEX_NAME)
  321.                 .query(queryBuilder -> queryBuilder.wildcard(wildcardQueryBuilder -> wildcardQueryBuilder
  322.                         .field("name")
  323.                         .wildcard("李*")))
  324.                 , Poet.class);
  325.         log.info(response.toString());
  326.     }
  328.     /**
  329.      * bool 查询,组合查询
  330.      */
  331.     @Test
  332.     public void searchBool() throws IOException {
  333.         //查询 success 包含 “思想” 且 age 在 [20-40] 之间的文档
  334.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  335.                         .index(INDEX_NAME)
  336.                         .query(queryBuilder -> queryBuilder
  337.                                 .bool(boolQueryBuilder -> boolQueryBuilder
  338.                                         .must(queryBuilder2 -> queryBuilder2
  339.                                                 .match(matchQueryBuilder -> matchQueryBuilder
  340.                                                         .field("success").query("思想"))
  341.                                         )
  342.                                         .must(queryBuilder2 -> queryBuilder2
  343.                                                 .range(rangeQueryBuilder -> rangeQueryBuilder
  344.                                                         .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
  345.                                         )
  346.                                 )
  347.                         )
  348.                 , Poet.class);
  349.         log.info(response.toString());
  351.         //过滤出 success 包含 “思想” 且 age 在 [20-40] 之间的文档，不计算得分
  352.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
  353.                         .index(INDEX_NAME)
  354.                         .query(queryBuilder -> queryBuilder
  355.                                 .bool(boolQueryBuilder -> boolQueryBuilder
  356.                                         .filter(queryBuilder2 -> queryBuilder2
  357.                                                 .match(matchQueryBuilder -> matchQueryBuilder
  358.                                                         .field("success").query("思想"))
  359.                                         )
  360.                                         .filter(queryBuilder2 -> queryBuilder2
  361.                                                 .range(rangeQueryBuilder -> rangeQueryBuilder
  362.                                                         .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
  363.                                         )
  364.                                 )
  365.                         )
  366.                 , Poet.class);
  367.         log.info(response2.toString());
  368.     }
  370.     /**
  371.      * aggs 查询，聚合查询
  372.      */
  373.     @Test
  374.     public void searchAggs() throws IOException {
  375.         //求和，类似 select sum(age) from poet-index
  376.         SearchResponse response = client.search(searchRequestBuilder -> searchRequestBuilder
  377.                         .index(INDEX_NAME)
  378.                         .aggregations("age_sum", aggregationBuilder -> aggregationBuilder
  379.                                 .sum(sumAggregationBuilder -> sumAggregationBuilder
  380.                                         .field("age")))
  381.                 , Poet.class);
  382.         log.info(response.toString());
  384.         //类似 select count distinct(age) from poet-index
  385.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  386.                         .index(INDEX_NAME)
  387.                         .aggregations("age_count", aggregationBuilder -> aggregationBuilder
  388.                                 .cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
  389.                 , Poet.class);
  390.         log.info(response.toString());
  392.         //数量、最大、最小、平均、求和
  393.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  394.                         .index(INDEX_NAME)
  395.                         .aggregations("age_stats", aggregationBuilder -> aggregationBuilder
  396.                                 .stats(statsAggregationBuilder -> statsAggregationBuilder
  397.                                         .field("age")))
  398.                 , Poet.class);
  399.         log.info(response.toString());
  401.         //select name,count(*) from poet-index group by name
  402.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  403.                         .index(INDEX_NAME)
  404.                         .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
  405.                                 .terms(termsAggregationBuilder -> termsAggregationBuilder
  406.                                         .field("name")))
  407.                 , Map.class);
  408.         log.info(response.toString());
  410.         //select name,age,count(*) from poet-index group by name,age
  411.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  412.                         .index(INDEX_NAME)
  413.                         .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
  414.                                 .terms(termsAggregationBuilder -> termsAggregationBuilder
  415.                                         .field("name")
  416.                                 )
  417.                                 .aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
  418.                                         .terms(termsAggregationBuilder -> termsAggregationBuilder
  419.                                                 .field("age")
  420.                                         ))
  421.                         )
  422.                 , Poet.class);
  423.         log.info(response.toString());
  425.         //类似 select avg(age) from poet-index where name='李白'
  426.         response = client.search(searchRequestBuilder -> searchRequestBuilder
  427.                         .index(INDEX_NAME)
  428.                         .query(queryBuilder -> queryBuilder
  429.                                 .bool(boolQueryBuilder -> boolQueryBuilder
  430.                                         .filter(queryBuilder2 -> queryBuilder2
  431.                                                 .term(termQueryBuilder -> termQueryBuilder
  432.                                                         .field("name").value("李白")))))
  433.                         .aggregations("ave_age", aggregationBuilder -> aggregationBuilder
  434.                                 .avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
  435.                 , Poet.class);
  436.         log.info(response.toString());
  437.     }
  439.     /**
  440.      * suggest 查询，推荐搜索
  441.      */
  442.     @Test
  443.     public void searchSuggest() throws IOException {
  444.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  445.                         .index(INDEX_NAME)
  446.                         .suggest(suggesterBuilder -> suggesterBuilder
  447.                                 .suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
  448.                                         .text("思考")
  449.                                         .term(termSuggesterBuilder -> termSuggesterBuilder
  450.                                                 .field("success")
  451.                                                 .suggestMode(SuggestMode.Always)
  452.                                                 .minWordLength(2)
  453.                                         )
  454.                                 )
  455.                         )
  456.                 , Poet.class);
  457.         log.info(response.toString());
  458.     }
  460.     /**
  461.      * 高亮显示
  462.      */
  463.     @Test
  464.     public void searchHighlight() throws IOException {
  465.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
  466.                         .index(INDEX_NAME)
  467.                         .query(queryBuilder -> queryBuilder
  468.                                 .match(matchQueryBuilder -> matchQueryBuilder
  469.                                         .field("success").query("思想艺术")))
  470.                         .highlight(highlightBuilder -> highlightBuilder
  471.                                 .preTags("<span color='red'>")
  472.                                 .postTags("</span>")
  473.                                 .fields("success", highlightFieldBuilder -> highlightFieldBuilder))
  474.                 , Poet.class);
  475.         log.info(response.toString());
  476.     }
  478.     @Data
  479.     @AllArgsConstructor
  480.     @NoArgsConstructor
  481.     static class Poet {
  482.         private Integer age;
  483.         private String name;
  484.         private String poems;
  485.         private String about;
  486.         /**成就*/
  487.         private String success;
  488.     }
  489. }
复制代码
ElasticsearchJavaCase2.java 
 
具体的 Elasticsearch Java API Client 使用说明，请参考官网文档：https://www.elastic.co/guide/en/elasticsearch/client/java-api-client/current/index.html。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

正序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

民工心事

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表