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

本文主要介绍 Elasticsearch Java API Client 的使用，相关的环境及软件信息如下：CentOS 7.6.1810、Java 1.8.0_321(客户端用)、Elasticsearch 8.2.2。
1、Java API Client 的特点

• Strongly typed requests and responses for all Elasticsearch APIs.
  
• Blocking and asynchronous versions of all APIs.
  
• Use of fluent builders and functional patterns to allow writing concise yet readable code when creating complex nested structures.
  
• Seamless integration of application classes by using an object mapper such as Jackson or any JSON-B implementation.
  
• Delegates protocol handling to an http client such as the Java Low Level REST Client that takes care of all transport-level concerns: HTTP connection pooling, retries, node discovery, and so on.
  

2、引入依赖

1. <dependency>
2.     <groupId>co.elastic.clients</groupId>
3.     <artifactId>elasticsearch-java</artifactId>
4.     <version>8.2.2</version>
5. </dependency>

复制代码

3、使用

Elasticsearch Java API Client 通过 API 的方式来组装请求数据，避免直接编写 JSON 字符串；请求数据的详细说明可参考：Elasticsearch 入门实战(3)--REST API 使用。
3.1、连接及关闭

Java API Client 底层依赖 Java Low Level REST Client，需先创建 Low Level REST Client。

1. private ElasticsearchTransport transport;
2. private ElasticsearchClient client;
4. @Before
5. public void before() {
6.     RestClient restClient = RestClient.builder(
7.             new HttpHost("10.49.196.10", 9200),
8.             new HttpHost("10.49.196.11", 9200),
9.             new HttpHost("10.49.196.12", 9200)).build();
10.     ObjectMapper objectMapper = new ObjectMapper();
11.     transport = new RestClientTransport(restClient, new JacksonJsonpMapper(objectMapper));
12.     client = new ElasticsearchClient(transport);
13. }
15. @After
16. public void after() throws IOException {
17.     client.shutdown();
18. }

复制代码

3.2、索引

3.2.1、创建索引

