标签：executionTimeAvg 聚合 查询 输入框 ElasticSearch executionDateGroup executionDate QueryB
OR条件查询
ES条件查询中有MUST/MUSTNOT/SHOULD逻辑，其中MUST/MUSTNOT与sql中的AND/NOT理解和用法基本一致，但SHOULD则与sql中的OR有些不一样，在ES中如果要表示OR查询，则需要配合MUST一起使用，即MUST(SHOULD A, SHOULD B)，表示A OR B
BoolQueryBuilder pinyinQuery = QueryBuilders.boolQuery();
if (!keyword.contains("-")) {
pinyinQuery.should(QueryBuilders.matchQuery("userName.pinyin", pinyin));
}
pinyinQuery.should(QueryBuilders.termQuery("userId", keyword));
BoolQueryBuilder queryEs = QueryBuilders.boolQuery()
.must(pinyinQuery)
.must(new TermQueryBuilder("officeStatus", "1"));
// 构造highlight
HighlightBuilder hiBuilder= new HighlightBuilder();
hiBuilder.preTags("<h2>").postTags("</h2>").field("userName.pinyin");
SearchResponse scrollRes =
client.prepareSearch(ES_INDEX_NAME)
.setTypes(ES_INDEX_USER_TYPE)
.setQuery(queryEs)
.highlighter(hiBuilder)
.setScroll("10s")
.setSize(1000)
.get();
分组聚合查询
实现类似select avg(executionTime) from t WHERE executionDate between 'A' AND 'B' group by executionDate ORDER BY executionDate ASC的查询后聚合。ES分组计算的逻辑是先将executionDate分组，然后在每个分组内在进行聚合，在API中是两个聚合aggregation包含的逻辑关系。
//1.先对executionDate分组，取名executionDateGroup，即实现group by executionDate，如果不设置size，则聚合返回默认10组数据
TermsAggregationBuilder groupTerms = AggregationBuilders.terms("executionDateGroup").field("executionDate").size(Integer.MAX_VALUE);
//设置排序 true为正序、flase为倒序，实现ORDER BY executionDate ASC
groupTerms.order(BucketOrder.key(true));
//2.聚合avg(executionTime)，取名executionTimeAvg
AvgAggregationBuilder timeAvg = AggregationBuilders.avg("executionTimeAvg").field("executionTime");
//3.两个aggregation父子关系
groupTerms.subAggregation(timeAvg);
//查询条件
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
RangeQueryBuilder rangeDateQuery = QueryBuilders.rangeQuery("executionDate").gte(DateFormatUtils.format(fromDate, "yyyy-MM-dd HH:mm:ss"))
.lte(DateFormatUtils.format(toDate, "yyyy-MM-dd HH:mm:ss"));
queryBuilder.must(rangeDateQuery);
//如果方法名不为空，则添加查询条件
if (StringUtils.isNotBlank(condition.getMethodName())) {
queryBuilder.must(new TermQueryBuilder("methodName", condition.getMethodName()));
}
SearchResponse searchRes = esClient.prepareSearch(CommonConstants.EHR_EXCUTION_AOP_LOG_INDEX)
.setTypes(CommonConstants.EHR_EXCUTION_AOP_LOG_TYPE)
.setQuery(queryBuilder)
.addAggregation(groupTerms) //设置聚合
.addSort("executionDate", SortOrder.ASC)
.get();
// 获取结果，提取结果的顺序与aggregation组合关系一致，先提取外层executionDateGroup，再提取多个分组的子层executionTimeAvg
Aggregation executionDateGroup = searchRes.getAggregations().get("executionDateGroup");
Terms timeAvgTerms = null;
if (executionDateGroup instanceof Terms) {
//外层aggregation
timeAvgTerms = (Terms) executionDateGroup;
List<? extends Terms.Bucket> buckets = timeAvgTerms.getBuckets();
for (Terms.Bucket elem : buckets) {
//子级aggregation
InternalAvg executionTimeAvg = (InternalAvg) elem.getAggregations().get("executionTimeAvg");
ExecutionInfoDto executionInfoDto = new ExecutionInfoDto();
executionInfoDto.setExecutionDate(elem.getKeyAsString());
executionInfoDto.setExecutionTime((int)executionTimeAvg.getValue());
executionInfoDtoList.add(executionInfoDto);
}
}
原文链接：https://blog.csdn.net/ljyhust/article/details/87278243
标签：executionTimeAvg,聚合,查询,输入框,ElasticSearch,executionDateGroup,executionDate,QueryB 来源： https://www.cnblogs.com/wj123bk/p/15739132.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。