【ElasticSearch】JavaRestClient实现索引库和文档的增删改查

川长思鸟来 2023-10-13 11:22 8阅读 0赞

#### 文章目录 ####

*  一、RestClient
 *   *  1、什么是RestClient
     *  2、导入demo工程
     *  3、数据结构分析与索引库创建
     *  4、初始化JavaRestClient
 *  二、RestClient操作索引库
 *   *  1、创建索引库
     *  2、删除索引库
     *  3、判断索引库是否存在
 *  三、RestClient操作文档
 *   *  1、新增文档
     *  2、查询文档
     *  3、修改文档
     *  4、删除文档
     *  5、批量导入文档

## 一、RestClient ##

### 1、什么是RestClient ###

ES官方提供了各种不同语言的客户端，用来操作ES，即RestClient。这些客户端的本质就是组装DSL语句，通过http请求发送给ES。

官方文档地址：
    https://www.elastic.co/guide/en/elasticsearch/client/index.html

![在这里插入图片描述][d208fda73bd24766b43417059be76a02.png]  
![在这里插入图片描述][5e2d563e242e43a58ac5ddd2e2cb0f3d.png]

### 2、导入demo工程 ###

数据库信息如下：

mysql -h localhost -P3306 -uroot -padmian123 testDB < tb_hotel.sql

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

导入demo工程，基本结构如下：

![在这里插入图片描述][58f4fad95a18401f9b2206978939f43d.png]

### 3、数据结构分析与索引库创建 ###

ES的mapping要考虑的点主要有：

*  字段名（name）
 *  字段类型（type）
 *  是否参与搜索（index）
 *  是否分词（type/keyword）
 *  分词时，分词器用哪种（analyzer）

接下来，照着表结构，创建ES索引库：

![在这里插入图片描述][486062b5973947be988bc9a354921908.png]

PUT /hotel
    {
        
      "mappings": {
        
        "properties":{
        
          "id":{
        
            "type": "keyword"  //注意这个类型
          },
          "name":{
        
            "type": "text",
            "analyzer": "ik_max_word",
            "copy_to": "all"
          },
          "address":{
        
            "type": "keyword", 
            "index": false   //根据业务场景，用户刚来，不会去搜地址address，不参与搜索，index改为false，不再默认，类型选用keyword
          },
          "price":{
        
            "type": "integer"
          },
          "score":{
           //price、score等将来要参与过滤和排序，需要index，用默认的true
            "type": "integer"
          },
          "brand":{
          //city、brand品牌参与搜索，且不分词
            "type":"keyword",
            "copy_to": "all"
          },
          "city":{
        
            "type":"keyword"
          },
          "starName":{
          //不用下划线
            "type":"keyword"
          },
          "business":{
        
            "type": "keyword",
            "copy_to": "all"
          },
          "location":{
        
            "type":"geo_point"   //经纬度两个字段合并为location，用ES的特定类型geo_point
          },
          "pic":{
        
            "type": "keyword",
            "index": false  //pic既不分词，也不搜索
          },
          "all":{
          //copy_to用的
            "type":"text",
            "analyzer": "ik_max_word"
          }
        }
      }
    }

用户就输入一个虹桥，我既想返回地址带虹桥的，也想返回商圈在虹桥的，还想返回酒店名称带虹桥的，如何实现？

> 加all字段，给需要的字段里加上从copy\_to，这样all字段就可以代表这些加了copy\_to的字段。`实现了在一个字段里搜到多个字段的内容。`

![在这里插入图片描述][6b781b7db4584edc91568b19f958c32a.png]  
![在这里插入图片描述][a0b5f97ed06245df84be3c069ba68077.png]

### 4、初始化JavaRestClient ###

*  引入es的RestHighLevelClient依赖

<dependency>   
    	<groupId>org.elasticsearch.client</groupId>    
    	<artifactId>elasticsearch-rest-high-level-client</artifactId>
    </dependency>

*  因为SpringBoot下默认的ES版本是7.6.2，所以我们需要定义properties覆盖默认的ES版本

*  初始化RestHighLevelClient

RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(       
    			HttpHost.create("http://10.4.130.110:9200"),
    			HttpHost.create("http://10.4.130.111:9200"),
    			HttpHost.create("http://10.4.130.112:9200")  //集群模式写多个
    ));

