ES学习日记(十一)-------Java操作ES之基本操作

前言

此篇博客还是一些基础操作,没什么可写的,需要的同学直接抄作业进行测试就可以

上一节写了连接和测试新增操作,这一节写java操作ES的基本操作,也就是增删改查,在这里补充一点知识,我们之前用了指定的索引进行指定添加

有一个情况是,如果我们指定了一个不存在的索引时,他会创建一个新的索引,例如我们这个ik1是不存在的,执行添加后也可以添加进去,索引库会新增一个叫ik1的索引,如图

一、查询

注:查询时需要查询存在的索引,不存在会报错,提示not found

    /**
     * 查询测试
     */
    @Test
    public void testRetrieve() throws IOException {
        GetRequest getRequest = new GetRequest("ik","5");
        GetResponse response = client.get(getRequest,RequestOptions.DEFAULT);
        System.out.println(response);
    }

二、更新

忽略警告


    /**
     * 更新
     *
     * @throws IOException
     */
    @Test
    public void testUpdate() throws IOException {
        HashMap<String,Object> map = new HashMap<>();
        map.put("name","哈西布鲁根");
        map.put("content","拳皇99");
        UpdateRequest updateRequest = new UpdateRequest("ik","5").doc(map);
        UpdateResponse updateResponse =client.update(updateRequest,RequestOptions.DEFAULT);
        System.out.println(updateRequest);
    }

三、删除


    /**
     * 删除
     */
    @Test
    public void testDelete() throws IOException {
        DeleteRequest deleteRequest = new DeleteRequest("ik","5");
        DeleteResponse deleteResponse = client.delete(deleteRequest,RequestOptions.DEFAULT);
        System.out.println(deleteRequest);
    }

四、批量增删改

其实就是增加了一个容器BulkRequest,把所有操作放到了这个容器里,然后同意操作

为了查看效果,注释了删除

    /**
     * 批量增删改
     */
    @Test
    public void testCUD() throws IOException {
        BulkRequest request = new BulkRequest();
        /*
         * 增加IndexRequest
         * XContentType键值对
         */
        request.add(new IndexRequest("ik").id("5").source(XContentType.JSON,"name","罗翔","content","法外狂徒张三"));
        /*
         * 更新UpdateRequest
         */
        request.add(new UpdateRequest("ik","5").doc(XContentType.JSON,"name","罗翔","content","法外狂徒李四"));
        /*
         * 删除DeleteRequest
         */
//        request.add(new DeleteRequest("ik").id("5"));
        BulkResponse bulkResponse = client.bulk(request,RequestOptions.DEFAULT);
        System.out.println(bulkResponse.toString());
    }

五、查询

1.查询全部

查询全部,可变参数可指定多个索引,如果结果超过十条,默认返回十条

/**
     * 查询
     *
     * @throws IOException
     */
    @Test
    public void testQuery() throws IOException {
        //可以指定多个索引,用逗号隔开
        SearchRequest searchRequest = new SearchRequest("ik","shop");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //查询所有
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT);
        System.out.println(response);
    }

查询结果是一个JSON,转了一下格式,看着清晰一点,查出来的内容是不能直接使用的,所以还需要转换格式

取出我们想要的部分,图例说明更清晰一些

有三种方式,根据实际使用情况选择,详见注释

/**
     * 查询
     *
     * @throws IOException
     */
    @Test
    public void testQuery() throws IOException {
        //可以指定多个索引,用逗号隔开
        SearchRequest searchRequest = new SearchRequest("ik","shop");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //查询所有,如果结果超过10条,默认显示10条
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT);
        //调整结构,取出需要的部分
        long value = response.getHits().getTotalHits().value;
        System.out.println(response);
        if(0<value){
            SearchHit[] hits = response.getHits().getHits();
            for(SearchHit hit : hits){
                System.out.println(hit.getIndex());
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                //三种方式,根据实际使用情况选择
                System.out.println(hit.getSourceAsMap());
                System.out.println(hit.getSourceAsString());
                System.out.println(hit.getSourceRef());
                System.out.println("==========");
            }
        }
    }

2.按照条件查询

按照条件查询可以分为单字段单索引,单字段多索引,多字段单索引,多字段多索引,多个用逗号隔开就行,有点区别,但区别不大,详见代码注释

