devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

从零开始：SpringBoot整合ElasticSearch实现简单增删改查_springboot elasticsearch 增

作者：知新_RL | 2024-02-08 11:04:35

赞

踩

springboot elasticsearch 增

        新建springboot项目就不再赘述，相关教程非常多，很容查到。Elasticsearch在windows与linux环境下的安装与使用可以参考以下文章：

Linux/windows环境下后端基础服务（tomcat，MongoDB， docker， elasticsearch等）部署说明

Elasticsearch+Postman简单入门

Springboot集成ElasticSearch

1.引入相关依赖

        es版本以自己安装的版本为准

  1. <dependency>
  2.     <groupId>com.alibaba</groupId>
  3.     <artifactId>fastjson</artifactId>
  4.     <version>1.2.41</version>
  5. </dependency>
  6.  
  7. <dependency>
  8.     <groupId>org.elasticsearch.client</groupId>
  9.     <artifactId>elasticsearch-rest-high-level-client</artifactId>
  10.     <version>7.13.2</version>
  11. </dependency>

2.在application.properties文件中配置es连接

        可同时配置多个es连接

  1. server.port=9650
  2.  
  3. spring.servlet.multipart.enabled=false
  4. spring.servlet.multipart.file-size-threshold=0
  5. spring.servlet.multipart.max-file-size=1MB
  6. spring.servlet.multipart.max-request-size=10MB
  7.  
  8. elasticsearch.http.host=localhost
  9. elasticsearch.http.port=9200
  10. elasticsearch.user.index=user
  11. elasticsearch.user.type=userInfo

3.编写配置类

  1. package com.example.elasticsearchdemo.config;
  2.  
  3. import org.apache.http.HttpHost;
  4. import org.elasticsearch.client.RestClient;
  5. import org.elasticsearch.client.RestClientBuilder;
  6. import org.elasticsearch.client.RestHighLevelClient;
  7. import org.springframework.beans.factory.annotation.Value;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.Configuration;
  10.  
  11. @Configuration
  12. public class ElasticsearchConfig {
  13.  
  14.     @Value("${elasticsearch.http.host}")
  15.     private String esHost;
  16.     @Value("${elasticsearch.http.port}")
  17.     private int esPort;
  18.  
  19.     @Bean
  20.     public RestHighLevelClient esRestClient() {
  21.         RestClientBuilder builder = null;
  22.         builder = RestClient.builder(new HttpHost(esHost,esPort,"http"));
  23.         RestHighLevelClient restHighLevelClient = new RestHighLevelClient(builder);
  24.         return restHighLevelClient;
  25.     }
  26.  
  27. }

编写简单增删改查示例

1.用 postman 在es中设计并新建索引和映射

        具体方法可参考文章：

        Elasticsearch+Postman简单入门

        映射如下：

  1. {
  2.     "mappings": {
  3.         "userInfo": {
  4.             "properties": {
  5.                 "id": {
  6.                     "type": "text",
  7.                     "fields": {
  8.                         "keyword": {
  9.                             "type":"keyword",
  10.                             "ignore_above":256
  11.                         }
  12.                     }
  13.                 },
  14.                 "name": {
  15.                     "type": "text",
  16.                     "fields": {
  17.                         "keyword": {
  18.                             "type":"keyword",
  19.                             "ignore_above":256
  20.                         }
  21.                     }
  22.                 },
  23.                 "age": {
  24.                     "type": "integer",
  25.                     "fields": {
  26.                         "keyword": {
  27.                             "type":"keyword",
  28.                             "ignore_above":256
  29.                         }
  30.                     }
  31.                 },
  32.                 "sex": {
  33.                     "type": "text",
  34.                     "fields": {
  35.                         "keyword": {
  36.                             "type":"keyword",
  37.                             "ignore_above":256
  38.                         }
  39.                     }
  40.                 },
  41.                 "interest ": {
  42.                     "type": "text",
  43.                     "fielddata": true,
  44.                     "fields": {
  45.                         "keyword": {
  46.                             "type":"keyword",
  47.                             "ignore_above":256
  48.                         }
  49.                     }
  50.                 }
  51.             }
  52.         }
  53.     }
  54. }

