0
0

通过Spring Data Elasticsearch操作ES

Elasticsearch

  1.     Elasticsearch (ES)是一个基于Lucene构建的开源、分布式、RESTful 接口全文搜索引擎。Elasticsearch 还是一个分布式文档数据库，其中每个字段均是被索引的数据且可被搜索，它能够扩展至数以百计的服务器存储以及处理PB级的数据。它可以在很短的时间内在存储、搜索和分析大量的数据。它通常作为具有复杂搜索场景情况下的核心发动机。**es是由java语言编写的**。
  3.     Elasticsearch就是为高可用和可扩展而生的。可以通过购置性能更强的服务器来完成。

官网

Elasticsearch：官方分布式搜索和分析引擎 | Elastichttps://www.elastic.co/cn/elasticsearch/

Spring Data

  1.     Spring Data是Spring 的一个子项目。用于简化数据库访问，支持NoSQL和关系数据库存储。其主要目标是使数据库的访问变得方便快捷。

官网

Spring DataLevel up your Java code and explore what Spring can do for you.https://spring.io/projects/spring-data

Spring Data ElasticSearch

  1.     Spring Data ElasticSearch 基于 spring data API 简化 elasticSearch操作，将原始操作elasticSearch的客户端API进行封装。Spring Data为Elasticsearch项目提供集成搜索引擎。Spring Data Elasticsearch POJO的关键功能区域为中心的模型与Elastichsearch交互文档和轻松地编写一个存储库数据访问层。

官网

Spring Data Elasticsearchhttps://spring.io/projects/spring-data-elasticsearch

代码

  1.     创建maven项目，并引入依赖
  1.     <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>2.3.6.RELEASE</version>
  5.         <relativePath/>
  6.     </parent>
  8.  <dependencies>
  9.         <dependency>
  10.             <groupId>org.projectlombok</groupId>
  11.             <artifactId>lombok</artifactId>
  12.         </dependency>
  13.         <dependency>
  14.             <groupId>org.springframework.boot</groupId>
  15.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  16.         </dependency>
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-devtools</artifactId>
  20.             <scope>runtime</scope>
  21.             <optional>true</optional>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-test</artifactId>
  26.             <scope>test</scope>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-test</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>junit</groupId>
  34.             <artifactId>junit</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework</groupId>
  38.             <artifactId>spring-test</artifactId>
  39.         </dependency>
  40.     </dependencies>

在resources文件夹下创建application.properties文件

application.properties内容如下

  1. # es 服务地址
  2. elasticsearch.host=部署es服务器的ip
  3. # es 服务端口
  4. elasticsearch.port=9200
  5. # 配置日志级别,开启 debug 日志
  6. logging.level.com.es=debug

创建MainApplication

  1. package com.es;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. @SpringBootApplication
  6. public class MainApplication {
  7.     public static void main(String[] args) {
  8.         SpringApplication.run(MainApplication.class, args);
  9.     }
  10. }

创建ElasticSearch配置文件ElasticsearchConfig

  1. package com.es.config;
  3. import lombok.Data;
  4. import org.apache.http.HttpHost;
  5. import org.elasticsearch.client.RestClient;
  6. import org.elasticsearch.client.RestClientBuilder;
  7. import org.elasticsearch.client.RestHighLevelClient;
  8. import org.springframework.boot.context.properties.ConfigurationProperties;
  9. import org.springframework.context.annotation.Configuration;
  10. import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
  12. @ConfigurationProperties(prefix = "elasticsearch")
  13. @Configuration
  14. @Data
  15. public class ElasticsearchConfig  extends AbstractElasticsearchConfiguration {
  17.     private String host ;
  18.     private Integer port ;
  20.     @Override
  21.     public RestHighLevelClient elasticsearchClient() {
  22.         RestClientBuilder builder = RestClient.builder(new HttpHost(host, port));
  23.         RestHighLevelClient restHighLevelClient = new
  24.                 RestHighLevelClient(builder);
  25.         return restHighLevelClient;
  26.     }
  27. }

