使用java query dsl进行“查询+聚合”elasticsearch

基础概念

Java Query DSL 是 Elasticsearch 提供的一种强大的查询语言，允许开发者通过 Java 代码构建复杂的查询和聚合操作。Elasticsearch 是一个基于 Lucene 的分布式搜索和分析引擎，广泛用于全文搜索、结构化搜索、分析以及各种复杂的数据处理任务。

类型与应用场景

类型：

全文搜索：用于处理自然语言文本的搜索。
结构化查询：针对特定字段进行的精确匹配和范围查询。
聚合分析：对数据进行分组、统计和汇总。

应用场景：

日志分析：实时监控和分析系统日志。
电商搜索：提供商品搜索和建议功能。
金融数据分析：处理和分析大量的金融交易数据。

示例代码

以下是一个使用 Java Query DSL 进行查询和聚合操作的示例：

import com.querydsl.core.types.dsl.BooleanExpression;
import com.querydsl.core.types.dsl.Expressions;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;

public class ElasticsearchQueryExample {

    public SearchSourceBuilder buildQuery() {
        BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()
                .must(QueryBuilders.matchQuery("field1", "value1"))
                .filter(QueryBuilders.rangeQuery("timestamp").gte("now-1d/d"));

        TermsAggregationBuilder aggregation = AggregationBuilders.terms("by_category")
                .field("category.keyword")
                .subAggregation(AggregationBuilders.avg("avg_value").field("value"));

        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(boolQuery);
        sourceBuilder.aggregation(aggregation);

        return sourceBuilder;
    }
}