/**
     * 根据条件查询
     *
     * @throws IOException
     */
    @Test
    public void testQueryMatch() throws IOException {
        //可以指定多个索引,用逗号隔开
        SearchRequest searchRequest = new SearchRequest("ik","shop");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //单字段匹配-->字段对值
//        searchSourceBuilder.query(QueryBuilders.matchQuery("content","中国"));
        //多字段匹配-->值对多字段
        searchSourceBuilder.query(QueryBuilders.multiMatchQuery("中国","content","name"));
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT);
        //调整结构,取出需要的部分
        long value = response.getHits().getTotalHits().value;
        System.out.println(response);
        if(0<value){
            SearchHit[] hits = response.getHits().getHits();
            for(SearchHit hit : hits){
                System.out.println(hit.getIndex());
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                //三种方式,根据实际使用情况选择
                System.out.println(hit.getSourceAsMap());
                System.out.println(hit.getSourceAsString());
                System.out.println(hit.getSourceRef());
                System.out.println("==========");
            }
        }
    }

3.排序
  /**
     * 排序
     *
     * @throws IOException
     */
    @Test
    public void testQuerySortHighLevel() throws IOException {
        //可以指定多个索引,用逗号隔开
        SearchRequest searchRequest = new SearchRequest("ik","shop");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //多字段匹配-->值对多字段
        searchSourceBuilder.query(QueryBuilders.multiMatchQuery("中国","content","name"));

        //从第几位开始分几条,分别是索引下标,大小
        //分页查询默认查询倒序
        searchSourceBuilder.from(0).size(5);
//        //正序写法
//        searchSourceBuilder.sort(SortBuilders.scoreSort().order(SortOrder.ASC));
        /*
         * 指定字段排序
         * 注意不是数据库里面的字段,是es里面的字段
         * 默认正序,倒序.order(SortOrder.DESC))
         *
         * 指定字段后,分数排序失效
         */
        searchSourceBuilder.sort(SortBuilders.fieldSort("id"));

        searchRequest.source(searchSourceBuilder);
        SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT);
        //调整结构,取出需要的部分
        long value = response.getHits().getTotalHits().value;
        System.out.println(response);
        if(0<value){
            SearchHit[] hits = response.getHits().getHits();
            for(SearchHit hit : hits){
                System.out.println(hit.getIndex());
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                //三种方式,根据实际使用情况选择
                System.out.println(hit.getSourceAsMap());
                System.out.println(hit.getSourceAsString());
                System.out.println(hit.getSourceRef());
                System.out.println("==========");
            }
        }
    }

4.高亮
/**
     * 排序
     *
     * @throws IOException
     */
    @Test
    public void testQuerySortHighLevel() throws IOException {
        //可以指定多个索引,用逗号隔开
        SearchRequest searchRequest = new SearchRequest("ik","shop");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //多字段匹配-->值对多字段
        searchSourceBuilder.query(QueryBuilders.multiMatchQuery("中国","content","name"));

        //从第几位开始分几条,分别是索引下标,大小
        //分页查询默认查询倒序
        searchSourceBuilder.from(0).size(5);
//        //正序写法
        searchSourceBuilder.sort(SortBuilders.scoreSort().order(SortOrder.ASC));
        /*
         * 指定字段排序
         * 注意不是数据库里面的字段,是es里面的字段
         * 默认正序,倒序.order(SortOrder.DESC))
         *
         * 指定字段后,分数排序失效
         */
//        searchSourceBuilder.sort(SortBuilders.fieldSort("id"));

        //高亮
        HighlightBuilder highlightBuilder = new HighlightBuilder().field("content").preTags("<p style='color:red'>").postTags("</>");
        searchSourceBuilder.highlighter(highlightBuilder);

        searchRequest.source(searchSourceBuilder);
        SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT);
        //调整结构,取出需要的部分
        long value = response.getHits().getTotalHits().value;
        System.out.println(response);
        if(0<value){
            SearchHit[] hits = response.getHits().getHits();
            for(SearchHit hit : hits){
                System.out.println(hit.getIndex());
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                //三种方式,根据实际使用情况选择
                System.out.println(hit.getSourceAsMap());
                System.out.println(hit.getSourceAsString());
                System.out.println(hit.getSourceRef());
                //显示高亮.fragments取文本
                System.out.println("hl: "+String.valueOf(hit.getHighlightFields().get("content").fragments()[0]));
                System.out.println("==========");
            }
        }
    }