创建实体类Person

  1. package com.es.DO;
  2. import lombok.Data;
  3. import org.springframework.data.annotation.Id;
  4. import org.springframework.data.elasticsearch.annotations.Document;
  5. import org.springframework.data.elasticsearch.annotations.Field;
  6. import org.springframework.data.elasticsearch.annotations.FieldType;
  8. @Data
  9. @Document(indexName = "contact", shards = 3, replicas = 1)
  10. public class Person {
  12.     /**
  13.      * 主键 id
  14.      */
  15.     @Id
  16.     public Long id;
  18.     /**
  19.      * 姓名 name
  20.      */
  21.     @Field(type = FieldType.Text, analyzer = "ik_max_word")
  22.     public String name;
  24.     /**
  25.      * 年龄 age
  26.      */
  27.     @Field(type = FieldType.Integer)
  28.     public int age;
  30.     /**
  31.      * 地址 address
  32.      */
  33.     @Field(type = FieldType.Keyword, index = false)
  34.     public String address;
  35. }

配置Person的Dao类，PersonDao

  1. package com.es.dao;
  3. import com.es.DO.Person;
  4. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
  5. import org.springframework.stereotype.Repository;
  7. @Repository
  8. public interface PersonDao extends ElasticsearchRepository<Person, Long>{
  10. }

创建测试类SpringDataESIndexTest，测试类跟启动类在同一个包下，不然启动会报错。

  1. package com.es.test;
  3. import com.es.DO.Person;
  4. import org.junit.Test;
  5. import org.junit.runner.RunWith;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.test.context.SpringBootTest;
  8. import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
  9. import org.springframework.test.context.junit4.SpringRunner;
  11. @RunWith(SpringRunner.class)
  12. @SpringBootTest
  13. public class SpringDataESIndexTest {
  15.     //注入 ElasticsearchRestTemplate
  16.     @Autowired
  17.     private ElasticsearchRestTemplate elasticsearchRestTemplate;
  19.     //创建索引并增加映射配置
  20.     @Test
  21.     public void createIndex(){
  22.         //创建索引，系统初始化会自动创建索引
  23.         System.out.println("创建索引");
  24.     }
  26.     @Test
  27.     public void deleteIndex(){
  28.         //创建索引，系统初始化会自动创建索引
  29.         boolean flg = elasticsearchRestTemplate.deleteIndex(Person.class);
  30.         System.out.println("删除索引 = " + flg);
  31.     }
  32. }

测试

  1.     对索引创建及删除进行测试
  3.     http://IP地址:9200/_cat/indices?v，用浏览器或Postman等工具访问该地址来看结果
  5.     运行createIndex测试方法

  1.      运行deleteIndex测试方法

文档操作

  1.      新加SpringDataESPersonDaoTest测试类

新增

  1.     @Autowired
  2.     private PersonDao personDao;
  3.     /**
  4.      * 新增
  5.      */
  6.     @Test
  7.     public void save(){
  8.         Person person = new Person();
  9.         person.setId(1L);
  10.         person.setName("张三");
  11.         person.setAge(21);
  12.         person.setAddress("北京市海淀区");
  13.         personDao.save(person);
  14.     }

测试地址：http://IP地址:9200/contact/_doc/1

修改

  1.     @Autowired
  2.     private PersonDao personDao;
  4.     //修改
  5.     @Test
  6.     public void update(){
  7.         Person person = new Person();
  8.         person.setId(1L);
  9.         person.setName("张三");
  10.         person.setAge(21);
  11.         person.setAddress("北京市朝阳区");
  12.         personDao.save(person);
  13.     }

测试地址：http://IP地址:9200/contact/_doc/1

根据 id 查询

  1.     @Autowired
  2.     private PersonDao personDao;    
  3.     
  4.     //根据 id 查询
  5.     @Test
  6.     public void findById(){
  7.         Person person = personDao.findById(1L).get();
  8.         System.out.println(person);
  9.     }

打印成功

打印所有

  1.     @Autowired
  2.     private PersonDao personDao;
  4.     @Test
  5.     public void findAll(){
  6.         Iterable<Person> persons = personDao.findAll();
  7.         for (Person person : persons) {
  8.             System.out.println(person);
  9.         }
  10.     }