1. @Test
2. public void createIndex() throws IOException {
3.     CreateIndexResponse response = client.indices().create(builder -> builder
4.             .settings(indexSettingsBuilder -> indexSettingsBuilder.numberOfReplicas("1").numberOfShards("2"))
5.             .mappings(typeMappingBuilder -> typeMappingBuilder
6.                     .properties("age", propertyBuilder -> propertyBuilder.integer(integerNumberPropertyBuilder -> integerNumberPropertyBuilder))
7.                     .properties("name", propertyBuilder -> propertyBuilder.keyword(keywordPropertyBuilder -> keywordPropertyBuilder))
8.                     .properties("poems", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
9.                     .properties("about", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
10.                     .properties("success", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
11.             )
12.             .index(INDEX_NAME));
13.     logger.info("acknowledged={}", response.acknowledged());
14. }

复制代码

3.2.2、修改 _mapping 信息

字段可以新增，已有的字段只能修改字段的 search_analyzer 属性。

1. @Test
2. public void modifyIndex() throws IOException {
3.     PutMappingResponse response = client.indices().putMapping(typeMappingBuilder -> typeMappingBuilder
4.             .index(INDEX_NAME)
5.             .properties("age", propertyBuilder -> propertyBuilder.integer(integerNumberPropertyBuilder -> integerNumberPropertyBuilder))
6.             .properties("name", propertyBuilder -> propertyBuilder.keyword(keywordPropertyBuilder -> keywordPropertyBuilder))
7.             .properties("poems", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_smart")))
8.     );
9.     logger.info("acknowledged={}", response.acknowledged());
10. }

复制代码

3.2.3、删除索引

1. @Test
2. public void deleteIndex() throws IOException {
3.     DeleteIndexResponse response = client.indices().delete(builder -> builder.index(INDEX_NAME));
4.     logger.info("acknowledged={}", response.acknowledged());
5. }

复制代码

3.2.4、查询索引列表

1. @Test
2. public void getIndex() throws IOException {
3.     //使用 * 也可以
4.     GetIndexResponse response = client.indices().get(builder -> builder.index("_all"));
5.     logger.info(response.result().toString());
6. }

复制代码

3.2.5、查询索引详情

1. @Test
2. public void getIndexDetail() throws IOException {
3.     GetIndexResponse response = client.indices().get(builder -> builder.index(INDEX_NAME));
4.     logger.info(response.result().toString());
5. }

复制代码

3.3、文档

3.3.1、创建文档

1. @Test
2. public void createDoc() throws IOException {
3.     Map<String, Object> doc = new HashMap<>();
4.     doc.put("age", 30);
5.     doc.put("name", "李白");
6.     doc.put("poems", "静夜思");
7.     doc.put("about", "字太白");
8.     doc.put("success", "创造了古代浪漫主义文学高峰、歌行体和七绝达到后人难及的高度");
10.     CreateResponse response = client.create(builder -> builder.index(INDEX_NAME).id("1").document(doc));
11.     logger.info(response.toString());
13.     Poet poet = new Poet(31, "杜甫", "登高", "字子美", "唐代伟大的现实主义文学作家，唐诗思想艺术的集大成者");
14.     response = client.create(builder -> builder.index(INDEX_NAME).id("2").document(poet));
15.     logger.info(response.toString());
16. }

复制代码

3.3.2、删除文档

1. @Test
2. public void deleteDoc() throws IOException {
3.     DeleteResponse response = client.delete(builder -> builder.index(INDEX_NAME).id("1"));
4.     logger.info(response.toString());
5. }

复制代码

3.3.3、修改文档

修改文档，只修改设置的字段。

1. @Test
2. public void updateDoc() throws IOException {
3.     Map<String, Object> doc = new HashMap<>();
4.     doc.put("age", 33);
5.     doc.put("name", "李白2");
7.     UpdateResponse response = client.update(builder -> builder.index(INDEX_NAME).id("1").doc(doc), Map.class);
8.     logger.info(response.toString());
10.     Poet poet = new Poet();
11.     poet.setAge(40);
12.     poet.setName("杜甫2");
13.     response = client.update(builder -> builder.index(INDEX_NAME).id("2").doc(poet).docAsUpsert(true), Poet.class);
14.     logger.info(response.toString());
15. }

复制代码

3.3.4、新增或修改文档

新增或修改文档，修改时所有的字段都会覆盖(相当于先删除在新增)。

1. @Test
2. public void createOrUpdateDoc() throws IOException {
3.     Map<String, Object> doc = new HashMap<>();
4.     doc.put("age", 33);
5.     doc.put("name", "李白2");
7.     //只更新设置的字段
8.     IndexResponse response = client.index(builder -> builder.index(INDEX_NAME).id("1").document(doc));
9.     logger.info(response.toString());
11.     Poet poet = new Poet();
12.     poet.setAge(40);
13.     poet.setName("杜甫2");
14.     response = client.index(builder -> builder.index(INDEX_NAME).id("2").document(poet));
15.     logger.info(response.toString());
16. }

复制代码

3.3.5、批量操作

1. @Test
2. public void bulk() throws IOException {
3.     List<BulkOperation> list = new ArrayList<>();
5.     //批量新增
6.     for (int i = 0; i < 5; i++) {
7.         Map<String, Object> doc = new HashMap<>();
8.         doc.put("age", 30);
9.         doc.put("name", "李白" + i);
10.         doc.put("poems", "静夜思");
11.         doc.put("about", "字太白");
12.         doc.put("success", "创造了古代浪漫主义文学高峰、歌行体和七绝达到后人难及的高度");
13.         String id = 10 + i + "";
14.         list.add(new BulkOperation.Builder().create(builder -> builder.index(INDEX_NAME).id(id).document(doc)).build());
15.     }
16.     for (int i = 0; i < 5; i++) {
17.         Poet poet = new Poet(31, "杜甫" + i, "登高", "字子美", "唐代伟大的现实主义文学作家，唐诗思想艺术的集大成者");
18.         String id = 20 + i + "";
19.         list.add(new BulkOperation.Builder().create(builder -> builder.index(INDEX_NAME).id(id).document(poet)).build());
20.     }
22.     //批量删除
23.     list.add(new BulkOperation.Builder().delete(builder -> builder.index(INDEX_NAME).id("1")).build());
24.     list.add(new BulkOperation.Builder().delete(builder -> builder.index(INDEX_NAME).id("2")).build());
26.     BulkResponse response = client.bulk(builder -> builder.index(INDEX_NAME).operations(list));
27.     logger.info(response.toString());
28. }

复制代码

3.4、查询

3.4.1、查询所有文档

1. @Test
2. public void getDocAll() throws IOException {
3.     SearchResponse<Map> response = client.search(builder -> builder.index(INDEX_NAME), Map.class);
4.     logger.info(response.toString());
5. }

复制代码

3.4.2、查询单个文档

1. @Test
2. public void getDoc() throws IOException {
3.     GetResponse<Map> response = client.get(builder -> builder.index(INDEX_NAME).id("1"), Map.class);
4.     if (response.found()) {
5.         logger.info(response.source().toString());
6.     }
8.     GetResponse<Poet> response2 = client.get(builder -> builder.index(INDEX_NAME).id("2"), Poet.class);
9.     if (response2.found()) {
10.         logger.info(response2.source().toString());
11.     }
12. }

复制代码

3.4.3、term/terms 查询

term/terms查询，对输入内容不做分词处理。

1. @Test
2. public void searchTerm() throws IOException {
3.     SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.             .index(INDEX_NAME)
5.             .query(queryBuilder -> queryBuilder
6.                     .term(termQueryBuilder -> termQueryBuilder
7.                             .field("name").value("李白")))
8.             .sort(sortOptionsBuilder -> sortOptionsBuilder
9.                     .field(fieldSortBuilder -> fieldSortBuilder
10.                             .field("name").order(SortOrder.Asc)))
11.             .source(sourceConfigBuilder -> sourceConfigBuilder
12.                     .filter(sourceFilterBuilder -> sourceFilterBuilder
13.                             .includes("age", "name")))
14.             .from(0)
15.             .size(10)
16.             , Map.class);
17.     logger.info(response.toString());
19.     List<FieldValue> words = new ArrayList<>();
20.     words.add(new FieldValue.Builder().stringValue("李白").build());
21.     words.add(new FieldValue.Builder().stringValue("杜甫").build());
22.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
23.                     .index(INDEX_NAME)
24.                     .query(queryBuilder -> queryBuilder
25.                             .terms(termsQueryBuilder -> termsQueryBuilder
26.                                     .field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
27.                     .source(sourceConfigBuilder -> sourceConfigBuilder
28.                             .filter(sourceFilterBuilder -> sourceFilterBuilder
29.                                     .excludes("about")))
30.                     .from(0)
31.                     .size(10)
32.             , Poet.class);
33.     logger.info(response2.toString());
34. }

复制代码

3.4.4、range(范围) 查询

1. @Test
2. public void searchRange() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .query(queryBuilder -> queryBuilder
6.                             .range(rangeQueryBuilder -> rangeQueryBuilder
7.                                     .field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
8.             , Poet.class);
9.     logger.info(response.toString());
10. }

复制代码

3.4.5、全文查询

3.4.5.1、match 查询

match 查询，对输入内容先分词再查询。

1. @Test
2. public void searchMatch() throws IOException {
3.     SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .query(queryBuilder -> queryBuilder
6.                             .match(matchQueryBuilder -> matchQueryBuilder
7.                                     .field("success").query("思想")))
8.             , Map.class);
9.     logger.info(response.toString());
10. }

复制代码

3.4.5.2、multi_match 查询

多个字段进行匹配。

1. @Test
2. public void searchMultiMatch() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .query(queryBuilder -> queryBuilder
6.                             .multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
7.                                     .fields("about", "success").query("思想")))
8.             , Poet.class);
9.     logger.info(response.toString());
10. }

复制代码

3.4.5.3、match_phrase 查询

匹配整个查询字符串。

1. @Test
2. public void searchMatchPhrase() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .query(queryBuilder -> queryBuilder
6.                             .matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder.field("success").query("文学作家")))
7.             , Poet.class);
8.     logger.info(response.toString());
9. }

