ElasticSearch之RestClient操作索引库和文档

news2024/9/29 13:24:21

前言：上文介绍了使用DSL语言操作索引库和文档，本篇文章将介绍使用Java中的RestClient来对索引库和文档进行操作。
希望能够加深自己的印象以及帮助到其他的小伙伴儿们😉😉。
如果文章有什么需要改进的地方还请大佬不吝赐教👏👏。
小威在此先感谢各位大佬啦~~🤞🤞

在这里插入图片描述

🏠个人主页：小威要向诸佬学习呀
🧑个人简介：大家好，我是小威，一个想要与大家共同进步的男人😉😉
目前状况🎉：24届毕业生，曾经在某央企公司实习，目前在某税务公司实习👏👏

💕欢迎大家：这里是CSDN，我总结知识的地方，欢迎来到我的博客，我亲爱的大佬😘

以下正文开始
在这里插入图片描述

文章目录

  • RestClient操作索引库
    • 创建索引库
    • 删除索引库
  • RestClient操作文档
    • 插入文档
    • 查询文档
    • 修改文档

在这里插入图片描述

好，那就详细记录下这块的知识。

前面记录了在网页端使用DSL语句对Elasticsearch的索引库和文档进行增删改查的简单操作。但是在日常的开发工作中，还是用Java语言操作比较多，因此需要使用Elasticsearch官方提供的RestClient操作索引库和文档。
在这里插入图片描述

首先准备一个索引库名为hotel的库并分析其中字段的数据结构，然后根据字段的名称，数据类型，是否参与搜索，是否分词，分词器等条件来完善其mapping，在其内部定义了一个名为“all”字段的属性，这个字段目的是将其他同时参与搜索的字段cope_to在一起，搜索的时候根据“all”字段内的查询条件一起搜索，可以提高搜索效率：

PUT /hotel
{
  "mappings": {
    "properties": {
      "id":{
        "type": "keyword"
      },
      "name":{
        "type": "text",
        "analyzer": "ik_max_word",
        "copy_to": "all"
      },
      "address":{
        "type": "keyword",
        "index": false
      },
      "price":{
        "type": "integer"
      },
      "score":{
        "type": "integer"
      },
      "brand":{
        "type": "keyword",
        "copy_to": "all"
      },
      "city":{
        "type":"keyword"
      },
      "starName":{
        "type": "keyword"
      },
      "business":{
        "type": "keyword"
        , "copy_to": "all"
      },
      "location":{
        "type": "geo_point"
      },
      "pic":{
        "type": "keyword",
        "index": false
      },
       "all":{
        "type": "text",
        "analyzer": "ik_max_word"
      }
      }
  }
}

那么，如何在idea中操作对索引库和文档进行操作呢？

倘若我们想要使用RestClient来操作，首要任务就是引入其依赖：

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

第二步，在测试类中编写测试方法，我们需要创建RestClient对象，然后对RestClient进行初始化，当然创建完成RestClient后需要销毁，代码如下：

    private RestHighLevelClient client;
    @BeforeEach //创建对象初始化
    void setUp() {
        client = new RestHighLevelClient(RestClient.builder(
                HttpHost.create("http://192.168.220.***:9200") //创建方法
        ));
    }
    @AfterEach //创建完成后销毁
    void tearDown() throws IOException {
        client.close();
    }

在这里插入图片描述

RestClient操作索引库

创建索引库

这里的创建索引库方法和我们上面DSL语句的含义是一样的，虽然描述方式有所不同。

  • 第一行代码创建索引库，相当于DSL语句中的PUT /hotel
  • 第二行代码准备请求参数，MAPPING_TEMPLATE为创建DSL语句中的内容（除去PUT /hotel那些）
  • 第三步调用client的indices()拿到操作索引库的所有方法，然后取出create方法
    @Test
    void testCreateIndex() throws IOException {
        // 1.准备Request      PUT /hotel
        CreateIndexRequest request = new CreateIndexRequest("hotel");
        // 2.准备请求参数
        request.source(MAPPING_TEMPLATE, XContentType.JSON);//这里将DSL语句封装成了MAPPING_TEMPLATE，优雅美观
        // 3.发送请求
        client.indices().create(request, RequestOptions.DEFAULT);
    }