删除

  1.     @Autowired
  2.     private PersonDao personDao;
  3.     
  4.     @Test
  5.     public void delete(){
  6.         Person person = new Person();
  7.         person.setId(1L);
  8.         personDao.delete(person);
  9.     }

测试地址：http://IP地址:9200/contact/_doc/1

已删除

批量新增

  1.     @Autowired
  2.     private PersonDao personDao;
  4.     //批量新增
  5.     @Test
  6.     public void saveAll(){
  7.         List<Person> personList = new ArrayList<>();
  8.         for (int i = 0; i < 10; i++) {
  9.             Person person = new Person();
  10.             person.setId(Long.valueOf(i));
  11.             person.setName("["+i+"]张三");
  12.             person.setAge(21+i);
  13.             person.setAddress("北京市海淀区");
  14.             personList.add(person);
  15.         }
  16.         personDao.saveAll(personList);
  17.     }

测试地址：http://ip地址:9200/contact/_search

分页查询

  1.     @Autowired
  2.     private PersonDao personDao;
  3.     
  4.     @Test
  5.     public void findByPageable(){
  6.         //设置排序(排序方式，正序还是倒序，排序的 id)
  7.         Sort sort = Sort.by(Sort.Direction.DESC,"id");
  8.         int currentPage=0;//当前页，第一页从 0 开始， 1 表示第二页
  9.         int pageSize = 5;//每页显示多少条
  10.         //设置查询分页
  11.         PageRequest pageRequest = PageRequest.of(currentPage, pageSize,sort);
  12.         //分页查询
  13.         Page<Person> personPage = personDao.findAll(pageRequest);
  14.         for (Person person : personPage.getContent()) {
  15.             System.out.println(person);
  16.         }
  17.     }

查询成功，查出第一页

完整代码如下

  1. package com.es.test;
  3. import com.es.DO.Person;
  4. import com.es.dao.PersonDao;
  5. import org.junit.Test;
  6. import org.junit.runner.RunWith;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.boot.test.context.SpringBootTest;
  9. import org.springframework.data.domain.Page;
  10. import org.springframework.data.domain.PageRequest;
  11. import org.springframework.data.domain.Sort;
  12. import org.springframework.test.context.junit4.SpringRunner;
  13. import java.util.ArrayList;
  14. import java.util.List;
  16. @RunWith(SpringRunner.class)
  17. @SpringBootTest
  18. public class SpringDataESPersonDaoTest {
  19.     @Autowired
  20.     private PersonDao personDao;
  21.     /**
  22.      * 新增
  23.      */
  24.     @Test
  25.     public void save(){
  26.         Person person = new Person();
  27.         person.setId(1L);
  28.         person.setName("张三");
  29.         person.setAge(21);
  30.         person.setAddress("北京市海淀区");
  31.         personDao.save(person);
  32.     }
  33.     //POSTMAN, GET http://IP地址:9200/contact/_doc/1
  35.     //修改
  36.     @Test
  37.     public void update(){
  38.         Person person = new Person();
  39.         person.setId(1L);
  40.         person.setName("张三");
  41.         person.setAge(21);
  42.         person.setAddress("北京市朝阳区");
  43.         personDao.save(person);
  44.     }
  45.     //POSTMAN, GET http://IP地址:9200/contact/_doc/1
  47.     //根据 id 查询
  48.     @Test
  49.     public void findById(){
  50.         Person person = personDao.findById(1L).get();
  51.         System.out.println(person);
  52.     }
  54.     @Test
  55.     public void findAll(){
  56.         Iterable<Person> persons = personDao.findAll();
  57.         for (Person person : persons) {
  58.             System.out.println(person);
  59.         }
  60.     }
  62.     //删除
  63.     @Test
  64.     public void delete(){
  65.         Person person = new Person();
  66.         person.setId(1L);
  67.         personDao.delete(person);
  68.     }
  69.     //POSTMAN, GET http://IP地址:9200/contact/_doc/1
  71.     //批量新增
  72.     @Test
  73.     public void saveAll(){
  74.         List<Person> personList = new ArrayList<>();
  75.         for (int i = 0; i < 10; i++) {
  76.             Person person = new Person();
  77.             person.setId(Long.valueOf(i));
  78.             person.setName("["+i+"]张三");
  79.             person.setAge(21+i);
  80.             person.setAddress("北京市海淀区");
  81.             personList.add(person);
  82.         }
  83.         personDao.saveAll(personList);
  84.     }
  86.     //分页查询
  87.     @Test
  88.     public void findByPageable(){
  89.         //设置排序(排序方式，正序还是倒序，排序的 id)
  90.         Sort sort = Sort.by(Sort.Direction.DESC,"id");
  91.         int currentPage=0;//当前页，第一页从 0 开始， 1 表示第二页
  92.         int pageSize = 5;//每页显示多少条
  93.         //设置查询分页
  94.         PageRequest pageRequest = PageRequest.of(currentPage, pageSize,sort);
  95.         //分页查询
  96.         Page<Person> personPage = personDao.findAll(pageRequest);
  97.         for (Person person : personPage.getContent()) {
  98.             System.out.println(person);
  99.         }
  100.     }
  101. }