2.在springboot中新建user类

        参考es映射新建对应的user类

  1. ackage com.example.elasticsearchdemo.bean;
  2.  
  3. import org.springframework.data.annotation.Id;
  4.  
  5. public class User {
  6.  
  7.     @Id
  8.     private String id;
  9.  
  10.     private String name;
  11.  
  12.     private Integer age;
  13.  
  14.     private String sex;
  15.  
  16.     private String interest;
  17.  
  18.     public String getId() {
  19.         return id;
  20.     }
  21.  
  22.     public void setId(String id) {
  23.         this.id = id;
  24.     }
  25.  
  26.     public String getName() {
  27.         return name;
  28.     }
  29.  
  30.     public void setName(String name) {
  31.         this.name = name;
  32.     }
  33.  
  34.     public Integer getAge() {
  35.         return age;
  36.     }
  37.  
  38.     public void setAge(Integer age) {
  39.         this.age = age;
  40.     }
  41.  
  42.     public String getSex() {
  43.         return sex;
  44.     }
  45.  
  46.     public void setSex(String sex) {
  47.         this.sex = sex;
  48.     }
  49.  
  50.     public String getInterest() {
  51.         return interest;
  52.     }
  53.  
  54.     public void setInterest(String interest) {
  55.         this.interest = interest;
  56.     }
  57.  
  58.     @Override
  59.     public String toString() {
  60.         return "User{" +
  61.                 "id='" + id + '\'' +
  62.                 ", name='" + name + '\'' +
  63.                 ", age=" + age +
  64.                 ", sex='" + sex + '\'' +
  65.                 ", interest='" + interest + '\'' +
  66.                 '}';
  67.     }
  68. }

3.实现简单增删改查

        注：若传入参数user对象包含id且es中已存在相同id，则更新替换；否则新建用户。条件查询中若传入map为空，则返回所有；否则执行多条件查询操作。

1）Controller层

  1. package com.example.elasticsearchdemo.controller;
  2.  
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.example.elasticsearchdemo.bean.User;
  5. import com.example.elasticsearchdemo.service.UserService;
  6. import org.springframework.web.bind.annotation.*;
  7.  
  8. import javax.annotation.Resource;
  9. import java.util.ArrayList;
  10. import java.util.List;
  11. import java.util.Map;
  12.  
  13. @RestController
  14. @RequestMapping("/user")
  15. @CrossOrigin(value = "*",  maxAge = 3600)
  16.  
  17. public class UserController {
  18.  
  19.     @Resource
  20.     private UserService service;
  21.  
  22.     /**新增与修改用户*/
  23.     @RequestMapping(value = "save", method = RequestMethod.POST)
  24.     public JSONObject saveUser(@RequestBody User user) {
  25.         JSONObject output = new JSONObject();
  26.         Map<String, Object> result = service.saveUser(user);
  27.         output.put("msg", result);
  28.         return output;
  29.     }
  30.  
  31.     /**删除用户*/
  32.     @RequestMapping(value = "delete/{id}", method = RequestMethod.DELETE)
  33.     public JSONObject deleteUser(@PathVariable("id") String id) {
  34.         JSONObject output = new JSONObject();
  35.         Map<String, Object> result = service.deleteUser(id);
  36.         output.put("msg", result);
  37.         return output;
  38.     }
  39.  
  40.  
  41.     /**条件查询*/
  42.     @RequestMapping(value = "get", method = RequestMethod.POST)
  43.     public JSONObject getUsers(@RequestBody Map<String,Object> maps) throws Exception{
  44.         JSONObject output = new JSONObject();
  45.         List result = new ArrayList();
  46.         if (maps != null) {
  47.             result = service.getUsers(maps);
  48.         } else {
  49.             result = service.getAllUsers();
  50.         }
  51.         output.put("data", result);
  52.         return output;
  53.     }
  54.  
  55. }

2）Service层

  1. package com.example.elasticsearchdemo.service;
  2.  
  3. import com.example.elasticsearchdemo.bean.User;
  4. import com.example.elasticsearchdemo.dao.common.UserEsDao;
  5. import org.springframework.stereotype.Service;
  6.  
  7. import javax.annotation.Resource;
  8. import java.util.List;
  9. import java.util.Map;
  10. import java.util.UUID;
  11.  
  12. @Service
  13. public class UserService {
  14.  
  15.     @Resource
  16.     private UserEsDao userEsDao;
  17.  
  18.     /**如果存在用户就修改，不存在就新增*/
  19.     public Map<String, Object> saveUser(User user) {
  20.         if (user.getId() == null) {
  21.             //生成唯一随机id
  22.             String id = UUID.randomUUID().toString().substring(24);
  23.             user.setId(id);
  24.         }
  25.         return userEsDao.saveUser(user);
  26.     }
  27.  
  28.     public Map<String,Object> deleteUser(String id) {
  29.         return userEsDao.deleteUser(id);
  30.     }
  31.  
  32.     public List getAllUsers() throws Exception{
  33.         return userEsDao.getUsers(null);
  34.     }
  35.  
  36.     public List getUsers(Map<String,Object> maps) throws Exception{
  37.         return userEsDao.getUsers(maps);
  38.     }
  39.  
  40. }