可以进入indices方法的源码，查看得返回的是indicesClient，如下：

public final IndicesClient indices() {
    return this.indicesClient;
}

delete的方法的源码，由此可见上面传入request请求即可：

public final class IndicesClient {
    private final RestHighLevelClient restHighLevelClient;

    IndicesClient(RestHighLevelClient restHighLevelClient) {
        this.restHighLevelClient = restHighLevelClient;
    }
    
    public AcknowledgedResponse delete(DeleteIndexRequest deleteIndexRequest, RequestOptions options) throws IOException {
        return restHighLevelClient.performRequestAndParseEntity(deleteIndexRequest, IndicesRequestConverters::deleteIndex, options,
            AcknowledgedResponse::fromXContent, emptySet());
    }
}

删除索引库

根据以上信息，我们不难得出使用RestClient删除索引库和判断索引库是否存在的相关代码：

    @Test //判断索引库是否存在
    void testExistsIndex() throws IOException {
        // 1.准备Request，注意这块是获取索引库请求而不是创建
        GetIndexRequest request = new GetIndexRequest("hotel");
        // 3.发送请求，调用exists方法
        boolean isExists = client.indices().exists(request, RequestOptions.DEFAULT);
        System.err.println(isExists ? "索引库存在" : "索引库不存在");
    }
    
    @Test  //删除索引库操作
    void testDeleteIndex() throws IOException {
        // 1.准备Request，指定删除哪个索引库
        DeleteIndexRequest request = new DeleteIndexRequest("hotel"); 
        // 3.发送请求，调用delete方法
        client.indices().delete(request, RequestOptions.DEFAULT);
    }

综上所述，索引库操作的基本步骤：
• 初始化RestHighLevelClient
• 创建XxxIndexRequest。Xxx可以是Create，Get，Delete
• 准备DSL语句（ Create时需要）
• 发送请求。调用RestHighLevelClient#indices().xxx()方法，xxx可以是create，exists，delete
在这里插入图片描述

RestClient操作文档

操作文档和操作索引库一样，需要完成RestClient的初始化和销毁操作，这里不展现重复代码了。

插入文档

前面调用MybatisPlus中查询的方法从数据库中查询出ID为61083的信息，由于索引库和数据库中的某字段不是很对应，所以做了一次转换。之后开始操作文档。

  • 第一步，创建文档，与POST /索引库名称/_doc/1相对应
  • 第二步，准备json文档，上部代码已经对数据json序列化了
  • 第三步，直接调用index方法发送请求
    private RestHighLevelClient client;
    @Autowired
    private IHotelService hotelService;
    
    @Test
    void testAddDocument() throws IOException {
        // 1.查询数据库hotel数据
        Hotel hotel = hotelService.getById(61083L);
        // 2.转换为HotelDoc
        HotelDoc hotelDoc = new HotelDoc(hotel);
        // 3.转JSON
        String json = JSON.toJSONString(hotelDoc);

        // 1.准备Request
        IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());//索引库中对id的要求为"keyword"，因此要转换成string类型
        // 2.准备请求参数DSL，其实就是文档的JSON字符串
        request.source(json, XContentType.JSON);
        // 3.发送请求
        client.index(request, RequestOptions.DEFAULT);
    }

查询文档

根据id查询文档信息，相对应的DSL语句为：GET /数据库名称/_doc/1。查询是新建GetRequest对象。

    @Test
    void testGetDocumentById() throws IOException {
        // 1.准备Request      // GET /hotel/_doc/{id}
        GetRequest request = new GetRequest("hotel", "61083");
        // 2.发送请求
        GetResponse response = client.get(request, RequestOptions.DEFAULT);
        // 3.解析响应结果
        String json = response.getSourceAsString();
        //查询出来的对象是json形式，这里转换成HotelDoc对象形式
        HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
        System.out.println("hotelDoc = " + hotelDoc);
    }

