• 【纯干货】SpringBoot 整合 ES 进行各种高级查询搜索

    在上篇 SpringBoot 整合 ElasticSearch 文章中，我们详细的介绍了 ElasticSearch 的索引和文档的基本增删改查的操作方法！

    本文将重点介绍 ES 的各种高级查询写法和使用。

    废话不多说，直接上代码！

    二、代码实践

    本文采用的SpringBoot版本号是2.1.0.RELEASE，服务端 es 的版本号是6.8.2，客户端采用的是官方推荐的Elastic Java High Level Rest Client版本号是6.4.2，方便与SpringBoot的版本兼容。

    es 最大的亮点就是查询非常丰富，可以在上亿的数据里面快速搜索出目标数据，查询如果实现呢？请看下文

    • 单条件精确查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 单条件精确查询
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search0() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.termsQuery("name", "赵里"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 多条件精确查询，取并集

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 多条件精确查询，取并集
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search1() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.termsQuery("name", "张", "陈"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 范围查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 范围查询，包括from、to
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search2() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.rangeQuery("age").from(20).to(32));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29.  
    30.     /**
    31.      * 范围查询，不包括from、to
    32.      * @throws IOException
    33.      */
    34.     @Test
    35.     public void search3() throws IOException {
    36.         // 创建请求
    37.         SearchSourceBuilder builder = new SearchSourceBuilder()
    38.                 .query(QueryBuilders.rangeQuery("age").from(20,false).to(30, false));
    39.  
    40.         //搜索
    41.         SearchRequest searchRequest = new SearchRequest();
    42.         searchRequest.indices("cs_index");
    43.         searchRequest.types("_doc");
    44.         searchRequest.source(builder);
    45.         // 执行请求
    46.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    47.         // 解析查询结果
    48.         System.out.println(response.toString());
    49.     }
    50.  
    51.  
    52.     /**
    53.      * 范围查询, lt:小于，gt:大于
    54.      * @throws IOException
    55.      */
    56.     @Test
    57.     public void search4() throws IOException {
    58.         // 创建请求
    59.         SearchSourceBuilder builder = new SearchSourceBuilder()
    60.                 .query(QueryBuilders.rangeQuery("age").lt(30).gt(20));
    61.  
    62.         //搜索
    63.         SearchRequest searchRequest = new SearchRequest();
    64.         searchRequest.indices("cs_index");
    65.         searchRequest.types("_doc");
    66.         searchRequest.source(builder);
    67.         // 执行请求
    68.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    69.         // 解析查询结果
    70.         System.out.println(response.toString());
    71.     }
    72.  
    73. }

    • 模糊查询，支持通配符

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 模糊查询，支持通配符
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search5() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.wildcardQuery("name","张三"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 不使用通配符的模糊查询，左右匹配

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 不使用通配符的模糊查询，左右匹配
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search6() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.queryStringQuery("张三").field("name"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 多字段模糊查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 多字段模糊查询
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search7() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.multiMatchQuery("长", "name", "city"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 多字段模糊查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 分页搜索
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search8() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .from(0).size(2);
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 字段排序

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 排序，字段的类型必须是：integer、double、long或者keyword
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search9() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .sort("createTime", SortOrder.ASC);
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 精确统计筛选文档数

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 精确统计筛选文档数,查询性能有所降低
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search10() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .trackTotalHits(true);
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 设置源字段过滤返回

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 设置源字段过虑,第一个参数结果集包括哪些字段，第二个参数表示结果集不包括哪些字段
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search11() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .fetchSource(new String[]{"name","age","city","createTime"},new String[]{});
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28.  
    29. }

    • 根据 id 精确匹配

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 根据id精确匹配
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search12() throws IOException {
    14.         String[] ids = new String[]{"1","2"};
    15.         // 创建请求
    16.         SearchSourceBuilder builder = new SearchSourceBuilder()
    17.                 .query(QueryBuilders.termsQuery("_id", ids));
    18.  
    19.         //搜索
    20.         SearchRequest searchRequest = new SearchRequest();
    21.         searchRequest.indices("cs_index");
    22.         searchRequest.types("_doc");
    23.         searchRequest.source(builder);
    24.         // 执行请求
    25.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    26.         // 解析查询结果
    27.         System.out.println(response.toString());
    28.     }
    29.  
    30. }

    • matchAllQuery 搜索全部

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * matchAllQuery搜索全部
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search21() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.matchAllQuery());
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28. }

    • match 搜索匹配

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * match搜索匹配
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search22() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder()
    16.                 .query(QueryBuilders.matchQuery("name", "张王"));
    17.  
    18.         //搜索
    19.         SearchRequest searchRequest = new SearchRequest();
    20.         searchRequest.indices("cs_index");
    21.         searchRequest.types("_doc");
    22.         searchRequest.source(builder);
    23.         // 执行请求
    24.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    25.         // 解析查询结果
    26.         System.out.println(response.toString());
    27.     }
    28. }

    • bool组合查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * bool组合查询
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search23() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
    18.         boolQueryBuilder.must(QueryBuilders.matchQuery("name", "张王"));
    19.         boolQueryBuilder.must(QueryBuilders.rangeQuery("age").lte(30).gte(20));
    20.         builder.query(boolQueryBuilder);
    21.  
    22.         //搜索
    23.         SearchRequest searchRequest = new SearchRequest();
    24.         searchRequest.indices("cs_index");
    25.         searchRequest.types("_doc");
    26.         searchRequest.source(builder);
    27.         // 执行请求
    28.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    29.         // 解析查询结果
    30.         System.out.println(response.toString());
    31.     }
    32. }

    • nested 类型嵌套查询

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * nested类型嵌套查询
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search24() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件查询
    18.         BoolQueryBuilder mainBool=new BoolQueryBuilder();
    19.         mainBool.must(QueryBuilders.matchQuery("name", "赵六"));
    20.  
    21.         //nested类型嵌套查询
    22.         BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
    23.         boolQueryBuilder.must(QueryBuilders.matchQuery("products.brand", "A"));
    24.         boolQueryBuilder.must(QueryBuilders.matchQuery("products.title", "巧克力"));
    25.         NestedQueryBuilder nested = QueryBuilders.nestedQuery("products",boolQueryBuilder, ScoreMode.None);
    26.         mainBool.must(nested);
    27.  
    28.         builder.query(mainBool);
    29.  
    30.         //搜索
    31.         SearchRequest searchRequest = new SearchRequest();
    32.         searchRequest.indices("cs_index");
    33.         searchRequest.types("_doc");
    34.         searchRequest.source(builder);
    35.         // 执行请求
    36.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    37.         // 解析查询结果
    38.         System.out.println(response.toString());
    39.     }
    40. }

    • 多条件查询 + 排序 + 分页

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 多条件查询 + 排序 + 分页
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search29() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件搜索
    18.         BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
    19.         boolQueryBuilder.must(QueryBuilders.matchQuery("name", "张王"));
    20.         boolQueryBuilder.must(QueryBuilders.rangeQuery("age").lte(30).gte(20));
    21.         builder.query(boolQueryBuilder);
    22.  
    23.         //结果集合分页
    24.         builder.from(0).size(2);
    25.  
    26.         //排序
    27.         builder.sort("createTime",SortOrder.ASC);
    28.  
    29.         //搜索
    30.         SearchRequest searchRequest = new SearchRequest();
    31.         searchRequest.indices("cs_index");
    32.         searchRequest.types("_doc");
    33.         searchRequest.source(builder);
    34.         // 执行请求
    35.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    36.         // 解析查询结果
    37.         System.out.println(response.toString());
    38.     }
    39. }

    • 聚合查询-求和

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 聚合查询 sum
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search30() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件搜索
    18.         builder.query(QueryBuilders.matchAllQuery());
    19.         //聚合查询
    20.         AggregationBuilder aggregation = AggregationBuilders.sum("sum_age").field("age");
    21.         builder.aggregation(aggregation);
    22.  
    23.         //搜索
    24.         SearchRequest searchRequest = new SearchRequest();
    25.         searchRequest.indices("cs_index");
    26.         searchRequest.types("_doc");
    27.         searchRequest.source(builder);
    28.         // 执行请求
    29.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    30.         // 解析查询结果
    31.         System.out.println(response.toString());
    32.     }
    33. }

    • 聚合查询-求平均值

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 聚合查询 avg
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search31() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件搜索
    18.         builder.query(QueryBuilders.matchAllQuery());
    19.         //聚合查询
    20.         AggregationBuilder aggregation = AggregationBuilders.avg("avg_age").field("age");
    21.         builder.aggregation(aggregation);
    22.  
    23.         //搜索
    24.         SearchRequest searchRequest = new SearchRequest();
    25.         searchRequest.indices("cs_index");
    26.         searchRequest.types("_doc");
    27.         searchRequest.source(builder);
    28.         // 执行请求
    29.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    30.         // 解析查询结果
    31.         System.out.println(response.toString());
    32.     }
    33. }

    • 聚合查询-计数

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 聚合查询 count
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search32() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件搜索
    18.         builder.query(QueryBuilders.matchAllQuery());
    19.         //聚合查询
    20.         AggregationBuilder aggregation = AggregationBuilders.count("count_age").field("age");
    21.         builder.aggregation(aggregation);
    22.  
    23.         //搜索
    24.         SearchRequest searchRequest = new SearchRequest();
    25.         searchRequest.indices("cs_index");
    26.         searchRequest.types("_doc");
    27.         searchRequest.source(builder);
    28.         // 执行请求
    29.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    30.         // 解析查询结果
    31.         System.out.println(response.toString());
    32.     }
    33. }

    • 聚合查询-分组

    1. @RunWith(SpringJUnit4ClassRunner.class)
    2. @SpringBootTest(classes = ElasticSearchApplication.class)
    3. public class SearchJunit {
    4.  
    5.     @Autowired
    6.     private RestHighLevelClient client;
    7.  
    8.     /**
    9.      * 聚合查询 分组
    10.      * @throws IOException
    11.      */
    12.     @Test
    13.     public void search33() throws IOException {
    14.         // 创建请求
    15.         SearchSourceBuilder builder = new SearchSourceBuilder();
    16.  
    17.         //条件搜索
    18.         builder.query(QueryBuilders.matchAllQuery());
    19.         //聚合查询
    20.         AggregationBuilder aggregation = AggregationBuilders.terms("tag_createTime").field("createTime")
    21.                 .subAggregation(AggregationBuilders.count("count_age").field("age")) //计数
    22.                 .subAggregation(AggregationBuilders.sum("sum_age").field("age")) //求和
    23.                 .subAggregation(AggregationBuilders.avg("avg_age").field("age")); //求平均值
    24.  
    25.         builder.aggregation(aggregation);
    26.  
    27.         //不输出原始数据
    28.         builder.size(0);
    29.  
    30.         //搜索
    31.         SearchRequest searchRequest = new SearchRequest();
    32.         searchRequest.indices("cs_index");
    33.         searchRequest.types("_doc");
    34.         searchRequest.source(builder);
    35.         // 执行请求
    36.         SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
    37.         // 解析查询结果
    38.         System.out.println(response.toString());
    39.     }
    40. }

    三、小结

    本文主要围绕 SpringBoot 整合 ElasticSearch 进行各种高级查询的介绍，在下篇文章中，我们会重点介绍 es 的性能调优！

    文章内容难免会有些遗漏的地方，欢迎网友批评指出！

  • 相关阅读:
    Docker容器中杀死僵尸进程、jobs命令
    多尺度深度学习——day52 基于领导者的多尺度注意力深度人物再识别架构
    CSB ---＞ （XXE）XML基础
    COPU陆首群教授应邀在ApacheCon Asia会议上致辞
    Java学习笔记3.5.4 继承 - Object类
    ESP32网络开发实例-将数据保存到InfluxDB时序数据库
    LeetCode算法题解|LeetCode435. 无重叠区间、LeetCode763. 划分字母区间、LeetCode56. 合并区间
    R语言使用ggplot2可视化泊松回归模型（Poisson Regression）的结果、可视化不同参量组合下的计数结果
    04.在谷歌浏览器中安装模拟浏览器ChromeDriver的详细步骤
    UVM实战——01基本概念_2 什么是UVM？
  • 原文地址：https://blog.csdn.net/qq_42093488/article/details/125464811