spring-data-elasticsearch(spring elasticsearch)

1.SpringBoot环境和测试类，我就不讲了。

2.yml中的配置

clustername：是es的集群名称，默认是elasticsearch

cluster-nodes：tcp的地址，不要写错。

spring:
  data:
    elasticsearch:
      cluster-name: elasticsearch
      cluster-nodes: 192.168.199.128:9300

3.注意：org.springframework.boot,的版本如果过高或者过低，都会和我的代码不一样，我的是2.0.6

4.实体类的创建，用于创建es索引库和mapping映射段

@document(indexName = "item", shards = 1,replicas =0 , type="docs")
public class Item {
    @Id
    Long id;
    @Field(type =FieldType.Text,analyzer = "ik_max_word")
    String title; //标题
    @Field(type = FieldType.Keyword)
    String category;// 分类
    @Field(type =FieldType.Keyword )
    String brand; // 品牌
    @Field(type =FieldType.Double )
    Double price; // 价格
    @Field(type =FieldType.Keyword ,index = false)
    String images; // 图片地址

    @Override
    public String toString() {
        return "Item{" +
                "id=" + id +
                ", title='" + title + ''' +
                ", category='" + category + ''' +
                ", brand='" + brand + ''' +
                ", price=" + price +
                ", images='" + images + ''' +
                '}';
    }

    public Item() {
    }

    public Item(Long id, String title, String category, String brand, Double price, String images) {
        this.id = id;
        this.title = title;
        this.category = category;
        this.brand = brand;
        this.price = price;
        this.images = images;
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getCategory() {
        return category;
    }

    public void setCategory(String category) {
        this.category = category;
    }

    public String getBrand() {
        return brand;
    }

    public void setBrand(String brand) {
        this.brand = brand;
    }

    public Double getPrice() {
        return price;
    }

    public void setPrice(Double price) {
        this.price = price;
    }

    public String getImages() {
        return images;
    }

    public void setImages(String images) {
        this.images = images;
    }
}

5.写一个结构，继承ElasticSearchRepository<实体类，主键类型>

6.测试代码

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringDataEsApplication.class)
public class elasticSearch {

    @Autowired
    private ElasticsearchTemplate elasticsearchTemplate;
    @Autowired
    private ItemRepository itemRepository;
    @Test
    public void textIndex(){
        elasticsearchTemplate.createIndex(Item.class);
        elasticsearchTemplate.putMapping(Item.class);
    }
    @Test
    public void testSave(){
        Item item=new Item(1L, "小米手机7", " 手机",
                "小米", 3499.00, "http://image.leyou.com/13123.jpg");
        itemRepository.save(item);
    }
    @Test
    public void testSaveAll(){
        List list=new ArrayList<>();
        list.add(new Item(1L, "小米手机7", "手机", "小米", 3299.00, "http://image.leyou.com/13123.jpg"));
        list.add(new Item(2L, "坚果手机R1", "手机", "锤子", 3699.00, "http://image.leyou.com/123.jpg"));
        list.add(new Item(3L, "华为meta10", "手机", "华为", 4499.00, "http://image.leyou.com/3.jpg"));
        list.add(new Item(4L, "小米Mix2S", "手机", "小米", 4299.00, "http://image.leyou.com/13123.jpg"));
        list.add(new Item(5L, "荣耀V10", "手机", "华为", 2799.00, "http://image.leyou.com/13123.jpg"));
        itemRepository.saveAll(list);
    }
    @Test
    public void testFindById(){
        Optional item = itemRepository.findById(1l);
        System.out.println(item.get());
    }
    @Test
    public void testSortFind(){
        Iterable price = itemRepository.findAll(Sort.by("price").descending());
        price.forEach((item)-> System.out.println(item));
//        或者price.forEach(System.out::println);
    }
    @Test
    public void testFindByTitle(){
        List shoujis = itemRepository.findByTitle("手机");
        shoujis.forEach((shouji)-> System.out.println(shouji));
    }
    @Test
    public void testFindPriceBetween(){
        List byPriceBetween = itemRepository.findByPriceBetween(3600d, 5000d);
        byPriceBetween.forEach(System.out::println);

    }
    @Test
    public void testFindByCategory(){
        List shoujis = itemRepository.findByCategory("手机");
        shoujis.forEach((shouji)-> System.out.println(shouji));
    }
    @Test
    public void testFindAll(){
        Iterable all = itemRepository.findAll();
        all.forEach(System.out::println);
    }


    
    @Test
    public void testQueryBuilders(){
        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title", "手机");
        Iterable search = itemRepository.search(matchQueryBuilder);
        search.forEach(System.out::println);
    }
    