修改文档

前面介绍的修改有两种方式，一种为全局修改，一种为增量修改，这里以增量修改为例（DSL语句：POST /数据库名称/_doc/1）：

    @Test
    void testUpdateById() throws IOException {
        // 1.准备Request
        UpdateRequest request = new UpdateRequest("hotel", "61083");
        // 2.准备参数,这里是需要改变的参数
        request.doc(
                "price", "870"
        );
        // 3.发送请求
        client.update(request, RequestOptions.DEFAULT);
    }

文档操作的基本步骤：
• 初始化RestHighLevelClient
• 创建XxxRequest。Xxx可以是Index，Get，Update，Delete
• 准备参数（Index和Update时需要）
• 发送请求。调用RestHighLevelClient.xxx()方法，xxx可以是index，get，update，delete
• 解析结果（Get时需要，将查询出的json形式转化为对象形式）

本篇文章就先分享到这里了，后续会继续分享其他方面的知识，感谢大佬认真读完支持咯~
在这里插入图片描述

文章到这里就结束了，如果有什么疑问的地方请指出，诸佬们一起讨论😁
希望能和诸佬们一起努力，今后我们顶峰相见🍻
再次感谢各位小伙伴儿们的支持🤞

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/349102.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

linux系统编程1--文件编程read和write

linux系统编程1--文件编程read和write

write函数进行文件写入操作1.write函数原型&#xff1a;ssize_t write(int fd, const void *buf, size_t count);2.参数1&#xff1a;int fd&#xff0c;文件描述符即open函数的返回值&#xff1b;参数2&#xff1a;const void *buf&#xff0c;写入到fd文件内容的写入缓冲区&a…
阅读更多...
10万字企业数字化（技术中台、数据中台、工业互联网平台建设方案

10万字企业数字化（技术中台、数据中台、工业互联网平台建设方案

【版权声明】本资料来源网络&#xff0c;知识分享&#xff0c;仅供个人学习&#xff0c;请勿商用。【侵删致歉】如有侵权请联系小编&#xff0c;将在收到信息后第一时间删除&#xff01;完整资料关注公众号“智慧方案文库”&#xff0c;部分资料内容&#xff1a; 目录 1 概述 …
阅读更多...
【nodejs-05】黑马nodejs学习笔记05-数据库基本操作02

【nodejs-05】黑马nodejs学习笔记05-数据库基本操作02

文章目录4.在项目中操作MySQL4.1 在项目中操作数据库的步骤4.2 安装与配置 mysql 模块4.3 使用 mysql 模块操作 MySQL 数据库5.前后端的身份认证5.1 Web 开发模式5.2 身份认证5.3 Session 认证机制5.4 在 Express 中使用 Session 认证5.5 JWT 认证机制5.6 在 Express 中使用 JW…
阅读更多...
用类比方式学习编程中函数递归（个人理解仅供参考）（内含汉诺塔问题的求解）

用类比方式学习编程中函数递归（个人理解仅供参考）（内含汉诺塔问题的求解）

目录 1.前言 2.递归的数学模型 3.相关的c语法 4.将递归的数学模型写成编程语言 5.利用类比方法将实际问题的代码写成函数递归的形式 例1: 例2: 6.汉诺塔问题的求解 1.前言 本人在学习函数递归编程方法的过程中&#xff0c;发现用类比的方式学习递归法可帮助我们在各种编…
阅读更多...
day14_类中成员之一：构造器

day14_类中成员之一：构造器