复制代码

3.4.5.4、match_all 查询

查询所有文档。

1. @Test
2. public void searchMatchAll() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .query(queryBuilder -> queryBuilder
6.                             .matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
7.             , Poet.class);
8.     logger.info(response.toString());
9. }

复制代码

3.4.5.5、query_string 查询

query_string 可以同时实现前面几种查询方法。

1. @Test
2. public void searchQueryString() throws IOException {
3.     //类似 match
4.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
5.                     .index(INDEX_NAME)
6.                     .query(queryBuilder -> queryBuilder
7.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
8.                                 .defaultField("success").query("古典文学")))
9.             , Poet.class);
10.     logger.info(response.toString());
12.     //类似 mulit_match
13.     response = client.search(searchRequestBuilder -> searchRequestBuilder
14.                     .index(INDEX_NAME)
15.                     .query(queryBuilder -> queryBuilder
16.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
17.                                     .fields("about", "success").query("古典文学")))
18.             , Poet.class);
19.     logger.info(response.toString());
21.     //类似 match_phrase
22.     response = client.search(searchRequestBuilder -> searchRequestBuilder
23.                     .index(INDEX_NAME)
24.                     .query(queryBuilder -> queryBuilder
25.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
26.                                     .defaultField("success").query(""文学作家"")))
27.             , Poet.class);
28.     logger.info(response.toString());
30.     //带运算符查询，运算符两边的词不再分词
31.     //查询同时包含 ”文学“ 和 ”伟大“ 的文档
32.     response = client.search(searchRequestBuilder -> searchRequestBuilder
33.                     .index(INDEX_NAME)
34.                     .query(queryBuilder -> queryBuilder
35.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
36.                                     .fields("success").query("文学 AND 伟大")))
37.             , Poet.class);
38.     logger.info(response.toString());
40.     //等同上一个查询
41.     response = client.search(searchRequestBuilder -> searchRequestBuilder
42.                     .index(INDEX_NAME)
43.                     .query(queryBuilder -> queryBuilder
44.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
45.                                     .fields("success").query("文学 伟大").defaultOperator(Operator.And)))
46.             , Poet.class);
47.     logger.info(response.toString());
49.     //查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
50.     response = client.search(searchRequestBuilder -> searchRequestBuilder
51.                     .index(INDEX_NAME)
52.                     .query(queryBuilder -> queryBuilder
53.                             .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
54.                                     .fields("name","success").query("(文学 AND 伟大) OR 高度")))
55.             , Poet.class);
56.     logger.info(response.toString());
57. }

复制代码

3.4.5.6、simple_query_string 查询

类似 query_string，主要区别如下：
1、不支持AND OR NOT ，会当做字符处理；使用 + 代替 AND，| 代替OR，- 代替 NOT
2、会忽略错误的语法

1. @Test
2. public void searchSimpleQueryString() throws IOException {
3.     //查询同时包含 ”文学“ 和 ”伟大“ 的文档
4.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
5.                     .index(INDEX_NAME)
6.                     .query(queryBuilder -> queryBuilder
7.                             .simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
8.                                     .fields("success").query("文学 + 伟大")))
9.             , Poet.class);
10.     logger.info(response.toString());
11. }

复制代码

3.4.6、模糊查询

1. @Test
2. public void searchFuzzy() throws IOException {
3.     //全文查询时使用模糊参数，先分词再计算模糊选项。
4.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
5.                     .index(INDEX_NAME)
6.                     .query(queryBuilder -> queryBuilder
7.                             .match(matchQueryBuilder -> matchQueryBuilder
8.                                     .field("success").query("思考").fuzziness("1")))
9.             , Poet.class);
10.     logger.info(response.toString());
12.     //使用 fuzzy query，对输入不分词，直接计算模糊选项。
13.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
14.                     .index(INDEX_NAME)
15.                     .query(queryBuilder -> queryBuilder
16.                             .fuzzy(fuzzyQueryBuilder ->  fuzzyQueryBuilder
17.                                     .field("success").fuzziness("1").value("理想")))
18.             , Poet.class);
19.     logger.info(response2.toString());
20. }

复制代码

3.4.7、组合查询

1. @Test
2. public void searchBool() throws IOException {
3.     //查询 success 包含 “思想” 且 age 在 [20-40] 之间的文档
4.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
5.             .index(INDEX_NAME)
6.             .query(queryBuilder -> queryBuilder
7.                     .bool(boolQueryBuilder -> boolQueryBuilder
8.                             .must(queryBuilder2 -> queryBuilder2
9.                                     .match(matchQueryBuilder -> matchQueryBuilder
10.                                             .field("success").query("思想"))
11.                             )
12.                             .must(queryBuilder2 -> queryBuilder2
13.                                     .range(rangeQueryBuilder -> rangeQueryBuilder
14.                                             .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
15.                             )
16.                     )
17.             )
18.     , Poet.class);
19.     logger.info(response.toString());
21.     //过滤出 success 包含 “思想” 且 age 在 [20-40] 之间的文档，不计算得分
22.     SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
23.             .index(INDEX_NAME)
24.             .query(queryBuilder -> queryBuilder
25.                     .bool(boolQueryBuilder -> boolQueryBuilder
26.                             .filter(queryBuilder2 -> queryBuilder2
27.                                     .match(matchQueryBuilder -> matchQueryBuilder
28.                                             .field("success").query("思想"))
29.                             )
30.                             .filter(queryBuilder2 -> queryBuilder2
31.                                     .range(rangeQueryBuilder -> rangeQueryBuilder
32.                                             .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
33.                             )
34.                     )
35.             )
36.     , Poet.class);
37.     logger.info(response2.toString());
38. }

复制代码

3.4.8、聚合查询

