springboot整合elasticsearch实现增删改查，elasticsearch学习二

亦凉 2021-05-05 03:18 559阅读 0赞

Elasticsearch Java API 大致分如下四类：

*  TransportClient
 *  RestClient
 *  Jest
 *  Spring Data Elasticsearch  
    笔者在本篇中主要会和大家讲Spring Data，因为使用springdata jpa操作比较方便简单

## 1.创建springboot工程，引入es和lombok的maven依赖，添加yml配置 ##

<dependency>
       <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
    
     <dependency>
       <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>

spring
      #------------------------ elasticsearch -----------------------------
      main:
        allow-bean-definition-overriding: true
      data:
        elasticsearch:
          repositories:
            enabled: true
          cluster-name: elasticsearch
          cluster-nodes: 127.0.0.1:9300

## 2,创建es的索引库 ##

1.可以通过postman或者head插件来创建索引库，笔者使用的是es6.2.4  
以下介绍使用postman创建es索引库，put请求，url：http://localhost:9200/test-search  
像mysql一样描述的话，就是创建一个名字叫做test-search的数据库，然后一个叫article的数据表，  
有三个字段，id long类型，title text类型 使用ik分词搜索，content text类型，使用ik分词搜索

{ 
      "settings": { 
        "index.number_of_shards": 1,
        "index.number_of_replicas": 0,
        "index.refresh_interval": "-1"
      },
      "mappings": { 
        "article": { 
          "properties": { 
            "id": { 
              "type": "long",
              "index": false
            },
            "title": { 
              "type": "text",
              "analyzer": "ik_max_word",
              "search_analyzer": "ik_max_word"
            },
            "content": { 
              "type": "text",
              "analyzer": "ik_max_word",
              "search_analyzer": "ik_max_word",
              "boost": 1.5
            }
          }
        }
      }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70]  
索引库创建成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 1]

## 3，回到springboot的工程，开始写代码 ##

1.创建一个叫article的实体类,其中的注解代表的含义分别是：

*  @Document: 代表一个文档记录 ，indexName: 用来指定索引名称， type: 用来指定索引类型
 *  @Id: 用来将对象中id和ES中\_id映射
 *  @Field: 用来指定ES中的字段对应Mapping，其中的type: 用来指定ES中存储类型，analyzer: 用来指定使用哪种分词器

@Data
    @Document(indexName = "test-search",type = "article",shards = 1,replicas = 0, refreshInterval = "-1")
    public class Article implements Serializable { 
    	@Id
        private Long id;
        
    	@Field(type = FieldType.Text,analyzer = "ik_max_word", searchAnalyzer = "ik_max_word")
        private String title; //标题
        
    	@Field(type = FieldType.Text,analyzer = "ik_max_word", searchAnalyzer = "ik_max_word")
        private String content;// 缩略内容
        
    }

2.dao层，创建一个ArticleRepository的接口，继承ElasticsearchRepository

public interface ArticleRepository extends ElasticsearchRepository<Article,Long> { 
        /** * 使用jpa的一个好处就是你想联合title和content去搜索，它就会有方法出现，使用pageable分页 * @param title * @param content * @param pageable * @return */
        Page<Article> findByTitleLikeOrContentLike(String title, String content, Pageable pageable);
    
        /** * 根据article的content内容去搜索，使用pageable份额有 * @param content * @param pageable * @return */
        Page<Article> findByContentLike(String content, Pageable pageable);
    }

3.service层，

@Service
    public class ArticleService { 
        @Autowired
        private ArticleRepository articleRepository;
    
        public void save(Article article){ 
            articleRepository.save(article);
        }
    
        public Page<Article> search(String title, String content, Pageable pageable){ 
            return articleRepository.findByTitleLikeOrContentLike(title,content,pageable);
        }
    
        public Page<Article> search(String content,Pageable pageable){ 
            return articleRepository.findByContentLike(content,pageable);
        }
        public Page<Article> findAll(Pageable pageable){ 
            return articleRepository.findAll(pageable);
        }
    }

4，controller

@RestController
    public class ArticleController { 
        @Autowired
        private ArticleRepository articleRepository;
    
        @Autowired
        private ArticleService articleService;
    	
    	//可以插入单条也可以多条
        @RequestMapping("/articleSave")
        public String save(){ 
        List<Article> articles = new ArrayList<>();
        articles.add(new Article(System.currentTimeMillis(),"小米",
                "小米手机"));
        articles.add(new Article(System.currentTimeMillis(),"华为",
                "华为手机"));
    
        for(int i=0; i<articles.size(); i++){ 
            articleRepository.save(articles.get(i));
            System.out.println(articles.get(i));
        }
        return "success";
        }
    
        @RequestMapping("/search")
        public String search(HttpServletRequest request){ 
            int pageNum = 0;
            int pageSize = 10;
            String title = request.getParameter("title");
            String content = request.getParameter("content");
            Pageable pageable = PageRequest.of(pageNum,pageSize);
            Page<Article> articles = articleService.search(title,content,pageable);
            return articles.toString();
        }
    }

## 5.其实只要集成了jpa他的增删改查就会变得特别简单，只要一点就会有提示 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 2]

## 我们可以试着删除一下1001 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 4]  
然后1001就被删除了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 5]

## 然后我们测试一下搜索 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][20200423150309488.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70]: /images/20210505/6692a604eef04ad98d74ab928ae8d7c2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 1]: /images/20210505/1859270c045f4e4891fd23fbb21a4c96.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 2]: /images/20210505/f9472553b3f149f0ba21ad2a70288668.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 3]: /images/20210505/c6faf1edb62244b78f68c51f36ba951b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 4]: /images/20210505/7e11baaa91034c1cbd922d27a7e66576.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 5]: /images/20210505/12bcbf7093ce46b1a077e854363c47a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70 6]: /images/20210505/d9f643b43d4a4333bcd023c132b4651e.png
[20200423150309488.png]: /images/20210505/eb72260fe92c4b03b00e3483fccecd73.png