    @Test
    public void testNativeSearchQueryBuilder(){
        NativeSearchQueryBuilder searchQueryBuilder=new NativeSearchQueryBuilder();
        //添加基本查询条件
        searchQueryBuilder.withQuery(QueryBuilders.matchQuery("title", "手机"));
        //执行查询，获取分页结果集
        Page items = itemRepository.search(searchQueryBuilder.build());//默认添加分页
        System.out.println(items.getTotalElements());
        System.out.println(items.getTotalPages());
        items.forEach(System.out::println);
    }
    
    @Test
    public void testPage(){
        NativeSearchQueryBuilder QueryBuilder=new NativeSearchQueryBuilder();
        //添加基本查询条件
        QueryBuilder.withQuery(QueryBuilders.matchQuery("category","手机"));
        //添加分页条件，页码从0开始，查询第二页每页两条
        QueryBuilder.withPageable(PageRequest.of(1,2));
        //执行查询，获取分页结果集
        Page search = this.itemRepository.search(QueryBuilder.build());
        System.out.println(search.getTotalPages());
        System.out.println(search.getTotalElements());
        search.getContent().forEach(System.out::println);
    }
    
    @Test
    public void testSort(){
        NativeSearchQueryBuilder QueryBuilder=new NativeSearchQueryBuilder();
        //添加基本查询条件
        QueryBuilder.withQuery(QueryBuilders.matchQuery("category","手机"));
        //添加排序
        QueryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.ASC));
        //执行查询，获取分页结果集
        Page search = this.itemRepository.search(QueryBuilder.build());
        System.out.println(search.getTotalPages());
        System.out.println(search.getTotalElements());
        search.getContent().forEach(System.out::println);
    }

    
    @Test
    public void testAgg(){
        NativeSearchQueryBuilder searchQueryBuilder = new NativeSearchQueryBuilder();
        //定义聚合名称和聚合字段
        searchQueryBuilder.addAggregation(AggregationBuilders.terms("brandAgg").field("brand"));
        //过滤掉普通结果集,不包含任何字段，也不排除任何字段，等于不显示普通字段。
        searchQueryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{},null));
        //执行查询,要使用page中的AggregationPage字类，才能拿到aggregation聚合
        AggregatedPage search = (AggregatedPage)itemRepository.search(searchQueryBuilder.build());
        //想要在聚合中拿到桶，就需要使用其下的Terms-StringTerms字类，根据我们的聚合方式，使用的子类也不同
        StringTerms brandAgg = (StringTerms)search.getAggregation("brandAgg");
        List buckets = brandAgg.getBuckets();
        buckets.forEach((bucket)->{
            //打印聚合名称和词条数
            System.out.println(bucket.getKeyAsString());
            System.out.println(bucket.getDocCount());
        });
    }

    //桶内嵌套度量
    @Test
    public void testAggAndDuliang(){
        NativeSearchQueryBuilder searchQueryBuilder = new NativeSearchQueryBuilder();
        //定义聚合名称和聚合字段
        searchQueryBuilder.addAggregation(AggregationBuilders.terms("brandAgg").field("brand")
                .subAggregation(AggregationBuilders.avg("price_avg").field("price")));
        //过滤掉普通结果集,不包含任何字段，也不排除任何字段，等于不显示普通字段。
        searchQueryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{},null));
        //执行查询,要使用page中的AggregationPage字类，才能拿到aggregation聚合
        AggregatedPage search = (AggregatedPage)itemRepository.search(searchQueryBuilder.build());
        //想要在聚合中拿到桶，就需要使用其下的Terms-StringTerms字类，根据我们的聚合方式，使用的子类也不同
        StringTerms brandAgg = (StringTerms)search.getAggregation("brandAgg");
        List buckets = brandAgg.getBuckets();
        buckets.forEach((bucket)->{
            //打印聚合名称和词条数
            System.out.println(bucket.getKeyAsString());
            System.out.println(bucket.getDocCount());
            //子聚合放入map中根据，map的key-子聚合名称获取聚合
            Map stringAggregationMap = bucket.getAggregations().asMap();
            //依旧需要强转，avg需要转成InternalAvg
            InternalAvg price_avg = (InternalAvg)stringAggregationMap.get("price_avg");
            System.out.println(price_avg.getValue());
        });
    }
}

7.最后附上依赖



    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.0.6.RELEASE
         
    
    cn.itcast.elasticSearch
    SpringDate-ElasticSearch
    1.0-SNAPSHOT
    jar
    
        UTF-8
        UTF-8
        1.8
    
    
        
            org.springframework.boot
            spring-boot-starter-test
            test
        
        
            org.springframework.boot
            spring-boot-starter-data-elasticsearch
        

    
    
        
            
                org.springframework.boot
                spring-boot-maven-plugin

spring-data-elasticsearch(spring elasticsearch)

大数据系统相关栏目本月热门文章