1. @Test
2. public void searchAggs() throws IOException {
3.     //求和
4.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
5.                     .index(INDEX_NAME)
6.                     .aggregations("age_sum", aggregationBuilder -> aggregationBuilder
7.                             .sum(sumAggregationBuilder -> sumAggregationBuilder
8.                                     .field("age")))
9.             , Poet.class);
10.     logger.info(response.toString());
12.     //类似 select count distinct(age) from poet-index
13.     response = client.search(searchRequestBuilder -> searchRequestBuilder
14.                     .index(INDEX_NAME)
15.                     .aggregations("age_count", aggregationBuilder -> aggregationBuilder
16.                             .cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
17.             , Poet.class);
18.     logger.info(response.toString());
20.     //数量、最大、最小、平均、求和
21.     response = client.search(searchRequestBuilder -> searchRequestBuilder
22.                     .index(INDEX_NAME)
23.                     .aggregations("age_stats", aggregationBuilder -> aggregationBuilder
24.                             .stats(statsAggregationBuilder -> statsAggregationBuilder
25.                                     .field("age")))
26.             , Poet.class);
27.     logger.info(response.toString());
29.     //select name,count(*) from poet-index group by name
30.     response = client.search(searchRequestBuilder -> searchRequestBuilder
31.                     .index(INDEX_NAME)
32.                     .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
33.                             .terms(termsAggregationBuilder -> termsAggregationBuilder
34.                                     .field("name")))
35.             , Poet.class);
36.     logger.info(response.toString());
38.     //select name,age,count(*) from poet-index group by name,age
39.     response = client.search(searchRequestBuilder -> searchRequestBuilder
40.                     .index(INDEX_NAME)
41.                     .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
42.                             .terms(termsAggregationBuilder -> termsAggregationBuilder
43.                                     .field("name")
44.                             )
45.                             .aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
46.                                     .terms(termsAggregationBuilder -> termsAggregationBuilder
47.                                             .field("age")
48.                                     ))
49.                     )
50.             , Poet.class);
51.     logger.info(response.toString());
53.     //类似 select avg(age) from poet-index where name='李白'
54.     response = client.search(searchRequestBuilder -> searchRequestBuilder
55.                     .index(INDEX_NAME)
56.                     .query(queryBuilder -> queryBuilder
57.                             .bool(boolQueryBuilder -> boolQueryBuilder
58.                                     .filter(queryBuilder2 -> queryBuilder2
59.                                             .term(termQueryBuilder -> termQueryBuilder
60.                                                     .field("name").value("李白")))))
61.                     .aggregations("ave_age", aggregationBuilder -> aggregationBuilder
62.                             .avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
63.             , Poet.class);
64.     logger.info(response.toString());
65. }

复制代码

3.4.9、推荐搜索

1. @Test
2. public void searchSuggest() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                     .index(INDEX_NAME)
5.                     .suggest(suggesterBuilder -> suggesterBuilder
6.                             .suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
7.                                     .text("思考")
8.                                     .term(termSuggesterBuilder -> termSuggesterBuilder
9.                                             .field("success")
10.                                             .suggestMode(SuggestMode.Always)
11.                                             .minWordLength(2)
12.                                     )
13.                             )
14.                     )
15.             , Poet.class);
16.     logger.info(response.toString());
17. }

复制代码

该测试会报如下错误：

1. co.elastic.clients.json.JsonpMappingException: Error deserializing co.elastic.clients.elasticsearch.core.search.TermSuggest: co.elastic.clients.json.UnexpectedJsonEventException: Unexpected JSON event 'START_ARRAY' instead of '[START_OBJECT, KEY_NAME]' (JSON path: suggest['term#success_suggest'][0].options) (line no=1, column no=247, offset=-1)

复制代码

还有高手知道原因？
3.4.10、高亮显示

1. @Test
2. public void searchHighlight() throws IOException {
3.     SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
4.                 .index(INDEX_NAME)
5.                 .query(queryBuilder -> queryBuilder
6.                         .match(matchQueryBuilder -> matchQueryBuilder
7.                                 .field("success").query("思想")))
8.                 .highlight(highlightBuilder -> highlightBuilder
9.                         .preTags("<span color='red'>")
10.                         .postTags("</span>")
11.                         .fields("success", highlightFieldBuilder -> highlightFieldBuilder))
12.         , Poet.class);
13.     logger.info(response.toString());
14. }

复制代码

3.4.11、SQL 查询

1. @Test
2. public void searchSql() throws IOException {
3.     QueryResponse response = client.sql().query(builder -> builder
4.             .format("json").query("SELECT * FROM "" + INDEX_NAME + "" limit 3"));
5.     logger.info(response.toString());
6. }

复制代码

该测试会报如下错误：

1. co.elastic.clients.json.JsonpMappingException: Error deserializing co.elastic.clients.elasticsearch.sql.QueryResponse: java.lang.UnsupportedOperationException (JSON path: rows[0][0]) (line no=1, column no=184, offset=-1)

复制代码

还有高手知道原因？
3.5、完整代码

