SpringDataElasticsearch的原生操作综合模板

墨蓝 2022-12-27 01:22 163阅读 0赞

自定义方法无法对应需求需求，`SpringDataElasticsearch`也支持原生查询，这个时候还是使用`ElasticsearchTemplate`

# 综合模板代码: #

public void testNativeQuery(){ 
        // 原生查询构建器
        NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
        
        //source过滤
        queryBuilder.withSourceFilter(new FetchSourceFilter(new String[0], new String[0]));
        
        //搜索条件
        queryBuilder.withQuery(QueryBuilders.matchQuery("title", "小米手机"));
        
        //分页及排序条件
        queryBuilder.withPageable(
            PageRequest.of(0, 2,
                           Sort.by(Sort.Direction.ASC, "price")));
        
        //聚合
        queryBuilder.addAggregation(AggregationBuilders.terms("brandAgg").field("brand"));
    
        // 构建查询条件，并且查询
        AggregatedPage<Goods> result = esTemplate.queryForPage(queryBuilder.build(), Goods.class);
    
    //-----------------------------------结果-----------------
        //分页结果
        long total = result.getTotalElements();
        int totalPages = result.getTotalPages();
        List<Goods> list = result.getContent();
        System.out.println("总条数 = " + total);
        System.out.println("总页数 = " + totalPages);
        System.out.println(list);
    
        //聚合结果
        Aggregations aggregations = result.getAggregations();
        Terms terms = aggregations.get("brandAgg");
        terms.getBuckets().forEach(b -> { 
            System.out.println("品牌 = " + b.getKeyAsString());
            System.out.println("count = " + b.getDocCount());
        });
    }

# 实体类 #

import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import org.springframework.data.annotation.Id;
    import org.springframework.data.elasticsearch.annotations.Document;
    import org.springframework.data.elasticsearch.annotations.Field;
    import org.springframework.data.elasticsearch.annotations.FieldType;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    @Document(indexName = "textceshi",shards=3,type = "goods")
    public class Goods { 
        @Id
        private Long id;
        @Field(type = FieldType.Text,analyzer = "ik_max_word")
        private String title; //标题
        @Field(type = FieldType.Keyword)
        private String category;// 分类
        @Field(type = FieldType.Keyword)
        private String brand; // 品牌
        @Field(type = FieldType.Double)
        private Double price; // 价格
        @Field(type = FieldType.Keyword)
        private String images; // 图片地址
    }