在单元测试里看下效果，打印restHighLevelClient对象：  
![在这里插入图片描述][9c6d20b05947436ea6e23791afa621e4.png]  
![在这里插入图片描述][60e43fed5116494881e38a1ce584004e.png]

## 二、RestClient操作索引库 ##

### 1、创建索引库 ###

示例代码：

@Test
    void testCreateHotelIndex() throws IOException {
            
    	// 1.创建Request对象    
    	CreateIndexRequest request = new CreateIndexRequest("hotel");    
    	// 2.请求参数，MAPPING_TEMPLATE是静态常量字符串，内容是创建索引库的DSL语句    
    	request.source(MAPPING_TEMPLATE, XContentType.JSON);    
    	// 3.发起请求    
    	client.indices().create(request, RequestOptions.DEFAULT);
    }

![在这里插入图片描述][f087a8e7d6fc406aa536f09ddc3e33e8.png]  
将创建索引库的DSL语句以静态字符串常量的形式统一写在常量类里：

![在这里插入图片描述][75bc8a23445f460eaaeb32182f9c8b7d.png]  
运行完成后，查看ES索引库：

GET /hotel

![在这里插入图片描述][298eb8eae5e44a13b744ac1cc8b2b32c.png]

整个过程，和我们去Kiana手动执行DSL对比：

![在这里插入图片描述][82dda2f06ead40a0a8f125eb1a40f73f.png]

### 2、删除索引库 ###

示例代码：

@Test
    void testDeleteHotelIndex() throws IOException {
          
    	// 1.创建Request对象     
    	DeleteIndexRequest request = new DeleteIndexRequest("hotel");    
    	// 2.发起请求    
    	client.indices().delete(request, RequestOptions.DEFAULT);
    }

### 3、判断索引库是否存在 ###

示例代码：

@Test
    void testExistsHotelIndex() throws IOException {
        
        // 1.创建Request对象    
        GetIndexRequest request = new GetIndexRequest("hotel");    
        // 2.发起请求     
        boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);    
        // 3.输出    
        System.out.println(exists);
    }

![在这里插入图片描述][0d232692c7b548b397cd5650dc34c324.png]

小结：

![在这里插入图片描述][b8bdb15dd86e44458d954ec03737733a.png]

## 三、RestClient操作文档 ##

接下来利用JavaRestClient实现文档的CRUD，去数据库查询酒店数据，导入到hotel索引库，实现酒店数据的CRUD。

和操作索引库一样，还是要先完成JavaRestClient的初始化：

public class ElasticsearchDocumentTest {
           
    	// 客户端   
    	private RestHighLevelClient client; 
    	        
    	@BeforeEach    
    	void setUp() {
                
    	client = new RestHighLevelClient(RestClient.builder(
    	               HttpHost.create("http://192.168.150.101:9200")
    	 ));    
    	 }  
    	  
    	 @AfterEach    
    	 void tearDown() throws IOException {
                
    	 client.close();    
    	 }
    }

接下来要在mysql查数据，写下Service层接口，让它继承MyBatisPlus的`IService<PO>`

import com.baomidou.mybatisplus.extension.service.IService;
    
    public interface IHotelService extends IService<Hotel> {
        
    }

### 1、新增文档 ###

先看下DSL语法和使用JavaRestClient操作代码来实现的对比：

![在这里插入图片描述][238a5a38ef4b438aa1e189536b72a909.png]

以上是简单逻辑和流程。注意MySQL中查出来的实体类字段和DSL下面的json字段不一样，这是tb\_hotel表对应的实体类：

@Data
    @TableName("tb_hotel")
    public class Hotel {
        
        @TableId(type = IdType.INPUT)
        private Long id;
        private String name;
        private String address;
        private Integer price;
        private Integer score;
        private String brand;
        private String city;
        private String starName;
        private String business;
        private String longitude;
        private String latitude;
        private String pic;
    }

这里**写个新类HotelDoc，将Hotel类封装成为和ES索引库字段对应的类**：

