SpringBoot整合Spring Data Elasticsearch

索引（indices）--------数据库（databases)
类型（type)------------数据表（table)
文档（Document）---------------- 行(row)
字段（Field）-------------------列(Columns ) 

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

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<Item,Long> {

}

   @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<Item> 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<Item> 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<Item> list = this.itemRepository.findByPriceBetween(2000.00, 3500.00);
        for (Item item : list) {
            System.out.println("item = " + item);
        }
    }

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

public interface ItemRepository extends ElasticsearchCrudRepository<Item,Long> {

    Item findByTitle(String title);

    List<Item> findByPriceBetween(double price1, double price2);

    List<Item> findByTitleLike(String title);
}

    //自定义查询,查询数目等
    @Test
    public void matchQuery(){
        // 构建查询条件
        NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
        // 添加基本分词查询
        queryBuilder.withQuery(QueryBuilders.matchQuery("title","坚果"));
        //获取结果
        Page<Item> items = (Page<Item>) 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<Item> items = (Page<Item>) 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);
        }
    }