SpringBoot+ElasticSearch聚合查询+条件查询
es7.0以上
对应mysql语句
select state,count(state) countState from indexName where is_delete=0 group by state
1.指定查询的索引
SearchRequest searchRequest = new SearchRequest(indexName);
2.构建过滤条件
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
3.构建聚合条件:根据state字段进行分组
AggregationBuilder aggregationBuilder = AggregationBuilders.terms("state").field("state");
4.构建查询条件:查询未删除
BoolQueryBuilder filterQuery = QueryBuilders.boolQuery();
filterQuery.must(QueryBuilders.termQuery("isDelete", 0));
5.将聚合条件和查询条件放入过滤条件中
searchSourceBuilder.aggregation(aggregationBuilder);
searchSourceBuilder.query(QueryBuilders.boolQuery().filter(filterQuery));
6.将过滤条件放入指定索引中
searchRequest.source(searchSourceBuilder);
7.查询
SearchResponse response = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
8.解析查询到结果
//map:key=分组的状态,value=每组的个数
Map<String, Integer> stateCountMap = new LinkedHashMap<>();
//拿到聚合结果
Terms terms = response.getAggregations().get(Fn.getName(EsTaskEntity::getState));
//遍历聚合结果
for (Terms.Bucket bucket : terms.getBuckets()) {
//getKeyAsString():分组之后每个详细的值
//bucket.getDocCount() 分组之后每个值得个数
stateCountMap.put(bucket.getKeyAsString(), Long.valueOf(bucket.getDocCount()).intValue());
}