文档搜索

  1.     新建测试类SpringDataESSearchTest

termQuery

  1.     @Autowired
  2.     private PersonDao personDao;
  3.     /**
  4.      * term 查询
  5.      * search(termQueryBuilder) 调用搜索方法，参数查询构建器对象
  6.      */
  7.     @Test
  8.     public void termQuery(){
  9.         TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "[8]张三");
  10.         Iterable<Person> persons = personDao.search(termQueryBuilder);
  11.         for (Person person : persons) {
  12.             System.out.println(person);
  13.         }
  14.     }

termQuery加分页

  1.     @Autowired
  2.     private PersonDao personDao;    
  3.     /**
  4.      * term 查询加分页
  5.      */
  6.     @Test
  7.     public void termQueryByPage(){
  8.         int currentPage= 0 ;
  9.         int pageSize = 5;
  10.         //设置查询分页
  11.         PageRequest pageRequest = PageRequest.of(currentPage, pageSize);
  12.         TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "[8]张三");
  13.         Iterable<Person> persons =
  14.                 personDao.search(termQueryBuilder,pageRequest);
  15.         for (Person person : persons) {
  16.             System.out.println(person);
  17.         }
  18.     }

只有一条name为[8]张三的记录

完整代码如下

  1. package com.es.test;
  3. import com.es.DO.Person;
  4. import com.es.dao.PersonDao;
  5. import org.elasticsearch.index.query.QueryBuilders;
  6. import org.elasticsearch.index.query.TermQueryBuilder;
  7. import org.junit.Test;
  8. import org.junit.runner.RunWith;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.boot.test.context.SpringBootTest;
  11. import org.springframework.data.domain.PageRequest;
  12. import org.springframework.test.context.junit4.SpringRunner;
  14. @RunWith(SpringRunner.class)
  15. @SpringBootTest
  16. public class SpringDataESSearchTest {
  18.     @Autowired
  19.     private PersonDao personDao;
  20.     /**
  21.      * term 查询
  22.      * search(termQueryBuilder) 调用搜索方法，参数查询构建器对象
  23.      */
  24.     @Test
  25.     public void termQuery(){
  26.         TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "[8]张三");
  27.         Iterable<Person> persons = personDao.search(termQueryBuilder);
  28.         for (Person person : persons) {
  29.             System.out.println(person);
  30.         }
  31.     }
  32.     /**
  33.      * term 查询加分页
  34.      */
  35.     @Test
  36.     public void termQueryByPage(){
  37.         int currentPage= 0 ;
  38.         int pageSize = 5;
  39.         //设置查询分页
  40.         PageRequest pageRequest = PageRequest.of(currentPage, pageSize);
  41.         TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "[8]张三");
  42.         Iterable<Person> persons =
  43.                 personDao.search(termQueryBuilder,pageRequest);
  44.         for (Person person : persons) {
  45.             System.out.println(person);
  46.         }
  47.     }
  49. }
标签： elasticsearch Java SpringBoot
本文转载自: https://blog.csdn.net/zhiwenganyong/article/details/122764105
版权归原作者 像向日葵一样~ 所有， 如有侵权，请联系我们删除。
登录后发布评论

“通过Spring Data Elasticsearch操作ES”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？