本教程详细指导如何将包含`match_all`查询和多个聚合（如`min`和`max`）的elasticsearch json查询转换为等效的java api。我们将重点展示如何利用`searchsourcebuilder`将多个`aggregationbuilder`组合成一个单一的搜索请求，从而避免多次api调用，提高查询效率和代码简洁性。
在Elasticsearch中，一个典型的搜索请求JSON体通常包含以下几个核心部分：
给定的JSON查询示例如下：
{
"size": 0,
"query": {
"match_all": {}
},
"aggs": {
"min": {
"min": {
"field": "<The date>"
}
},
"max":{
"max": {
"field": "<The date>"
}
}
}
}这个查询的目标是获取所有文档中指定日期字段的最小值和最大值，同时不返回任何文档。
要使用Java API构建并执行上述查询，我们需要了解几个关键类：
立即学习“Java免费学习笔记（深入）”；
用户常遇到的一个误区是，认为每个AggregationBuilder的调用都需要单独的API请求。实际上，AggregationBuilder只是构建聚合定义的语句，它们会被添加到同一个SearchSourceBuilder中，最终通过一次client.search()调用发送给Elasticsearch。
以下是实现上述JSON查询的Java API步骤：
本系统经过多次升级改造，系统内核经过多次优化组合，已经具备相对比较方便快捷的个性化定制的特性，用户部署完毕以后，按照自己的运营要求，可实现快速定制会费管理，支持在线缴费和退费功能财富中心，管理会员的诚信度数据单客户多用户登录管理全部信息支持审批和排名不同的会员级别有不同的信息发布权限企业站单独生成，企业自主决定更新企业站信息留言、询价、报价统一管理，分系统查看分类信息参数化管理，支持多样分类信息，
0
首先，创建一个SearchSourceBuilder实例，并设置match_all查询和size为0。
import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.index.query.QueryBuilders; SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); // 设置查询条件为匹配所有文档 searchSourceBuilder.query(QueryBuilders.matchAllQuery()); // 设置返回文档数量为0，因为我们只关心聚合结果 searchSourceBuilder.size(0);
接下来，使用AggregationBuilders为日期字段添加min和max聚合。注意，这两个聚合都通过searchSourceBuilder.aggregation()方法添加到同一个SearchSourceBuilder实例中。
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.MaxAggregationBuilder;
import org.elasticsearch.search.aggregations.metrics.MinAggregationBuilder;
// 定义Min聚合，别名为"min"，作用于"date"字段
MinAggregationBuilder minAggregation = AggregationBuilders.min("min").field("date");
searchSourceBuilder.aggregation(minAggregation);
// 定义Max聚合，别名为"max"，作用于"date"字段
MaxAggregationBuilder maxAggregation = AggregationBuilders.max("max").field("date");
searchSourceBuilder.aggregation(maxAggregation);注意：在原始问题中，用户在尝试MinAggregationBuilder时错误地使用了AggregationBuilders.max("min").field("date")。正确的做法是使用AggregationBuilders.min("min").field("date")。上述代码已修正此错误。
将构建好的SearchSourceBuilder放入SearchRequest中，并指定要查询的索引。最后，通过RestHighLevelClient执行请求。
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.action.search.SearchResponse;
// 假设您已经初始化了RestHighLevelClient实例
// RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));
SearchRequest searchRequest = new SearchRequest("your_index_name"); // 替换为您的实际索引名称
searchRequest.source(searchSourceBuilder);
// 执行API调用
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);将以上片段组合起来，形成一个完整的Java API调用示例：
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.Max;
import org.elasticsearch.search.aggregations.metrics.Min;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.apache.http.HttpHost;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
public class ElasticsearchMultiAggregationTutorial {
public static void main(String[] args) throws IOException {
// 1. 初始化RestHighLevelClient
// 实际应用中，请确保客户端是单例并妥善管理其生命周期
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(
new HttpHost("localhost", 9200, "http")));
try {
// 2. 构建SearchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
// 设置查询条件：匹配所有文档
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
// 设置返回文档数量为0，因为我们只关心聚合结果
searchSourceBuilder.size(0);
// 设置超时时间（可选）
searchSourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
// 3. 添加多个聚合操作
// 添加Min聚合，别名为"min"，作用于"date"字段
searchSourceBuilder.aggregation(AggregationBuilders.min("min").field("date"));
// 添加Max聚合，别名为"max"，作用于"date"字段
searchSourceBuilder.aggregation(AggregationBuilders.max("max").field("date"));
// 4. 封装SearchRequest
SearchRequest searchRequest = new SearchRequest("your_index_name"); // 替换为您的实际索引名称
searchRequest.source(searchSourceBuilder);
System.out.println("Generated Elasticsearch Query JSON:");
System.out.println(searchSourceBuilder.toString()); // 打印生成的JSON，方便调试
// 5. 执行API调用
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
// 6. 处理聚合结果
// 获取Min聚合结果
Min minAggregation = searchResponse.getAggregations().get("min");
double minValue = minAggregation.getValue();
System.out.println("Min date value: " + minValue); // 对于日期字段，通常需要进一步格式化
// 获取Max聚合结果
Max maxAggregation = searchResponse.getAggregations().get("max");
double maxValue = maxAggregation.getValue();
System.out.println("Max date value: " + maxValue); // 对于日期字段，通常需要进一步格式化
} catch (IOException e) {
System.err.println("Error during Elasticsearch search: " + e.getMessage());
e.printStackTrace();
} finally {
// 7. 关闭RestHighLevelClient
try {
if (client != null) {
client.close();
}
} catch (IOException e) {
System.err.println("Error closing Elasticsearch client: " + e.getMessage());
}
}
}
}以上就是Elasticsearch Java API：在单次请求中实现多聚合查询的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
105
收藏
