Elasticsearch入门之SpringBoot整合Elasticsearch

所以，我们只需要定义接口，然后继承它就 OK 了，是不是和 Spring Data JPA 类似

// 泛型的参数分别是实体类型和主键类型
public interface ItemRepository extends ElasticsearchRepository {
	
	// 自定义的方法
    List findByPriceBetween(double price1, double price2);

	// 自定义的方法
    List findByTitleLike(String keyword);
}

@Slf4j
@Service
public class ItemServiceImpl implements ItemService {

	@Autowired
	private ItemRepository itemRepository;

	@Override
	public void saveAll(List list) {
		itemRepository.saveAll(list);
	}

	@Override
	public List findAll() {
		List items = new ArrayList<>();
		Iterable itemIterable = itemRepository.findAll();
		itemIterable.forEach(cc -> log.info("--------" + cc + "--------"));
		itemIterable.forEach(items::add);
		return items;
	}

	// 根据价格区间查询
	@Override
	public List findByPriceBetween(double price1, double price2) {
		return itemRepository.findByPriceBetween(price1, price2);
	}

	// 根据标题(实体类中的字段)中的关键字查询
	@Override
	public List findByTitleLike(String keyword) {
		return itemRepository.findByTitleLike(keyword);
	}
}

@Controller
@RequestMapping(path = {"/es"})
public class EsController {

    @Autowired
    private ItemService itemService;

    @RequestMapping(path = {"/add"}, method = {RequestMethod.POST})
    @ResponseBody
    public ResponseMap add() {
        List list = new ArrayList<>();
        list.add(new Item(2L, "坚果手机R1", " 手机", "锤子", 3699.00, "http://image.baidu.com/13123.jpg"));
        list.add(new Item(3L, "华为meta10", " 手机", "华为", 4499.00, "http://image.baidu.com/13123.jpg"));
        try {
            itemService.saveAll(list);
            return new ResponseMap().success().message("添加数据成功");
        } catch (Exception e) {
            return new ResponseMap().error().message("添加数据失败");
        }
    }

    @RequestMapping(path = {"/selectAll"}, method = {RequestMethod.GET})
    @ResponseBody
    public ResponseMap selectAll() {
        List list = itemService.findAll();
        // 如果List集合不包含任何元素，返回true
        if (list.isEmpty()) {
            return new ResponseMap().error().message("查询数据失败");
        }
        return new ResponseMap().success().message("查询数据成功").data(list);
    }

    // 根据价格区间查询
    @RequestMapping(path = {"/selectByPrice"}, method = {RequestMethod.POST})
    @ResponseBody
    public ResponseMap selectByPrice(double price1, double price2) {
        List list = itemService.findByPriceBetween(price1, price2);
        if (list.isEmpty()) {
            return new ResponseMap().error().message("查询数据失败，可能没有你想要的数据");
        }
        return new ResponseMap().success().message("查询数据成功").data(list);
    }


    // 根据标题中(实体类中的字段)的关键字查询
    @RequestMapping(path = {"/customQuery"}, method = {RequestMethod.GET})
    @ResponseBody
    public ResponseMap customQuery(@RequestParam(name = "keyword") String keyword) {
        List list = itemService.findByTitleLike(keyword);
        if (list.isEmpty()) {
            return new ResponseMap().error().message("查询数据失败，可能没有你想要的数据");
        }
        return new ResponseMap().success().message("查询数据成功").data(list);
    }
}

自定义接口只要继承 ElasticsearchRepository 接口即可，默认会提供很多实现，比如 CRUD 和搜索相关的实现。类似于 Spring Data JPA 读取数据 方法名符合 Spring Data 规则

自定义接口中声明方法：无需实现类，Spring Data 会根据方法名，自动生成实现类，方法名必须符合下面的规则

表格内容摘自 Spring Data Elasticsearch 官网

public interface EmployeeInfoRepository extends ElasticsearchRepository {

    // 精确查找 方法名规则：finByxxx
    List findByName(String name);

    // AND 语句查询
    List findByNameAndAge(String name, Integer age);

    // OR 语句查询
    List findByNameOrAge(String name, Integer age);

    // 分页查询员工信息
    Page findByName(String name, Pageable page);

    // NOT 语句查询
    Page findByNameNot(String name, Pageable page);

    // LIKE 语句查询
    Page findByNameLike(String name, Pageable page);
}

matchQuery：词条匹配，先分词然后在调用termQuery进行匹配TermQuery：词条匹配，不分词wildcardQuery：通配符匹配fuzzyQuery：模糊匹配rangeQuery：范围匹配booleanQuery：布尔查询

自定义查询详情参考： https://blog.csdn.net/weixin_43814195/article/details/85281287

使用 postman 测试接口 http://localhost:8080/es/add，结果如下

elasticSearch-head 插件页面查询新增的数据，如下

使用 postman 测试接口 http://localhost:8080/es/selectAll，结果如下

使用 postman 测试接口 http://localhost:8080/es/selectByPrice，注意查看上述添加的两条数据的 price 字段，结果如下

根据文档对象 Item 中的 title 字段来查询，使用 postman 测试接口 http://localhost:8080/es/customQuery，结果如下

推荐参考：https://blog.csdn.net/weixin_43814195/article/details/85281287
推荐参考：https://blog.csdn.net/qq_38011415/article/details/112241548