JavaEE：SpringBoot集成Elasticsearch搜索

前提：

配置SpringBoot，见此地址：
https://blog.csdn.net/a526001650a/article/details/106687559

安装Elasticsearch服务器并启动，见此地址：
https://blog.csdn.net/a526001650a/article/details/107235178

一、配置Elasticsearch：

1.导入Elasticsearch依赖包，在工程/pom.xml中：

<dependencies>
    <!-- 导入elasticsearch搜索引擎依赖 -->
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-elasticsearch</artifactId>
        <version>4.0.1.RELEASE</version>
    </dependency>
</dependencies>

2.配置Elasticsearch服务器地址与端口(在工程/src/main/resources/application.yml中)：

server:
  port: 10004

spring:
  application:
    name: mall-search
  data: #配置elasticsearch服务器地址与端口
    elasticsearch:
      cluster-nodes: 127.0.0.1:9300

二、操作索引库的数据：

1.创建实体类映射到索引库：

//与索引库文档相映射的实体类
@Document(indexName = "mall", type = "user") //indexName为索引库名，type为文档名
public class User {
    @Id
    private String id;
    //默认，index表示是否要索引，analyzer配置存储时分司方式，searchAnalyzer配置查询时分词方式
    @Field(index = true, searchAnalyzer = "ik_smart", analyzer = "ik_smart")
    private String name;
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

2.增删改查业务接口，需要继承ElasticsearchRepository接口：

//索引库增删改查操作接口，需要继承ElasticsearchRepository
public interface UserDao extends ElasticsearchRepository<User, String> { //类似Spring Data JPA
}

3.业务类中增删改查方法：

@Service
public class UserBiz {
    @Autowired //自动创建索引库Dao实现类
    private UserDao userDao;
    //插入
    public void insert(User user) {
        userDao.save(user);
    }
    //更新
    public void update(User user) {
        userDao.save(user);
    }
    // 根据ID查
    public User findById(String id) {
        return userDao.findById(id).get();
    }
    //查全部
    public List<User> findAll(int pageIndex, int pageSize) {
        Pageable pageable = PageRequest.of(pageIndex, pageSize);  //创建分页参数对象
        return userDao.findAll(pageable).toList(); //分页获取列表
    }
    // 模糊匹配
    public List<User> search(String key) {
        WildcardQueryBuilder queryBuilder = QueryBuilders.wildcardQuery("name", "*" + key + "*");//搜索name中含有key的记录
        Pageable pageable = PageRequest.of(0, 20);  //创建分页条件
        return userDao.search(queryBuilder, pageable).toList();
    }
    //删除
    public void delete(String id) {
        userDao.deleteById(id);
    }
}

4.测试效果：

@Controller
public class UserController {
    @Autowired //自动创建Dao实现类
    private UserBiz userBiz;

    @RequestMapping("/insert")
    @ResponseBody
    public String insert() {
        User user = new User();
        user.setName("杨行生2");
        userBiz.insert(user);
        return "插入成功";
    }
    @RequestMapping("/update")
    @ResponseBody
    public String update() {
        User user = new User();
        user.setId("8fmKM3MB_eVRoZWmJuBe");
        user.setName("杨先生3");
        userBiz.update(user);
        return "更新成功";
    }
    @RequestMapping("/findById")
    @ResponseBody
    public User findById() {
        return userBiz.findById("8fmKM3MB_eVRoZWmJuBe");
    }
    @RequestMapping("/findAll")
    @ResponseBody
    public List<User> findAll() {
        return userBiz.findAll(0, 20);
    }
    @RequestMapping("/search")
    @ResponseBody
    public List<User> search() {
        return userBiz.search("先");
    }
    @RequestMapping("/delete")
    @ResponseBody
    public String delete() {
        userBiz.delete("8fmKM3MB_eVRoZWmJuBe");
        return "删除成功";
    }
}

 

本文地址：https://blog.csdn.net/a526001650a/article/details/107243495