elasticsearch（⼆）：java操作es实现分组聚合查询和基本查
询
es查询还有⼀个很常⽤的⼀种叫聚合查询，相当于mysql中的分组group by 后拿各组数量进⾏统计 ，实现起来也是很简单。
基本查询包含聚合：
具体直接看代码，代码中部分有注释
/**
* person查询
* 继承baseService的list返回的query对象
* @return
*/
public Result personList(PersonInfo personInfo) {
Result result = new Result();
//如果参数有值，放这个map中
Map<String, Object> queryParams = new HashMap<>();
//接收参数，如果没有则按没条件查询，下⽅有判空
String query_EQ_personName = PersonName();
String query_EQ_workOrgId = WorkOrgId()+"";
String query_EQ_filed = Filed();
groupby分组
if( StringUtils.isNotEmpty(query_EQ_personName) ){
queryParams.put("EQ_person_name", query_EQ_personName);
}
if( StringUtils.isNotEmpty(query_EQ_workOrgId) && !"null".equals(query_EQ_workOrgId)){
queryParams.put("EQ_work_org_id", Integer.parseInt(query_EQ_workOrgId));
}
if( StringUtils.isNotEmpty(query_EQ_filed) ){
queryParams.put("EQ_filed", query_EQ_filed);
}
QueryBuilder queryBuilder = createQueryBuilder(create(queryParams));
//左侧聚合条件：⼈员类型，职称
SearchQuery searchQuery = creatSearchQuery(queryBuilder,
//指定要聚合的字段
//查询操作，这⾥⽤的另外⼀种查询，不包括分页效果
AggregatedPage<PersonInfoEs> page = (AggregatedPage<PersonInfoEs>) personRepository.search(searchQuery);
//创建map⽤来放聚合的数据
Map<String,Object> title = new HashMap<>();
Map<String,Object> personType = new HashMap<>();
//从结果中根据名称来拿聚合出来的数据
Terms termTitle = (Terms) Aggregations().getAsMap().get("title");
Terms termPersonType = (Terms) Aggregations().getAsMap().get("personType");
Terms termMilitary_rank = (Terms) Aggregations().getAsMap().get("military_rank");
//遍历⽅式拿数据，放⼊map中，map为数据内容，value为数量
for (Terms.Bucket bucket : Buckets()) {
personType.Key().toString().isEmpty() ? "其他" : Key().toString(), DocCount());
}
for (Terms.Bucket bucket : Buckets()) {
title.Key().toString().isEmpty() ? "其他" : Key().toString(), DocCount());
}
for (Terms.Bucket bucket : Buckets()) {
military_rank.Key().toString().isEmpty() || null== Key() ? "其他" : Key().toString(), DocCount());
}
/
/最后在放⼊map中⼀并返回
Map<String, Object> totalMap = new LinkedHashMap<>();
Map<String, Object> totalMap = new LinkedHashMap<>();
totalMap.put("title", title);
totalMap.put("personType",personType );
totalMap.put("military_rank", military_rank);
result.setCode(200);
Map<String, Object> contentMap = new HashMap<>();
contentMap.put("content", Content());
result.setData(contentMap);
result.setCount(String.TotalElements()));
result.Size());
result.Number());
HashMap<String, List<GroupInfo>> groupFilterMap = builAggregationVo(totalMap);
result.setGroupFilter(groupFilterMap);
return result;
}
返回结果如下：
如有问题请留⾔探讨；

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。