写在最后

一些基础用法,详见注释,都能用

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

计算机网络-TCP断开连接阶段错误应对机制

连接断开阶段 四次挥手机制&#xff1a;TCP连接的断开需要四次挥手&#xff0c;这是因为双方都需要独立地关闭数据传输。第二次和第三次挥手不能合并&#xff0c;因为在回复第二次挥手的时候&#xff0c;可能还有数据没有接收完成&#xff0c;所以需要先回复ACK报文&#xff0c…

单片机IGBT驱动电路一例

概述&#xff1a; 驱动的作用有三个&#xff1a; 1.是作为放大器获得所需要的驱动电压。 2.是提高输出电流能力。 3.是进行功率回路和控制回路的隔离 信号从MCU到IGBT驱动芯片 首先驱动电流需要放大 MCU的输出电流是mA级别&#xff0c;而IGBT需要的驱动电流可能达到几安培…

基于小程序+ssm实现的悬赏信息发布系统

作者主页&#xff1a;Java码库 主营内容&#xff1a;SpringBoot、Vue、SSM、HLMT、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、小程序、安卓app等设计与开发。 收藏点赞不迷路 关注作者有好处 文末获取源码 技术选型 【后端】&#xff1a;Java 【框架】&#xff1a;ssm 【…

ubuntu系统安装k8s1.28精简步骤

目录 一、规划二、环境准备2.1 配置apt仓库配置系统基本软件仓库配置k8s软件仓库安装常用软件包 2.2 修改静态ip、ntp时间同步、主机名、hosts文件、主机免密2.3 内核配置2.4 关闭防火墙、selinux、swap2.5 安装软件安装docker安装containerd安装k8s软件包 三、安装配置k8s3.1 …

【linux】基础IO(三)

上一节基础IO我们着重理解了重定向与缓冲区&#xff0c;这节我们需要重点理解文件再磁盘中是怎样存储。以及上一节我们没有涉及到的知识。 stderr到时有什么用&#xff1f; 目录 fd-> 0 1 2&#xff1a;初步理解2怎样将错误与正确输出都打印在一个文件&#xff1f; 文件在硬…

如何从应用商店Microsoft Store免费下载安装HEVC视频扩展插件

在电脑上打开一张HEIC类型的图片提示缺少HEVC解码器&#xff0c;无法打开查看&#xff0c;现象如下&#xff1a; 这种情况一般会提示我们需要下载安装HEVC解码器&#xff0c;点击“立即下载并安装”会跳转到应用商店&#xff0c;但是我们发现需要付费7元才能下载安装 免费安装…

独家福利:Figma汉化大礼包,让UI设计零障碍!快来领取吧!

Figma是国外开发的软件。全英文页面限制了国内很多UI设计师的发挥&#xff0c;只能用Figma中文插件中文使用。Figma中文插件虽然不如中文版好用&#xff0c;但基本可以理解意思。那么Figma中文插件在哪里可以下载呢&#xff1f;下面介绍两种Figma中文插件的下载和安装方法&…

Redis数据库②高可用+持久化+性能管理

目录 一.高可用 二.持久化 1.Redis 提供两种方式进行持久化 2.RDB 持久化 &#xff08;1&#xff09;手动触发 &#xff08;2&#xff09;自动触发 &#xff08;3&#xff09;执行流程 &#xff08;4&#xff09;启动时加载 3.AOF持久化 &#xff08;1&#xff09;开…

如何进行软件质量评估?

一、为何评估 软件质量评估的重要性体现在以下几个关键方面&#xff1a; 确保用户需求满足&#xff1a; 软件质量评估首先是为了确保软件产品能够准确、完整地满足用户的需求。通过评估&#xff0c;可以发现软件在功能、性能、安全性等方面的不足之处&#xff0c;及时进行修正…

uniapp中自定义tabbar无法跳转?如何解决