由来 我们发现我们new完对象时&#xff0c;所有成员变量都是默认值&#xff0c;如果我们需要赋别的值&#xff0c;需要挨个为它们再赋值&#xff0c;太麻烦了。我们能不能在new对象时&#xff0c;直接为当前对象的某个或所有成员变量直接赋值呢。可以&#xff0c;Java给我们提…
阅读更多...
【算法】二分

【算法】二分

作者&#xff1a;指针不指南吗 专栏&#xff1a;算法篇 &#x1f43e;或许会很慢&#xff0c;但是不可以停下来&#x1f43e; 文章目录1.二分思想2.二分模板3.二分应用1.二分思想 思想 单调的元素&#xff0c;一定可以二分&#xff1b;非单调不一定不能二分 每次把整个区间 [ …
阅读更多...
【企业云端全栈开发实践-1】项目介绍及环境准备、Spring Boot快速上手

【企业云端全栈开发实践-1】项目介绍及环境准备、Spring Boot快速上手

本节目录一、 项目内容介绍二、Maven介绍2.1 Maven作用2.2 Maven依赖2.3 本地仓库配置三、Spring Boot快速上手3.1 Spring Boot特点3.2 遇到的Bug&#xff1a;spring-boot-maven-plugin3.3 遇到的Bug2&#xff1a;找不到Getmapping四、开发环境热部署一、 项目内容介绍 本课程…
阅读更多...
肿瘤HRR和HRD 简单记录

肿瘤HRR和HRD 简单记录

最近看到两个在肿瘤领域高频出现的词HRR和HRD&#xff0c; 遂简单记录下。 HRR和HRD的概念 当细胞受到外界不良环境的压力下往往会导致DNA的损伤&#xff0c;此时便会触发DNA 损伤反应 (DDR)&#xff0c;从而激活许多DNA修复通路。在这些DNA损伤中&#xff0c;DNA 双链断裂&a…
阅读更多...
【云原生】centos7搭建安装k8s集群 v1.25版本详细教程实战

【云原生】centos7搭建安装k8s集群 v1.25版本详细教程实战

文章目录前言一. 实验环境二. k8s 的介绍三 . k8s的安装3.1 搭建实验环境3.1.1 硬件层面的要求3.1.2 软件层面环境配置3.2 docker的安装3.2.1 搭建docker3.2.2 部署 cri-dockerd3.3 部署k8s3.3.1 配置添加阿里云的yum源3.3.2 安装kubeadm kubelet kubectl3.3.3 k8s-master节点初…
阅读更多...
浪涌保护器，防雷浪涌保护器的作用和类型指南

浪涌保护器，防雷浪涌保护器的作用和类型指南

1&#xff0e; 什么是SPD浪涌保护器&#xff1f;地凯防雷SPD浪涌保护器是防止雷击导致故障的避雷器和浪涌保护设备。广泛用于电源浪涌对策的变阻器在通电超过规格的雷电浪涌电流、超过最大容许电路电压的过电压、过电流时&#xff0c;会进入短路故障模式&#xff0c;存在冒烟起…
阅读更多...
Mysql元数据获取方法(information_schema绕过方法)

Mysql元数据获取方法(information_schema绕过方法)

前提&#xff1a;如果waf或其它过滤了information_schema关键字&#xff0c;那我们该如何获取元数据呢&#xff1f;能够代替information_schema的有&#xff1a;sys.schema_auto_increment_columnssys.schema_table_statistics_with_bufferx$schema_table_statistics_with_buff…
阅读更多...
大数据框架之Hadoop：HDFS（七）HDFS 2.X新特性

大数据框架之Hadoop：HDFS（七）HDFS 2.X新特性

7.1集群间数据拷贝 scp实现两个远程主机之间的文件复制 ​ scp -r hello.txt roothadoop103:/root/hello.txt // 推 push ​ scp -r roothadoop103:/root/hello.txt hello.txt // 拉 pull ​ scp -r roothadoop103:/root/hello.txt roothadoop104:/root //是通过本地主机中…
阅读更多...
计算机技术与软件（初级、中级、高级）考试（软考）是什么？软考的时间安排是什么时候？

