04-HighLevelAPI入门

灌篮少年  金牌会员 | 2022-9-16 17:15:50 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 764|帖子 764|积分 2292

八、HighLevelAPI

8.1、RestAPI介绍&项目导入

8.1.1、RestAPI介绍


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

  • 其中的Java Rest Client又包括两种

    • Java Low Level Rest Client
    • Java High Level Rest Client


本次学习的是HighLevel版本
8.1.2、项目导入

有需要的可以直接联系本人
①、数据库数据导入


  • 导入自定义的数据即可；
②、创建初始工程


  • 初始工程创建成功后，目录结构如下所示


    • 其中HotelDoc后续会说到

  • 配置application.yml

    • 在spring层级下添加es的服务端路径配置
      1.   elasticsearch:
      2.     rest:
      3.       uris:
      4.         - http://192.168.222.135:9200
      复制代码

  • 导入相关依赖

      1. <?xml version="1.0" encoding="UTF-8"?>
      2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
      4.     <modelVersion>4.0.0</modelVersion>
      5.     <parent>
      6.         <groupId>org.springframework.boot</groupId>
      7.         <artifactId>spring-boot-starter-parent</artifactId>
      8.         <version>2.3.8.RELEASE</version>
      9.         <relativePath/>
      10.     </parent>
      11.     <groupId>com.coolman.hotel</groupId>
      12.     <artifactId>hotel-demo</artifactId>
      13.     <name>hotel-demo</name>
      14.     <description>Demo project for Spring Boot</description>
      15.     <properties>
      16.         <java.version>1.8</java.version>
      17.     </properties>
      18.     <dependencies>
      19.         <dependency>
      20.             <groupId>org.springframework.boot</groupId>
      21.             <artifactId>spring-boot-starter-web</artifactId>
      22.         </dependency>
      23.         <dependency>
      24.             <groupId>com.baomidou</groupId>
      25.             <artifactId>mybatis-plus-boot-starter</artifactId>
      26.             <version>3.1.1</version>
      27.         </dependency>
      28.         <dependency>
      29.             <groupId>mysql</groupId>
      30.             <artifactId>mysql-connector-java</artifactId>
      31.             <version>8.0.27</version>
      32.             <scope>runtime</scope>
      33.         </dependency>
      34.         <dependency>
      35.             <groupId>org.projectlombok</groupId>
      36.             <artifactId>lombok</artifactId>
      37.             <optional>true</optional>
      38.         </dependency>
      39.         <dependency>
      40.             <groupId>org.springframework.boot</groupId>
      41.             <artifactId>spring-boot-starter-test</artifactId>
      42.             <scope>test</scope>
      43.         </dependency>
      44.                 <dependency>
      45.             <groupId>org.apache.commons</groupId>
      46.             <artifactId>commons-lang3</artifactId>
      47.         </dependency>
      49.         
      50.         <dependency>
      51.             <groupId>org.elasticsearch.client</groupId>
      52.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
      53.         </dependency>
      54.     </dependencies>
      56.     <build>
      57.         <plugins>
      58.             <plugin>
      59.                 <groupId>org.springframework.boot</groupId>
      60.                 <artifactId>spring-boot-maven-plugin</artifactId>
      61.                 <configuration>
      62.                     <excludes>
      63.                         <exclude>
      64.                             <groupId>org.projectlombok</groupId>
      65.                             <artifactId>lombok</artifactId>
      66.                         </exclude>
      67.                     </excludes>
      68.                 </configuration>
      69.             </plugin>
      70.         </plugins>
      71.     </build>
      73. </project>
      复制代码

  • 编写测试类，验证是否可以正常连接

      1. package com.coolman.hotel.test;
      3. import lombok.extern.slf4j.Slf4j;
      4. import org.elasticsearch.client.RestHighLevelClient;
      5. import org.junit.jupiter.api.Test;
      6. import org.springframework.beans.factory.annotation.Autowired;
      7. import org.springframework.boot.test.context.SpringBootTest;
      9. @SpringBootTest
      10. @Slf4j
      11. public class TestConnectES {
      13.     @Autowired
      14.     private RestHighLevelClient restHighLevelClient;
      16.     @Test
      17.     public void testConnect() {
      18.       log.info(restHighLevelClient + "");
      19.     }
      20. }
      复制代码


8.2、创建索引


  • 代码如下所示

      1.     /**
      2.      * 创建索引测试
      3.      */
      4.     @Test
      5.     public void testCreateIndex() throws IOException {
      6.         // 1. 获取索引操作对象
      7.         IndicesClient indicesClient = restHighLevelClient.indices();
      9.         // 2. 创建索引对象
      10.         CreateIndexRequest request = new CreateIndexRequest("hotel");// 相当于DSL语句的 PUT hotel 请求，但是还没执行
      12.         // 3. 执行操作
      13.         CreateIndexResponse response = indicesClient.create(request, RequestOptions.DEFAULT);
      15.         // 4. 获取结果
      16.         log.info(response.isAcknowledged() + "");
      18.     }
      复制代码

  • 运行结果如下所示



  • Kibana验证