@Data
    @NoArgsConstructor
    public class HotelDoc {
        
        private Long id;
        private String name;
        private String address;
        private Integer price;
        private Integer score;
        private String brand;
        private String city;
        private String starName;
        private String business;
        private String location; //!
        private String pic;
    
        public HotelDoc(Hotel hotel) {
           //有参构造，传入要封装的对象
            this.id = hotel.getId();  //对于这些不用包装的字段，直接get到后赋值给包装对象的属性就行
            this.name = hotel.getName();
            this.address = hotel.getAddress();
            this.price = hotel.getPrice();
            this.score = hotel.getScore();
            this.brand = hotel.getBrand();
            this.city = hotel.getCity();
            this.starName = hotel.getStarName();
            this.business = hotel.getBusiness();  
            this.location = hotel.getLatitude() + ", " + hotel.getLongitude();   //注意这里
            this.pic = hotel.getPic();
        }
    }

接下来实现**去数据库查询酒店数据，导入到hotel索引库：**

@Resource
    IHotelService iHotelService;
    
    @Test
    void testIndexDocument() throws IOException {
        
     	//从MySQL查
         Hotel hotel = iHotelService.getById(60359L);   
         //封装
         HotelDoc hotelDoc = new HotelDoc(hotel);
         //创建request
         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
         //放入要新增的json传
         request.source(JSON.toJSONString(hotelDoc), XContentType.JSON);
         //发请求
         client.index(request, RequestOptions.DEFAULT);
     }

### 2、查询文档 ###

根据id查询到的文档数据是json，再反序列化成Java对象。代码和DSL语句的对比：

![在这里插入图片描述][b551ead4e320485e918349d65e864a8b.png]

@Test
    void testGetDocumentById() throws IOException {
        
        GetRequest request = new GetRequest("hotel","60359");
        GetResponse response = client.get(request,RequestOptions.DEFAULT);
        //看上图DSL执行返回结果中有个_source，这个getSource方法就是拿这个数据
        String json = response.getSourceAsString();
        //解析
        HotelDoc hotelDoc = JSON.parseObject(json,HotelDoc.class);
        System.out.println(hotelDoc);
    }

![在这里插入图片描述][07403ae38ba84f3f9f5dba3d57f4c0d9.png]

### 3、修改文档 ###

接下来根据id去修改ES文档的酒店数据。修改文档数据有两种方式：

方式一：全量更新。再次写入id一样的文档，就会删除旧文档，添加新文档
    方式二：局部更新。只更新部分字段

实现下方式二：  
![在这里插入图片描述][6c29e32fec214afeae3a0fac678fa245.png]

@Test
    void testUpdateDocumentById() throws IOException {
        
        UpdateRequest request = new UpdateRequest("hotel","60359");
        request.doc(
                "price","0.01",
                "startName","四星级"
        );
        client.update(request,RequestOptions.DEFAULT);
    }

### 4、删除文档 ###

根据id删除文档数据：

![在这里插入图片描述][a4955fa154e745028e868cea6e7735bc.png]

@Test
    void testDeleteDocumentById() throws IOException {
        
        DeleteRequest request = new DeleteRequest("hotel","60359");
        client.delete(request,RequestOptions.DEFAULT);
    }

再get已经无数据：

![在这里插入图片描述][21cd806b92bd4fa0a37b8de172fbeb82.png]

小结：  
![在这里插入图片描述][282b55a4594c401f8f271f9e5eb46e3a.png]

### 5、批量导入文档 ###

接下来批量查询酒店数据，然后批量导入索引库中，实现思路：

*  利用mybatis-plus查询酒店数据
 *  将查询到的酒店数据（Hotel）转换为文档类型数据（HotelDoc）
 *  利用JavaRestClient中的Bulk批处理，实现批量新增文档

代码逻辑：

![在这里插入图片描述][71496f96ee4e491bba17bd574c285228.png]

@Test
    void testBulk() throws IOException {
        
    	//从MySQL查到所有数据
        List<Hotel> hotels = iHotelService.list();
        BulkRequest request = new BulkRequest();
        //遍历Hotel的对象集合
        for(Hotel hotel : hotels){
        
        	//Hotel转HotelDoc
            HotelDoc hotelDoc = new HotelDoc(hotel);
            //创建新增文档的Request对象
            request.add(new IndexRequest("hotel")
                    .id(hotelDoc.getId().toString())
                    .source(JSON.toJSONString(hotelDoc),XContentType.JSON)
            );
        }
        //发送请求
        client.bulk(request,RequestOptions.DEFAULT);
    
    
    
    }