3）Dao层

  1. package com.example.elasticsearchdemo.dao.common;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.example.elasticsearchdemo.bean.User;
  6. import com.fasterxml.jackson.core.JsonProcessingException;
  7. import com.fasterxml.jackson.databind.ObjectMapper;
  8. import org.elasticsearch.action.bulk.BulkRequest;
  9. import org.elasticsearch.action.bulk.BulkResponse;
  10. import org.elasticsearch.action.delete.DeleteRequest;
  11. import org.elasticsearch.action.index.IndexRequest;
  12. import org.elasticsearch.action.search.SearchRequest;
  13. import org.elasticsearch.action.search.SearchResponse;
  14. import org.elasticsearch.client.RequestOptions;
  15. import org.elasticsearch.client.RestHighLevelClient;
  16. import org.elasticsearch.index.query.*;
  17. import org.elasticsearch.search.SearchHit;
  18. import org.elasticsearch.search.builder.SearchSourceBuilder;
  19. import org.elasticsearch.search.sort.SortOrder;
  20. import org.springframework.beans.factory.annotation.Autowired;
  21. import org.springframework.beans.factory.annotation.Value;
  22. import org.springframework.stereotype.Repository;
  23.  
  24. import java.io.IOException;
  25. import java.util.*;
  26.  
  27. @Repository
  28. public class UserEsDao {
  29.  
  30.     @Autowired
  31.     private RestHighLevelClient client;
  32.     @Value("${elasticsearch.user.index}")
  33.     private String userIndex;
  34.     @Value("${elasticsearch.user.type}")
  35.     private String userType;
  36.  
  37.  
  38.     /**
  39.      * 往es中插入新数据
  40.      */
  41.     public Map<String, Object> saveUser(User user){
  42.         Map<String,Object> ret = new HashMap<>();
  43.  
  44.         Map map = null;
  45.         try{
  46.             //实体转换成map以请求es
  47.             map = JSON.parseObject(JSON.toJSONString(user), Map.class);
  48.         }catch (Exception e){
  49.             e.printStackTrace();
  50.         }
  51.  
  52.         BulkRequest bulkRequest = new BulkRequest();
  53.         //IndexRequest构造函数第三个参数指定id
  54.         bulkRequest.add(new IndexRequest(userIndex,userType,user.getId()).source(map));
  55.         try{
  56.             BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
  57.             ret.put("msg",bulkResponse);
  58.             return ret;
  59.         }catch (IOException e){
  60.             ret.put("msg",e.getStackTrace());
  61.             e.printStackTrace();
  62.         }
  63.         return ret;
  64.     }
  65.  
  66.     /**
  67.      * 从es中删除一条数据
  68.      */
  69.     public Map<String,Object> deleteUser(String id){
  70.         Map<String,Object> ret = new HashMap<>();
  71.         BulkRequest request = new BulkRequest();
  72.         request.add(new DeleteRequest(userIndex,userType,id));
  73.         try {
  74.             BulkResponse bulkResponse = client.bulk(request, RequestOptions.DEFAULT);
  75.             ret.put("msg",bulkResponse);
  76.             return ret;
  77.         }catch (IOException e){
  78.             ret.put("msg",e.getStackTrace());
  79.             e.printStackTrace();
  80.         }
  81.         return ret;
  82.  
  83.     }
  84.  
  85.     /**
  86.      * 条件查询
  87.      */
  88.     public List getUsers(Map<String,Object> maps) throws IOException {
  89.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  90.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  91.         //判断是否是条件查询
  92.         if (maps != null) {
  93.             Set<String> keys = maps.keySet();
  94.             for (String key: keys) {
  95.                 boolQueryBuilder.must(QueryBuilders.matchPhraseQuery(key, maps.get(key)));
  96.             }
  97.         } else {
  98.             MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery();
  99.             boolQueryBuilder.should(matchAllQueryBuilder);
  100.         }
  101.         searchSourceBuilder.query(boolQueryBuilder).size(10).from(0).sort("age", SortOrder.DESC);//分页以及排序
  102.         SearchRequest searchRequest = new SearchRequest();
  103.         searchRequest.indices(userIndex);
  104.         searchRequest.types(userType);
  105.         searchRequest.source(searchSourceBuilder);
  106.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  107.         List list = new ArrayList();
  108.         for (SearchHit hit: searchResponse.getHits()) {
  109.             String s = JSON.toJSONString(hit);
  110.             JSONObject o = JSON.parseObject(s);
  111.             list.add(o.getJSONObject("sourceAsMap"));
  112.         }
  113.         return list;
  114.     }
  115.  
  116. }

后续会更新springboot+elasticsearch空间检索示例。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/68726
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号