8.3、添加映射


  • 代码如下所示

    • 因为创建映射需要DSL语句，所以先在kibana编写如下语句

        1. DELETE hotel
        3. GET hotel/_mapping
        5. # 分析hotel索引库的映射结构
        6. # index属性：是否建立索引，默认值true，如果该字段不用查询，则设置false
        7. # copy_to: 把指定字段的值拷贝到另一个字段上
        8. PUT hotel
        9. {
        10.   "mappings": {
        11.     "properties": {
        12.       "id": {
        13.         "type": "keyword"
        14.       },
        15.       "name": {
        16.         "type": "text",
        17.         "analyzer": "ik_smart",
        18.         "copy_to": "all"
        19.       },
        20.       "address": {
        21.         "type": "text",
        22.         "analyzer": "ik_smart"
        23.       },
        24.       "price": {
        25.         "type": "integer"
        26.       },
        27.       "score": {
        28.         "type": "integer"
        29.       },
        30.       "brand": {
        31.         "type": "keyword",
        32.         "copy_to": "all"
        33.       },
        34.       "city": {
        35.         "type": "keyword"
        36.       },
        37.       "starName": {
        38.         "type": "keyword"
        39.       },
        40.       "business": {
        41.         "type": "keyword",
        42.         "copy_to": "all"
        43.       },
        44.       "location": {
        45.         "type": "geo_point"
        46.       },
        47.       "pic": {
        48.         "type": "keyword",
        49.         "index": false
        50.       },
        51.       "isAD": {
        52.         "type": "boolean"
        53.       },
        54.       "all": {
        55.         "type": "text",
        56.         "analyzer": "ik_smart"
        57.       }
        58.     }
        59.   }
        60. }
        复制代码

    • 创建成功后，再删除，将mappings中的字段复制到Java代码中
      1.     /**
      2.      * 添加映射测试
      3.      */
      4.     @Test
      5.     public void testAddMapping() throws IOException {
      6.         // 1. 创建索引操作对象
      7.         IndicesClient indicesClient = restHighLevelClient.indices();
      9.         // 2. 创建索引
      10.         CreateIndexRequest request = new CreateIndexRequest("hotel");
      12.         // 3. 定义mapping语句
      13.         String mapping = "{\n" +
      14.                 "    "properties": {\n" +
      15.                 "      "id": {\n" +
      16.                 "        "type": "keyword"\n" +
      17.                 "      },\n" +
      18.                 "      "name": {\n" +
      19.                 "        "type": "text",\n" +
      20.                 "        "analyzer": "ik_smart",\n" +
      21.                 "        "copy_to": "all"\n" +
      22.                 "      },\n" +
      23.                 "      "address": {\n" +
      24.                 "        "type": "text",\n" +
      25.                 "        "analyzer": "ik_smart"\n" +
      26.                 "      },\n" +
      27.                 "      "price": {\n" +
      28.                 "        "type": "integer"\n" +
      29.                 "      },\n" +
      30.                 "      "score": {\n" +
      31.                 "        "type": "integer"\n" +
      32.                 "      },\n" +
      33.                 "      "brand": {\n" +
      34.                 "        "type": "keyword",\n" +
      35.                 "        "copy_to": "all"\n" +
      36.                 "      },\n" +
      37.                 "      "city": {\n" +
      38.                 "        "type": "keyword"\n" +
      39.                 "      },\n" +
      40.                 "      "starName": {\n" +
      41.                 "        "type": "keyword"\n" +
      42.                 "      },\n" +
      43.                 "      "business": {\n" +
      44.                 "        "type": "keyword",\n" +
      45.                 "        "copy_to": "all"\n" +
      46.                 "      },\n" +
      47.                 "      "location": {\n" +
      48.                 "        "type": "geo_point"\n" +
      49.                 "      },\n" +
      50.                 "      "pic": {\n" +
      51.                 "        "type": "keyword",\n" +
      52.                 "        "index": false\n" +
      53.                 "      },\n" +
      54.                 "      "isAD": {\n" +
      55.                 "        "type": "boolean"\n" +
      56.                 "      },\n" +
      57.                 "      "all": {\n" +
      58.                 "        "type": "text",\n" +
      59.                 "        "analyzer": "ik_smart"\n" +
      60.                 "      }\n" +
      61.                 "    }\n" +
      62.                 "  }";
      64.         request.mapping(mapping, XContentType.JSON);    // 设置mappings字段，并指定其内容为json格式
      66.         // 4. 执行操作
      67.         CreateIndexResponse response = indicesClient.create(request, RequestOptions.DEFAULT);
      69.         // 5. 获取结果
      70.         log.info(response.isAcknowledged() + "");
      72.     }
      复制代码
    • ​

  • 运行结果如下所示



  • Kibana验证



8.4、删除索引


  • 代码如下所示

      1.     /**
      2.      * 删除索引测试
      3.      */
      4.     @Test
      5.     public void testDeleteIndex() throws IOException {
      6.         // 1. 获取索引操作对象
      7.         IndicesClient indicesClient = restHighLevelClient.indices();
      8.         
      9.         // 2. 获取索引对象
      10.         DeleteIndexRequest request = new DeleteIndexRequest("hotel");   // DELETE hotel
      12.         // 3. 执行操作
      13.         AcknowledgedResponse response = indicesClient.delete(request, RequestOptions.DEFAULT);
      15.         // 4. 获取结果
      16.         log.info("" + response.isAcknowledged());
      17.     }
      复制代码

  • 比较简单，自行验证即可