1. package com.abc.demo.es;
3. import co.elastic.clients.elasticsearch.ElasticsearchClient;
4. import co.elastic.clients.elasticsearch._types.*;
5. import co.elastic.clients.elasticsearch._types.aggregations.AverageAggregation;
6. import co.elastic.clients.elasticsearch._types.aggregations.CardinalityAggregation;
7. import co.elastic.clients.elasticsearch._types.aggregations.SumAggregation;
8. import co.elastic.clients.elasticsearch._types.query_dsl.*;
9. import co.elastic.clients.elasticsearch.cat.IndicesResponse;
10. import co.elastic.clients.elasticsearch.core.*;
11. import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
12. import co.elastic.clients.elasticsearch.indices.*;
13. import co.elastic.clients.elasticsearch.sql.QueryResponse;
14. import co.elastic.clients.json.JsonData;
15. import co.elastic.clients.json.jackson.JacksonJsonpMapper;
16. import co.elastic.clients.transport.ElasticsearchTransport;
17. import co.elastic.clients.transport.rest_client.RestClientTransport;
18. import com.fasterxml.jackson.databind.ObjectMapper;
19. import lombok.AllArgsConstructor;
20. import lombok.Data;
21. import lombok.NoArgsConstructor;
22. import org.apache.http.HttpHost;
23. import org.elasticsearch.client.RestClient;
24. import org.junit.After;
25. import org.junit.Before;
26. import org.junit.Test;
27. import org.slf4j.Logger;
28. import org.slf4j.LoggerFactory;
30. import java.io.IOException;
31. import java.util.ArrayList;
32. import java.util.HashMap;
33. import java.util.List;
34. import java.util.Map;
36. public class ElasticsearchJavaCase {
37.     private static final Logger logger = LoggerFactory.getLogger(ElasticsearchJavaCase.class.getName());
39.     private static final String INDEX_NAME = "poet-index";
41.     private ElasticsearchTransport transport;
42.     private ElasticsearchClient client;
44.     @Before
45.     public void before() {
46.         RestClient restClient = RestClient.builder(
47.                 new HttpHost("10.49.196.10", 9200),
48.                 new HttpHost("10.49.196.11", 9200),
49.                 new HttpHost("10.49.196.12", 9200)).build();
50.         ObjectMapper objectMapper = new ObjectMapper();
51.         transport = new RestClientTransport(restClient, new JacksonJsonpMapper(objectMapper));
52.         client = new ElasticsearchClient(transport);
53.     }
55.     @After
56.     public void after() throws IOException {
57.         transport.close();
58.     }
60.     /**
61.      * 创建索引
62.      */
63.     @Test
64.     public void createIndex() throws IOException {
65.         CreateIndexResponse response = client.indices().create(builder -> builder
66.                 .settings(indexSettingsBuilder -> indexSettingsBuilder.numberOfReplicas("1").numberOfShards("2"))
67.                 .mappings(typeMappingBuilder -> typeMappingBuilder
68.                         .properties("age", propertyBuilder -> propertyBuilder.integer(integerNumberPropertyBuilder -> integerNumberPropertyBuilder))
69.                         .properties("name", propertyBuilder -> propertyBuilder.keyword(keywordPropertyBuilder -> keywordPropertyBuilder))
70.                         .properties("poems", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
71.                         .properties("about", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
72.                         .properties("success", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_max_word")))
73.                 )
74.                 .index(INDEX_NAME));
75.         logger.info("acknowledged={}", response.acknowledged());
76.     }
78.     /**
79.      * 修改索引的_mapping信息
80.      * 字段可以新增，已有的字段只能修改字段的search_analyzer属性
81.      */
82.     @Test
83.     public void modifyIndex() throws IOException {
84.         PutMappingResponse response = client.indices().putMapping(typeMappingBuilder -> typeMappingBuilder
85.                 .index(INDEX_NAME)
86.                 .properties("age", propertyBuilder -> propertyBuilder.integer(integerNumberPropertyBuilder -> integerNumberPropertyBuilder))
87.                 .properties("name", propertyBuilder -> propertyBuilder.keyword(keywordPropertyBuilder -> keywordPropertyBuilder))
88.                 .properties("poems", propertyBuilder -> propertyBuilder.text(textPropertyBuilder -> textPropertyBuilder.analyzer("ik_max_word").searchAnalyzer("ik_smart")))
89.         );
90.         logger.info("acknowledged={}", response.acknowledged());
91.     }
93.     /**
94.      * 删除索引
95.      */
96.     @Test
97.     public void deleteIndex() throws IOException {
98.         DeleteIndexResponse response = client.indices().delete(builder -> builder.index(INDEX_NAME));
99.         logger.info("acknowledged={}", response.acknowledged());
100.     }
102.     /**
103.      * 查询索引列表
104.      */
105.     @Test
106.     public void getIndex() throws IOException {
107.         //使用 * 也可以
108.         GetIndexResponse response = client.indices().get(builder -> builder.index("_all"));
109.         logger.info(response.result().toString());
110.     }
112.     /**
113.      * 查询索引详情
114.      */
115.     @Test
116.     public void getIndexDetail() throws IOException {
117.         GetIndexResponse response = client.indices().get(builder -> builder.index(INDEX_NAME));
118.         logger.info(response.result().toString());
119.     }
121.     /**
122.      * 创建文档
123.      */
124.     @Test
125.     public void createDoc() throws IOException {
126.         Map<String, Object> doc = new HashMap<>();
127.         doc.put("age", 30);
128.         doc.put("name", "李白");
129.         doc.put("poems", "静夜思");
130.         doc.put("about", "字太白");
131.         doc.put("success", "创造了古代浪漫主义文学高峰、歌行体和七绝达到后人难及的高度");
133.         CreateResponse response = client.create(builder -> builder.index(INDEX_NAME).id("1").document(doc));
134.         logger.info(response.toString());
136.         Poet poet = new Poet(31, "杜甫", "登高", "字子美", "唐代伟大的现实主义文学作家，唐诗思想艺术的集大成者");
137.         response = client.create(builder -> builder.index(INDEX_NAME).id("2").document(poet));
138.         logger.info(response.toString());
139.     }
141.     /**
142.      * 删除文档
143.      */
144.     @Test
145.     public void deleteDoc() throws IOException {
146.         DeleteResponse response = client.delete(builder -> builder.index(INDEX_NAME).id("1"));
147.         logger.info(response.toString());
148.     }
150.     /**
151.      * 修改文档，只修改设置的字段
152.      */
153.     @Test
154.     public void updateDoc() throws IOException {
155.         Map<String, Object> doc = new HashMap<>();
156.         doc.put("age", 33);
157.         doc.put("name", "李白2");
159.         UpdateResponse response = client.update(builder -> builder.index(INDEX_NAME).id("1").doc(doc), Map.class);
160.         logger.info(response.toString());
162.         Poet poet = new Poet();
163.         poet.setAge(40);
164.         poet.setName("杜甫2");
165.         response = client.update(builder -> builder.index(INDEX_NAME).id("2").doc(poet).docAsUpsert(true), Poet.class);
166.         logger.info(response.toString());
167.     }
169.     /**
170.      * 新增或修改文档，修改时所有的字段都会覆盖(相当于先删除在新增)
171.      */
172.     @Test
173.     public void createOrUpdateDoc() throws IOException {
174.         Map<String, Object> doc = new HashMap<>();
175.         doc.put("age", 33);
176.         doc.put("name", "李白2");
178.         //只更新设置的字段
179.         IndexResponse response = client.index(builder -> builder.index(INDEX_NAME).id("1").document(doc));
180.         logger.info(response.toString());
182.         Poet poet = new Poet();
183.         poet.setAge(40);
184.         poet.setName("杜甫2");
185.         response = client.index(builder -> builder.index(INDEX_NAME).id("2").document(poet));
186.         logger.info(response.toString());
187.     }
190.     /**
191.      * 批量操作
192.      */
193.     @Test
194.     public void bulk() throws IOException {
195.         List<BulkOperation> list = new ArrayList<>();
197.         //批量新增
198.         for (int i = 0; i < 5; i++) {
199.             Map<String, Object> doc = new HashMap<>();
200.             doc.put("age", 30);
201.             doc.put("name", "李白" + i);
202.             doc.put("poems", "静夜思");
203.             doc.put("about", "字太白");
204.             doc.put("success", "创造了古代浪漫主义文学高峰、歌行体和七绝达到后人难及的高度");
205.             String id = 10 + i + "";
206.             list.add(new BulkOperation.Builder().create(builder -> builder.index(INDEX_NAME).id(id).document(doc)).build());
207.         }
208.         for (int i = 0; i < 5; i++) {
209.             Poet poet = new Poet(31, "杜甫" + i, "登高", "字子美", "唐代伟大的现实主义文学作家，唐诗思想艺术的集大成者");
210.             String id = 20 + i + "";
211.             list.add(new BulkOperation.Builder().create(builder -> builder.index(INDEX_NAME).id(id).document(poet)).build());
212.         }
214.         //批量删除
215.         list.add(new BulkOperation.Builder().delete(builder -> builder.index(INDEX_NAME).id("1")).build());
216.         list.add(new BulkOperation.Builder().delete(builder -> builder.index(INDEX_NAME).id("2")).build());
218.         BulkResponse response = client.bulk(builder -> builder.index(INDEX_NAME).operations(list));
219.         logger.info(response.toString());
220.     }
222.     /**
223.      * 查询索有文档
224.      */
225.     @Test
226.     public void getDocAll() throws IOException {
227.         SearchResponse<Map> response = client.search(builder -> builder.index(INDEX_NAME), Map.class);
228.         logger.info(response.toString());
229.     }
231.     /**
232.      * 查询单个文档
233.      */
234.     @Test
235.     public void getDoc() throws IOException {
236.         GetResponse<Map> response = client.get(builder -> builder.index(INDEX_NAME).id("1"), Map.class);
237.         if (response.found()) {
238.             logger.info(response.source().toString());
239.         }
241.         GetResponse<Poet> response2 = client.get(builder -> builder.index(INDEX_NAME).id("2"), Poet.class);
242.         if (response2.found()) {
243.             logger.info(response2.source().toString());
244.         }
245.     }
247.     /**
248.      * term/terms查询,对输入内容不做分词处理
249.      */
250.     @Test
251.     public void searchTerm() throws IOException {
252.         SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
253.                 .index(INDEX_NAME)
254.                 .query(queryBuilder -> queryBuilder
255.                         .term(termQueryBuilder -> termQueryBuilder
256.                                 .field("name").value("李白")))
257.                 .sort(sortOptionsBuilder -> sortOptionsBuilder
258.                         .field(fieldSortBuilder -> fieldSortBuilder
259.                                 .field("name").order(SortOrder.Asc)))
260.                 .source(sourceConfigBuilder -> sourceConfigBuilder
261.                         .filter(sourceFilterBuilder -> sourceFilterBuilder
262.                                 .includes("age", "name")))
263.                 .from(0)
264.                 .size(10)
265.                 , Map.class);
266.         logger.info(response.toString());
268.         List<FieldValue> words = new ArrayList<>();
269.         words.add(new FieldValue.Builder().stringValue("李白").build());
270.         words.add(new FieldValue.Builder().stringValue("杜甫").build());
271.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
272.                         .index(INDEX_NAME)
273.                         .query(queryBuilder -> queryBuilder
274.                                 .terms(termsQueryBuilder -> termsQueryBuilder
275.                                         .field("name").terms(termsQueryFieldBuilder -> termsQueryFieldBuilder.value(words))))
276.                         .source(sourceConfigBuilder -> sourceConfigBuilder
277.                                 .filter(sourceFilterBuilder -> sourceFilterBuilder
278.                                         .excludes("about")))
279.                         .from(0)
280.                         .size(10)
281.                 , Poet.class);
282.         logger.info(response2.toString());
283.     }
285.     /**
286.      * range查询,范围查询
287.      */
288.     @Test
289.     public void searchRange() throws IOException {
290.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
291.                         .index(INDEX_NAME)
292.                         .query(queryBuilder -> queryBuilder
293.                                 .range(rangeQueryBuilder -> rangeQueryBuilder
294.                                         .field("age").gte(JsonData.of("20")).lt(JsonData.of("40"))))
295.                 , Poet.class);
296.         logger.info(response.toString());
297.     }
299.     /**
300.      * match查询，对输入内容先分词再查询
301.      */
302.     @Test
303.     public void searchMatch() throws IOException {
304.         SearchResponse<Map> response = client.search(searchRequestBuilder -> searchRequestBuilder
305.                         .index(INDEX_NAME)
306.                         .query(queryBuilder -> queryBuilder
307.                                 .match(matchQueryBuilder -> matchQueryBuilder
308.                                         .field("success").query("思想")))
309.                 , Map.class);
310.         logger.info(response.toString());
311.     }
313.     /**
314.      * multi_match查询,-
315.      */
316.     @Test
317.     public void searchMultiMatch() throws IOException {
318.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
319.                         .index(INDEX_NAME)
320.                         .query(queryBuilder -> queryBuilder
321.                                 .multiMatch(multiMatchQueryBuilder -> multiMatchQueryBuilder
322.                                         .fields("about", "success").query("思想")))
323.                 , Poet.class);
324.         logger.info(response.toString());
325.     }
327.     /**
328.      * match_phrase 查询,匹配整个查询字符串
329.      */
330.     @Test
331.     public void searchMatchPhrase() throws IOException {
332.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
333.                         .index(INDEX_NAME)
334.                         .query(queryBuilder -> queryBuilder
335.                                 .matchPhrase(matchPhraseQueryBuilder -> matchPhraseQueryBuilder.field("success").query("文学作家")))
336.                 , Poet.class);
337.         logger.info(response.toString());
338.     }
340.     /**
341.      * match_all 查询,查询所有
342.      */
343.     @Test
344.     public void searchMatchAll() throws IOException {
345.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
346.                         .index(INDEX_NAME)
347.                         .query(queryBuilder -> queryBuilder
348.                                 .matchAll(matchAllQueryBuilder -> matchAllQueryBuilder))
349.                 , Poet.class);
350.         logger.info(response.toString());
351.     }
353.     /**
354.      * query_string 查询
355.      */
356.     @Test
357.     public void searchQueryString() throws IOException {
358.         //类似 match
359.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
360.                         .index(INDEX_NAME)
361.                         .query(queryBuilder -> queryBuilder
362.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
363.                                     .defaultField("success").query("古典文学")))
364.                 , Poet.class);
365.         logger.info(response.toString());
367.         //类似 mulit_match
368.         response = client.search(searchRequestBuilder -> searchRequestBuilder
369.                         .index(INDEX_NAME)
370.                         .query(queryBuilder -> queryBuilder
371.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
372.                                         .fields("about", "success").query("古典文学")))
373.                 , Poet.class);
374.         logger.info(response.toString());
376.         //类似 match_phrase
377.         response = client.search(searchRequestBuilder -> searchRequestBuilder
378.                         .index(INDEX_NAME)
379.                         .query(queryBuilder -> queryBuilder
380.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
381.                                         .defaultField("success").query(""文学作家"")))
382.                 , Poet.class);
383.         logger.info(response.toString());
385.         //带运算符查询，运算符两边的词不再分词
386.         //查询同时包含 ”文学“ 和 ”伟大“ 的文档
387.         response = client.search(searchRequestBuilder -> searchRequestBuilder
388.                         .index(INDEX_NAME)
389.                         .query(queryBuilder -> queryBuilder
390.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
391.                                         .fields("success").query("文学 AND 伟大")))
392.                 , Poet.class);
393.         logger.info(response.toString());
395.         //等同上一个查询
396.         response = client.search(searchRequestBuilder -> searchRequestBuilder
397.                         .index(INDEX_NAME)
398.                         .query(queryBuilder -> queryBuilder
399.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
400.                                         .fields("success").query("文学 伟大").defaultOperator(Operator.And)))
401.                 , Poet.class);
402.         logger.info(response.toString());
404.         //查询 name 或 success 字段包含"文学"和"伟大"这两个单词，或者包含"李白"这个单词的文档。
405.         response = client.search(searchRequestBuilder -> searchRequestBuilder
406.                         .index(INDEX_NAME)
407.                         .query(queryBuilder -> queryBuilder
408.                                 .queryString(queryStringQueryBuilder -> queryStringQueryBuilder
409.                                         .fields("name","success").query("(文学 AND 伟大) OR 高度")))
410.                 , Poet.class);
411.         logger.info(response.toString());
412.     }
414.     /**
415.      * simple_query_string 查询,和query_string类似
416.      * 不支持AND OR NOT，会当做字符串处理
417.      * 使用 +替代AND,|替代OR,-替代NOT
418.      */
419.     @Test
420.     public void searchSimpleQueryString() throws IOException {
421.         //查询同时包含 ”文学“ 和 ”伟大“ 的文档
422.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
423.                         .index(INDEX_NAME)
424.                         .query(queryBuilder -> queryBuilder
425.                                 .simpleQueryString(simpleQueryStringQueryBuilder -> simpleQueryStringQueryBuilder
426.                                         .fields("success").query("文学 + 伟大")))
427.                 , Poet.class);
428.         logger.info(response.toString());
429.     }
431.     /**
432.      * 模糊查询
433.      */
434.     @Test
435.     public void searchFuzzy() throws IOException {
436.         //全文查询时使用模糊参数，先分词再计算模糊选项。
437.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
438.                         .index(INDEX_NAME)
439.                         .query(queryBuilder -> queryBuilder
440.                                 .match(matchQueryBuilder -> matchQueryBuilder
441.                                         .field("success").query("思考").fuzziness("1")))
442.                 , Poet.class);
443.         logger.info(response.toString());
445.         //使用 fuzzy query，对输入不分词，直接计算模糊选项。
446.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
447.                         .index(INDEX_NAME)
448.                         .query(queryBuilder -> queryBuilder
449.                                 .fuzzy(fuzzyQueryBuilder ->  fuzzyQueryBuilder
450.                                         .field("success").fuzziness("1").value("理想")))
451.                 , Poet.class);
452.         logger.info(response2.toString());
453.     }
455.     /**
456.      * bool查询,组合查询
457.      */
458.     @Test
459.     public void searchBool() throws IOException {
460.         //查询 success 包含 “思想” 且 age 在 [20-40] 之间的文档
461.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
462.                 .index(INDEX_NAME)
463.                 .query(queryBuilder -> queryBuilder
464.                         .bool(boolQueryBuilder -> boolQueryBuilder
465.                                 .must(queryBuilder2 -> queryBuilder2
466.                                         .match(matchQueryBuilder -> matchQueryBuilder
467.                                                 .field("success").query("思想"))
468.                                 )
469.                                 .must(queryBuilder2 -> queryBuilder2
470.                                         .range(rangeQueryBuilder -> rangeQueryBuilder
471.                                                 .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
472.                                 )
473.                         )
474.                 )
475.         , Poet.class);
476.         logger.info(response.toString());
478.         //过滤出 success 包含 “思想” 且 age 在 [20-40] 之间的文档，不计算得分
479.         SearchResponse<Poet> response2 = client.search(searchRequestBuilder -> searchRequestBuilder
480.                 .index(INDEX_NAME)
481.                 .query(queryBuilder -> queryBuilder
482.                         .bool(boolQueryBuilder -> boolQueryBuilder
483.                                 .filter(queryBuilder2 -> queryBuilder2
484.                                         .match(matchQueryBuilder -> matchQueryBuilder
485.                                                 .field("success").query("思想"))
486.                                 )
487.                                 .filter(queryBuilder2 -> queryBuilder2
488.                                         .range(rangeQueryBuilder -> rangeQueryBuilder
489.                                                 .field("age").gte(JsonData.of("20")).lt(JsonData.of("40")))
490.                                 )
491.                         )
492.                 )
493.         , Poet.class);
494.         logger.info(response2.toString());
495.     }
497.     /**
498.      * aggs查询,聚合查询
499.      */
500.     @Test
501.     public void searchAggs() throws IOException {
502.         //求和
503.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
504.                         .index(INDEX_NAME)
505.                         .aggregations("age_sum", aggregationBuilder -> aggregationBuilder
506.                                 .sum(sumAggregationBuilder -> sumAggregationBuilder
507.                                         .field("age")))
508.                 , Poet.class);
509.         logger.info(response.toString());
511.         //类似 select count distinct(age) from poet-index
512.         response = client.search(searchRequestBuilder -> searchRequestBuilder
513.                         .index(INDEX_NAME)
514.                         .aggregations("age_count", aggregationBuilder -> aggregationBuilder
515.                                 .cardinality(cardinalityAggregationBuilder -> cardinalityAggregationBuilder.field("age")))
516.                 , Poet.class);
517.         logger.info(response.toString());
519.         //数量、最大、最小、平均、求和
520.         response = client.search(searchRequestBuilder -> searchRequestBuilder
521.                         .index(INDEX_NAME)
522.                         .aggregations("age_stats", aggregationBuilder -> aggregationBuilder
523.                                 .stats(statsAggregationBuilder -> statsAggregationBuilder
524.                                         .field("age")))
525.                 , Poet.class);
526.         logger.info(response.toString());
528.         //select name,count(*) from poet-index group by name
529.         response = client.search(searchRequestBuilder -> searchRequestBuilder
530.                         .index(INDEX_NAME)
531.                         .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
532.                                 .terms(termsAggregationBuilder -> termsAggregationBuilder
533.                                         .field("name")))
534.                 , Poet.class);
535.         logger.info(response.toString());
537.         //select name,age,count(*) from poet-index group by name,age
538.         response = client.search(searchRequestBuilder -> searchRequestBuilder
539.                         .index(INDEX_NAME)
540.                         .aggregations("name_terms", aggregationBuilder -> aggregationBuilder
541.                                 .terms(termsAggregationBuilder -> termsAggregationBuilder
542.                                         .field("name")
543.                                 )
544.                                 .aggregations("age_terms", aggregationBuilder2 -> aggregationBuilder2
545.                                         .terms(termsAggregationBuilder -> termsAggregationBuilder
546.                                                 .field("age")
547.                                         ))
548.                         )
549.                 , Poet.class);
550.         logger.info(response.toString());
552.         //类似 select avg(age) from poet-index where name='李白'
553.         response = client.search(searchRequestBuilder -> searchRequestBuilder
554.                         .index(INDEX_NAME)
555.                         .query(queryBuilder -> queryBuilder
556.                                 .bool(boolQueryBuilder -> boolQueryBuilder
557.                                         .filter(queryBuilder2 -> queryBuilder2
558.                                                 .term(termQueryBuilder -> termQueryBuilder
559.                                                         .field("name").value("李白")))))
560.                         .aggregations("ave_age", aggregationBuilder -> aggregationBuilder
561.                                 .avg(averageAggregationBuilder -> averageAggregationBuilder.field("age")))
562.                 , Poet.class);
563.         logger.info(response.toString());
564.     }
566.     /**
567.      * suggest查询,推荐搜索, 报错
568.      */
569.     @Test
570.     public void searchSuggest() throws IOException {
571.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
572.                         .index(INDEX_NAME)
573.                         .suggest(suggesterBuilder -> suggesterBuilder
574.                                 .suggesters("success_suggest", fieldSuggesterBuilder -> fieldSuggesterBuilder
575.                                         .text("思考")
576.                                         .term(termSuggesterBuilder -> termSuggesterBuilder
577.                                                 .field("success")
578.                                                 .suggestMode(SuggestMode.Always)
579.                                                 .minWordLength(2)
580.                                         )
581.                                 )
582.                         )
583.                 , Poet.class);
584.         logger.info(response.toString());
585.     }
587.     /**
588.      * 高亮显示
589.      */
590.     @Test
591.     public void searchHighlight() throws IOException {
592.         SearchResponse<Poet> response = client.search(searchRequestBuilder -> searchRequestBuilder
593.                     .index(INDEX_NAME)
594.                     .query(queryBuilder -> queryBuilder
595.                             .match(matchQueryBuilder -> matchQueryBuilder
596.                                     .field("success").query("思想")))
597.                     .highlight(highlightBuilder -> highlightBuilder
598.                             .preTags("<span color='red'>")
599.                             .postTags("</span>")
600.                             .fields("success", highlightFieldBuilder -> highlightFieldBuilder))
601.             , Poet.class);
602.         logger.info(response.toString());
603.     }
605.     /**
606.      * sql查询，报错
607.      */
608.     @Test
609.     public void searchSql() throws IOException {
610.         QueryResponse response = client.sql().query(builder -> builder
611.                 .format("json").query("SELECT * FROM "" + INDEX_NAME + "" limit 1"));
612.         logger.info(response.toString());
613.     }
616.     @Data
617.     @AllArgsConstructor
618.     @NoArgsConstructor
619.     static class Poet {
620.         private Integer age;
621.         private String name;
622.         private String poems;
623.         private String about;
624.         /**成就*/
625.         private String success;
626.     }
627. }

复制代码

ElasticsearchJavaCase.java 
详细的 Elasticsearch Java API Client 使用说明，请参考官网文档：https://www.elastic.co/guide/en/elasticsearch/client/java-api-client/current/index.html。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！