&#x1f3c6;本文收录于「Bug调优」专栏&#xff0c;主要记录项目实战过程中的Bug之前因后果及提供真实有效的解决方案&#xff0c;希望能够助你一臂之力&#xff0c;帮你早日登顶实现财富自由&#x1f680;&#xff1b;同时&#xff0c;欢迎大家关注&&收藏&&…

0基础如何进入IT行业?一文揭秘成功蜕变之路!|TodayAI

一、引言 在数字化转型的浪潮下&#xff0c;IT行业的魅力日益增强&#xff0c;吸引了大量跨领域人才的关注。然而&#xff0c;对于那些零基础的人来说&#xff0c;进入这个充满机遇和挑战的领域似乎是一条充满未知和困难的道路。本文旨在探讨零基础者如何通过有效的学习路径、…

1688详情API接口:解锁多元化应用场景java php c++

随着互联网的快速发展&#xff0c;数据交换和信息共享已成为企业日常运营不可或缺的一部分。在这样的背景下&#xff0c;API&#xff08;应用程序接口&#xff09;接口作为实现数据互通的重要工具&#xff0c;受到了越来越多企业的青睐。1688详情API接口作为阿里巴巴旗下的重要…

Games101Homework【6】Acceleration structure(Including framework analysis)

Code Analysis&#xff1a; friend&#xff1a; C中友元&#xff08;友元函数和友元类&#xff09;的用法和功能_friend class a<b>-CSDN博客 [C&#xff1a;不如Coding]&#xff08;11&#xff09;&#xff1a;友元函数与友元类_哔哩哔哩_bilibili Here is a simple…

C++模仿qq界面

#include "mywidget.h"MyWidget::MyWidget(QWidget *parent): QWidget(parent) {//设置窗口的大小this->resize(645,497);//设置窗口名字this->setWindowTitle("QQ");//设置窗口图标this->setWindowIcon(QIcon("C:\\zhouzhouMyfile\\qt_proj…

C语言结构体大小

1、结构体成员类型 结构体成员的类型&#xff0c;不同的结构体成员占用的内存大小不同 2、结构体对齐 为了提高内存访问的效率&#xff0c;编译器会对结构体进行对齐。对齐的方式是按照成员的类型和顺序来进行的。对齐的目的是为了让结构体成员的地址能够被整除&#xff0c;从…

✌2024/4/3—力扣—字符串转换整数

代码实现&#xff1a; int myAtoi(char *str) {long ret 0;int flag 1; // 默认正数// 去除空格及判断符号位while (*str ) {str;}if (*str -) {flag -1;str;} else if (*str ) {str;}// 排除非数字的情况if (*str < 0 || *str > 9) {return 0;}while (*str > …

[C++][算法基础]堆排序(堆)

输入一个长度为 n 的整数数列&#xff0c;从小到大输出前 m 小的数。 输入格式 第一行包含整数 n 和 m。 第二行包含 n 个整数&#xff0c;表示整数数列。 输出格式 共一行&#xff0c;包含 m 个整数&#xff0c;表示整数数列中前 m 小的数。 数据范围 1≤m≤n≤&#x…

真实的招生办对话邮件及美国高校官网更新的反 AI 政策

这两年 ChatGPT 的热度水涨船高&#xff0c;其编写功能强大&#xff0c;且具备强大的信息整合效果&#xff0c;所以呈现的内容在一定程度上具备可读性。 那么&#xff0c;美国留学文书可以用 ChatGPT 写吗&#xff1f;使用是否有风险&#xff1f;外网博主 Kushi Uppu 在这个申…

C++ vector顺序表模拟实现

目录 前言&#xff1a; 模拟实现&#xff1a; 构造函数&#xff1a; 析构函数&#xff1a; 容量调整&#xff08;reserve&#xff09;&#xff1a; resize函数&#xff1a; 尾插&#xff08;push_back&#xff09;: 尾删&#xff08;pop_back&#xff09;: 插入&#xff…

基于Spring boot+Vue的业余排球俱乐部会员管理系统

5 系统功能模块的具体实现 5.1超级会员角色 5.1.1 登录 超级管理员登录通过用户名和密码去数据库查询用户表&#xff0c;该名称是否在用户表中存在&#xff0c;如果存在&#xff0c;则通过用户名和密码查询密码是否正确&#xff0c;然后吧用户的信息存在jwt的负载里&#xf…