SpringBoot整合SpringDataElasticsearch的过程详解

      org.springframework.boot
      spring-boot-starter-data-elasticsearch

spring.data.elasticsearch.cluster-name=elasticsearch //名字必须和elasticsearch.yml里面的cluster.name相同
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300 
spring.data.elasticsearch.repositories.enabled=true

@Document(indexName = "item",type = "docs", shards = 1, replicas = 0)//标记为文档类型，ndexName：对应索引库名称type：对应在索引库中的类型，shards：分片数量，默认5，replicas：副本数量，默认1
public class Item {
  @Id //主键
  private Long id;
  @Field(type = FieldType.Text, analyzer = "ik_max_word") //标记为成员变量　　FieldType，可以是text、long、short、date、integer等　　text：存储数据时候，会自动分词，并生成索引　　keyword：存储数据时候，不会分词建立索引　　analyzer:分词器名称
  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(index = false, type = FieldType.Keyword)//index:是否索引
  private String images; // 图片地址

 　 @Autowired
  private ElasticsearchTemplate elasticsearchTemplate;

   //添加索引
  @Test
  public void addIndex() {
    elasticsearchTemplate.createIndex(Item.class);
  }

  //删除索引
  @Test
  public void delete(){
    elasticsearchTemplate.deleteIndex("item");
  }

public interface ItemRepository extends ElasticsearchCrudRepository {
}

  @Autowired
  private ItemRepository itemRepository;

//新增一个对象
  @Test
  public void insert(){
    Item item = new Item(2L,"坚果R1","手机","锤子",2500.00,"http://image.baidu.com/13123.jpg");
    //Order order = new Order(20180020,"菜单");
    itemRepository.save(item);
  }

//批量新增
  @Test
  public void insertList(){
    List list = new LinkedList<>();
    list.add(new Item(9L,"华为p20","手机","华为",3500.00,"http://image.baidu.com/13123.jpg"));
    list.add(new Item(10L,"华为p30","手机","华为",5450.00,"http://image.baidu.com/13123.jpg"));
    list.add(new Item(11L,"华为p30 pro","手机","华为",6980.00,"http://image.baidu.com/13123.jpg"));
    itemRepository.saveAll(list);
  }

//根据字段查询所有
  @Test
  public void queryAll(){
    //升序,相应降序为dscending
    Iterable items = this.itemRepository.findAll(Sort.by("price").ascending());
    for (Item item : items){
      System.out.println(item);
    }
  }

//自定义方法,根据Title查询
  @Test
  public void findByTitle(){
    Item item = this.itemRepository.findByTitle("坚果pro");
    System.out.println(item);
  }

//根据区间查询
  @Test
  public void queryByPriceBetween(){
    List list = this.itemRepository.findByPriceBetween(2000.00, 3500.00);
    for (Item item : list) {
      System.out.println("item = " + item);
    }
  }

//模糊查询
  @Test
  public void queryLikeTitle(){
    List list = this.itemRepository.findByTitleLike("R2");
    for (Item item : list){
      System.out.println(item);
    }
  }

public interface ItemRepository extends ElasticsearchCrudRepository {
  Item findByTitle(String title);
  List findByPriceBetween(double price1, double price2);
  List findByTitleLike(String title);
}

//自定义查询,查询数目等
  @Test
  public void matchQuery(){
    // 构建查询条件
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 添加基本分词查询
    queryBuilder.withQuery(QueryBuilders.matchQuery("title","坚果"));
    //获取结果
    Page items = (Page) this.itemRepository.findAll();
    //条数
    long total = items.getTotalElements();
    System.out.println("total = "+total);
    for (Item item : items){
      System.out.println(item);
    }
  }关键的是NativeSearchQueryBuilder这个类

//分页查询
  @Test
  public void queryByPage(){
    NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();
    nativeSearchQueryBuilder.withQuery(QueryBuilders.termQuery("category","手机"));
    int page = 0;
    int size = 2;
    nativeSearchQueryBuilder.withPageable(PageRequest.of(page,size));
    Page items = (Page) this.itemRepository.findAll();
    long total = items.getTotalElements();
    int totalPage = items.getTotalPages();
    int nowPage = items.getNumber();
    int pageSize = items.getSize();
    System.out.println("总条数 = "+total);
    System.out.println("总页数 = "+totalPage);
    System.out.println("当前页 = "+nowPage);
    System.out.println("每页大小 = "+pageSize);
    for (Item item : items){
      System.out.println(item);
    }
  }