最后查询单个文档或者查所有：

//查所有
    GET /hotel/_search

![在这里插入图片描述][c481d9d232e645e9a2bb8108e6a1ce15.png]

[d208fda73bd24766b43417059be76a02.png]: https://img-blog.csdnimg.cn/d208fda73bd24766b43417059be76a02.png
[5e2d563e242e43a58ac5ddd2e2cb0f3d.png]: https://img-blog.csdnimg.cn/5e2d563e242e43a58ac5ddd2e2cb0f3d.png
[6c28f169bbf44ed88e8165a5220b8e71.png]: https://img-blog.csdnimg.cn/6c28f169bbf44ed88e8165a5220b8e71.png
[58f4fad95a18401f9b2206978939f43d.png]: https://img-blog.csdnimg.cn/58f4fad95a18401f9b2206978939f43d.png
[486062b5973947be988bc9a354921908.png]: https://img-blog.csdnimg.cn/486062b5973947be988bc9a354921908.png
[6b781b7db4584edc91568b19f958c32a.png]: https://img-blog.csdnimg.cn/6b781b7db4584edc91568b19f958c32a.png
[a0b5f97ed06245df84be3c069ba68077.png]: https://img-blog.csdnimg.cn/a0b5f97ed06245df84be3c069ba68077.png
[9c6d20b05947436ea6e23791afa621e4.png]: https://img-blog.csdnimg.cn/9c6d20b05947436ea6e23791afa621e4.png
[60e43fed5116494881e38a1ce584004e.png]: https://img-blog.csdnimg.cn/60e43fed5116494881e38a1ce584004e.png
[f087a8e7d6fc406aa536f09ddc3e33e8.png]: https://img-blog.csdnimg.cn/f087a8e7d6fc406aa536f09ddc3e33e8.png
[75bc8a23445f460eaaeb32182f9c8b7d.png]: https://img-blog.csdnimg.cn/75bc8a23445f460eaaeb32182f9c8b7d.png
[298eb8eae5e44a13b744ac1cc8b2b32c.png]: https://img-blog.csdnimg.cn/298eb8eae5e44a13b744ac1cc8b2b32c.png
[82dda2f06ead40a0a8f125eb1a40f73f.png]: https://img-blog.csdnimg.cn/82dda2f06ead40a0a8f125eb1a40f73f.png
[0d232692c7b548b397cd5650dc34c324.png]: https://img-blog.csdnimg.cn/0d232692c7b548b397cd5650dc34c324.png
[b8bdb15dd86e44458d954ec03737733a.png]: https://img-blog.csdnimg.cn/b8bdb15dd86e44458d954ec03737733a.png
[238a5a38ef4b438aa1e189536b72a909.png]: https://img-blog.csdnimg.cn/238a5a38ef4b438aa1e189536b72a909.png
[b551ead4e320485e918349d65e864a8b.png]: https://img-blog.csdnimg.cn/b551ead4e320485e918349d65e864a8b.png
[07403ae38ba84f3f9f5dba3d57f4c0d9.png]: https://img-blog.csdnimg.cn/07403ae38ba84f3f9f5dba3d57f4c0d9.png
[6c29e32fec214afeae3a0fac678fa245.png]: https://img-blog.csdnimg.cn/6c29e32fec214afeae3a0fac678fa245.png
[a4955fa154e745028e868cea6e7735bc.png]: https://img-blog.csdnimg.cn/a4955fa154e745028e868cea6e7735bc.png
[21cd806b92bd4fa0a37b8de172fbeb82.png]: https://img-blog.csdnimg.cn/21cd806b92bd4fa0a37b8de172fbeb82.png
[282b55a4594c401f8f271f9e5eb46e3a.png]: https://img-blog.csdnimg.cn/282b55a4594c401f8f271f9e5eb46e3a.png
[71496f96ee4e491bba17bd574c285228.png]: https://img-blog.csdnimg.cn/71496f96ee4e491bba17bd574c285228.png
[c481d9d232e645e9a2bb8108e6a1ce15.png]: https://img-blog.csdnimg.cn/c481d9d232e645e9a2bb8108e6a1ce15.png