ElasticSearch6.x 基于SpringBoot 实现ElasticSearch之分组统计查询

太过爱你忘了你带给我的痛 2023-10-18 22:27 145阅读 0赞

AggregationUtil.java中添加如下方法，

/**
    	     * 分组统计
    	     * @param index 索引
    	     * @param field 文档属性
    	     * @return
    	     */
    	    public Terms terms(String index,String field){
    	    	String name = "terms";
    	        AggregationBuilder agg=AggregationBuilders.terms(name).field(field);
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }
    	    
    	    /**
    	     * 过滤器统计
    	     * @param index 索引
    	     * @param field 文档属性
    	     * @return
    	     */
    	    public Filter filter(String index, String field, String key){
    	        QueryBuilder query=QueryBuilders.termQuery(field,key);
    	        String name ="filter";
    	        AggregationBuilder agg=AggregationBuilders.filter(name,query);
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }
    	    
    	    /**
    	     * 多过滤器统计
    	     * @param index 索引
    	     * @param list  过滤条件队列
    	     * @return
    	     */
    	    public Filters filters(String index, List<TermQueryBuilder> list){
    	    	String name = "filters";
    	    	
    	    	FiltersAggregator.KeyedFilter[] filters = new FiltersAggregator.KeyedFilter[list.size()];
    	    	for(int i=0; i <list.size(); i++){
    	    		TermQueryBuilder obj = list.get(i);
    	    		FiltersAggregator.KeyedFilter item = new FiltersAggregator.KeyedFilter(obj.fieldName(),obj);
    	    		filters[i] = item;
    	    	}
    	    	
    	        AggregationBuilder agg=AggregationBuilders.filters(name, filters);
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }
    	    
    	    /**
    	     * 区间统计
    	     * @param index 索引
    	     * @param field 文档属性
    	     * @return
    	     */
    	    public Range range(String index, String field, double to, double from){
    	    	String name ="range";
    	        AggregationBuilder agg=AggregationBuilders
    	                .range(name)
    	                .field(field)
    	                .addUnboundedTo(to)//第1个范围 ( ,to)
    	                .addRange(to,from)//第2个范围[to,from)
    	                .addUnboundedFrom(from);//第3个范围[from,)
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }
    
    	
    
    	    /**
    	     * 日期区间统计
    	     * @param index 索引
    	     * @param field 文档属性
    	     * @return
    	     */
    	    public Range dateRange(String index, String field,String to,String from, String formated){
    	    	String name ="dateRange";
    	        AggregationBuilder agg=AggregationBuilders
    	                .dateRange(name)
    	                .field(field)
    	                .format(formated)
    	                .addUnboundedTo(to)
    	                .addUnboundedFrom(from);
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }
    	    
    	    /**
    	     * Missing统计
    	     * @param field
    	     * @return
    	     */
    	    public Missing missing(String index, String field){
    	    	String name ="missing";
    	        AggregationBuilder agg=AggregationBuilders.missing(name).field(field);
    	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet();
    	        return response.getAggregations().get(name);
    	    }