计算机技术与软件（初级、中级、高级）考试（软考）是什么？软考的时间安排是什么时候？

一、软考是什么&#xff1f; 计算机技术与软件专业技术资格&#xff08;水平&#xff09;考试&#xff08;以下简称计算机软件资格考试&#xff09;是原中国计算机软件专业技术资格和水平考试&#xff08;简称软件考试&#xff09;的完善与发展。计算机软件资格考试是由国家人力…
阅读更多...
Fluent工作目录

Fluent工作目录

1 工作目录定义工作目录&#xff08;working directory&#xff09;是一种文件存储路径设置方式。基于工作目录的方法&#xff0c;写文件时只需要指定文件名&#xff0c;而不需要指定完全的文件路径&#xff0c;从而简化程序编写&#xff0c;对不同操作系统环境有更好的适应性。…
阅读更多...
#笨鸟先飞# 数据结构与算法基础 课程笔记 第六章 图

#笨鸟先飞# 数据结构与算法基础 课程笔记 第六章 图

图的定义和基本术语图&#xff1a;G( V , E ) Graph&#xff08;Vertex&#xff0c;Edge&#xff09;V&#xff1a;顶点&#xff08;数据元素&#xff09;的有穷非空集合&#xff1b;E&#xff1a;边的有穷集合。无向图&#xff1a;每条边都是无方向的有向图&#xff1a;每条边…
阅读更多...
新手小白入门必看！如何批量注册Twitter账号？

新手小白入门必看！如何批量注册Twitter账号？

Twitter是目前海外比较流行的社媒营销平台&#xff0c;所以很多从事跨境电商行业的朋友都需要利用多个Twitter账号来推广营销&#xff0c;但是注册和管理多个Twitter账号其实并不是简单的事情。龙哥将会在这里详细讲讲该如何批量注册并且让这些账号不会因为关联被封号&#xff…
阅读更多...
如何合理地制定项目管理计划？

如何合理地制定项目管理计划？

甘特图是一个比较常见的直观地项目管理专用工具&#xff0c;我们可以使用用Excel制作表格&#xff0c;也可是使用项目管理软件。 详细的项目计划不能完全保证项目成功&#xff0c;但是可以将失败的风险降到最低。通过项目管理软件的图标&#xff0c;项目管理者可以直观的查看任…
阅读更多...
字符串的特殊读取——基于蓝桥杯两道题目（C/C++)

字符串的特殊读取——基于蓝桥杯两道题目（C/C++)

目录 1 例题 1.1 卡片换位 1.2 人物相关性分析 2 字符串的读取 2.1 综述 2.2 scanf 2.3 getline/getchar/get 2.4 注意 2.5 说明 先看例题 1 例题 1.1 卡片换位 问题描述 你玩过华容道的游戏吗&#xff1f; 这是个类似的&#xff0c;但更简单的游戏。 看…
阅读更多...
加拿大访问学者如何提升自我

加拿大访问学者如何提升自我

学习加拿大先进的科学技术和研究方法是我们访学的最主要目的。(1)根据自己的先前的研究计划、加方导师的项目和科研条件尽早调整自己目前学习和研究。(2)可以适当、有选择地听一些相关的课程&#xff0c;在提高英语水平的同时&#xff0c;又能够了解外国的教学方法。(3)与导师积…
阅读更多...
pytest+yaml+allure接口自动化测试框架04.处理request

pytest+yaml+allure接口自动化测试框架04.处理request

前言 ​ 环境搭建配置、封装日志缓存、读取yaml测试文件&#xff0c;这些工作我们上几个章节已经都做完了&#xff0c;读取文件之后&#xff0c;我们已经成功拿到了测试yaml文件中的测试数据了&#xff0c;那我们接下来就通过这些数据去执行测试&#xff0c;主要就是对这些数据…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023