8.5、添加文档


  • 代码如下所示

      1.     /**
      2.      * 添加文档测试
      3.      */
      4. // Jackson
      5.     private ObjectMapper objectMapper = new ObjectMapper();
      6.     @Test
      7.     public void testAddDocument() throws IOException {
      8.         // 先获取 指定的 hotel数据
      9.         Hotel hotel = hotelMapper.selectById(36934);
      10.         HotelDoc hotelDoc = new HotelDoc(hotel);
      12.         // 1. 创建请求对象
      13.         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
      15.         // 2. 填充文档内容
      16.         String json = objectMapper.writeValueAsString(hotelDoc);
      17.         request.source(json, XContentType.JSON);
      19.         // 3. 执行请求体对象
      20.         IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
      22.         // 4. 获取结果
      23.         log.info(response.getId() + "");
      24.     }
      复制代码

  • Kibana验证



8.6、修改、查询、删除文档

8.6.1、修改文档

修改文档和添加文档操作一样，需要注意的是修改文档必须是已经存在的ID


  • 代码如下所示

      1.     /**
      2.      * 修改文档
      3.      */
      4.     @Test
      5.     public void testUpdateDocument() throws IOException {
      6.         // 1. 先获取 指定的 hotel 数据
      7.         Hotel hotel = hotelMapper.selectById(36934L);
      8.         HotelDoc hotelDoc = new HotelDoc(hotel);
      10.         // 2. 修改数据，如价格
      11.         hotelDoc.setPrice(1999999999);
      13.         // 3. 将 hotelDoc 对象转换为 JSON格式的数据
      14.         String json = objectMapper.writeValueAsString(hotelDoc);
      16.         // 4. 创建请求对象
      17.         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
      18.         request.source(json, XContentType.JSON);
      20.         // 5. 执行操作
      21.         IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
      23.         log.info(response.getId());
      24.     }
      复制代码

  • Kibana验证



8.6.2、查询文档


  • 代码如下所示

      1.     /**
      2.      * 查询文档
      3.      */
      4.     @Test
      5.     public void testSearchDocument() throws IOException {
      6.         Long id = 36934L;
      7.         // 1. 创建请求
      8.         GetRequest request = new GetRequest("hotel").id(id.toString());
      10.         // 2. 执行请求
      11.         GetResponse response = restHighLevelClient.get(request, RequestOptions.DEFAULT);
      13.         // 3. 取出结果
      14.         String hotelDocJson = response.getSourceAsString();
      16.         HotelDoc hotelDoc = objectMapper.readValue(hotelDocJson, HotelDoc.class);
      18.         log.info(hotelDoc.toString());
      19.     }
      复制代码

  • 运行结果如下所示



8.6.3、删除文档


  • 代码如下所示

      1.     /**
      2.      * 删除文档
      3.      */
      4.     @Test
      5.     public void testDeleteDocument() throws IOException {
      6.         Long id = 36934L;
      7.         // 1. 创建请求
      8.         DeleteRequest request = new DeleteRequest("hotel").id(id.toString());
      10.         // 2. 执行请求
      11.         DeleteResponse response = restHighLevelClient.delete(request, RequestOptions.DEFAULT);
      13.         log.info(response.getId());
      15.     }
      复制代码

  • Kibana验证



8.7、批量添加


  • Bulk批量操作是将文档的增删改查一些列操作，通过一次请求全都做完。减少网络传输次数
  • 应用场景

    • ES索引库数据初始化的时候，可以将数据库的数据查询出来通过批量操作导入到索引库中

  • 代码如下所示

      1.     /**
      2.      * 批量添加文档
      3.      */
      4.     @Test
      5.     public void testBatchAddDocument() throws IOException {
      6.         // 1. 获取需要导入的数据
      7.         List<Hotel> hotelList = hotelMapper.selectList(null);
      9.         if(CollectionUtils.isNotEmpty(hotelList)) {
      10.             // 2. 创建批量操作请求对象
      11.             BulkRequest bulkRequest = new BulkRequest();
      13.             // 4. 获取文档映射的对象数据
      14.             for (Hotel hotel : hotelList) {
      15.                 HotelDoc hotelDoc = new HotelDoc(hotel);
      17.                 // 5. 创建请求对象
      18.                 IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());;
      20.                 // 6. 填充内容
      21.                 String json = objectMapper.writeValueAsString(hotelDoc);
      22.                 request.source(json, XContentType.JSON);
      24.                 // 7. 将数据添加到批量操作对象中
      25.                 bulkRequest.add(request);
      26.             }
      27.             // 8. 一次性执行批量操作
      28.             BulkResponse response = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      29.             log.info(response.status().toString());
      30.         }
      31.     }
      复制代码

  • 运行结果如下所示



  • Kibana验证




免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

正序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

灌篮少年

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表