转自：https://blog.csdn.net/u013089490/article/details/84323903

1、ElasticsearchRepository

1.1、ElasticsearchRepository源码

@NoRepositoryBean
public interface ElasticsearchRepository<T, ID extends Serializable> extends ElasticsearchCrudRepository<T, ID> {
    <S extends T> S index(S entity);
    Iterable<T> search(QueryBuilder query);
     //search方法需要QueryBuilder参数和springdata的Pageable分页参数
   //其中QueryBuilder是一个接口，常用的实现类有MatchQueryBuilder、RangeQueryBuilder范围、FuzzyQueryBuilder模糊、WildcardQueryBuilder模糊。
    Page<T> search(QueryBuilder query, Pageable pageable);
    //SearchQuery是一个查询接口，NativeSearchQuery是该接口的一个实现
    Page<T> search(SearchQuery searchQuery);
    Page<T> searchSimilar(T entity, String[] fields, Pageable pageable);
    void refresh();
    Class<T> getEntityClass();
}

【注意】
（1）ElasticsearchRepository里面search(QueryBuilder query)方法，其中QueryBuilder是一个接口，常用的实现类有MatchQueryBuilder、RangeQueryBuilder范围、FuzzyQueryBuilder模糊、WildcardQueryBuilder模糊。
（2）ElasticsearchRepository里面search(SearchQuery searchQuery)方法,主要是看QueryBuilder和SearchQuery两个参数;其中SearchQuery是一个接口，有一个实现类叫NativeSearchQuery。

1.2、自定义方法

   自定义方法的前提是我们需要继承ElasticsearchRepository接口，利用强大的Spring Data来实现。比如：你的方法名叫做：findByTitle，那么它就知道你是根据title查询，然后自动帮你完成，无需写实现类。<br />【自定义方法命名约定】：

例如，我们来按照价格区间查询，定义这样的一个方法findByPriceBetween：

/**
 * 需要继承ElasticsearchRepository接口
 * 由于Item实体类中id为Long类型
 */
public interface ItemRepository extends ElasticsearchRepository<Item,Long> {
    /**
     * 方法名必须遵守SpringData的规范
     * 价格区间查询     
     */
    List<Item> findByPriceBetween(double price1, double price2);
}

2、基本操作

在【https://mp.csdn.net/postedit/84323886】基础上我们进行以下操作，实体类和索引创建都是安装上述博客内容；下面只对Repository操作详细说明。

2.1、定义自己的Repository接口

/**
 * 需要继承ElasticsearchRepository接口
 * 由于Item实体类中id为Long类型
 */
public interface ItemRepository extends ElasticsearchRepository<Item,Long> {
    /**
     * 方法名必须遵守SpringData的规范
     * 价格区间查询
     */
    List<Item> findByPriceBetween(double price1, double price2);
}

2.2、新增单条文档

添加单条文档数据使用的save()方法。

@Autowired
private ItemRepository itemRepository;
@Test
public void insert(){
    Item item = new Item(1L, "小米手机7", " 手机","小米", 3499.00, "http://image.leyou.com/13123.jpg");
    itemRepository.save(item);
}

2.3、插入多条文档

插入多条文档数据使用的saveAll()方法。

@Autowired
private ItemRepository itemRepository;
@Test
public void indexList() {
    List<Item> 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/13123.jpg"));
    list.add(new Item(3L, "华为META10", "手机", "华为", 4499.00, "http://image.leyou.com/13123.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);
}

2.4、修改文档

修改文档数据也是使用的save()方法。

@Autowired
private ItemRepository itemRepository;
@Test
public void update(){
    //Optional是java8新添加的类
    Optional<Item> itemOptional= itemRepository.findById(1L);
    Item item = itemOptional.get();
    item.setTitle("修改后的小米8");
    itemRepository.save(item);
}

2.5、基本简单查询

【代码例子】

/**
 * 查询全部，并安装价格降序排序
*/
@Test
public void testFind(){
    // Sort是包下的org.springframework.data类，Sort.Direction是个枚举类
    Iterable<Item> items = this.itemRepository.findAll(Sort.by(Sort.Direction.DESC, "price"));
    items.forEach(item-> System.err.println(item));
}

2.6、自定义方法查询

我们在DAO层的ItemRepository接口中自定义按照价格区间查询方法：

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {
    /**
     * 方法名必须遵守SpringData的规范
     * 价格区间查询
     */
    List<Item> findByPriceBetween(double price1, double price2);
}

【代码】

@Autowired
private ItemRepository itemRepository;
/**
 * 自定义方法findByPriceBetween查询范围
*/
@Test
public void queryByPriceBetween(){
    List<Item> items = itemRepository.findByPriceBetween(3500, 4500);
    items.stream().forEach(item -> {
        System.err.println("item:"+item);
    });
}