实用篇-ES-RestClient查询文档

一、快速入门

上面的查询文档都是依赖kibana，在浏览器页面使用DSL语句去查询es，如何用java去查询es里面的文档(数据)呢
我们通过match_all查询来演示基本的API，注意下面演示的是 'match_all查询，也叫基础查询'
首先保证你已经做好了 '实用篇-ES-环境搭建' ，创建了名为gghotel的索引库，然后开始下面的操作。如果需要浏览器操作es，那就不需要启动kibana容器

在进行下面的操作之前，确保你已经看了前面 '实用篇-ES-RestClient操作文档' 学的 '1. RestClient案例准备'，然后在进行下面的操作


第一步: 在src/test/java/cn.itcast.hotel目录新建HotelSearchTest类，写入如下

package cn.itcast.hotel;import cn.itcast.hotel.service.IHotelService;
import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.io.IOException;@SpringBootTest
public class HotelIndexTest2 {private RestHighLevelClient client;@Autowiredprivate IHotelService hotelService;@Testvoid init(){System.out.println(client);}@BeforeEachvoid setUp(){this.client = new RestHighLevelClient(RestClient.builder(//指定你Centos7部署的es的主机地址HttpHost.create("http://192.168.229.129:9200")));}@AfterEachvoid tearDown() throws IOException {this.client.close();}@Testvoid testMatchAll() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数request.source().query(QueryBuilders.matchAllQuery());//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);System.out.println(response);}}

第二步: 把控制台里面我们需要的数据解析出来。返回的数据很多，我们主要是解析hits里面的数据就行了

把HotelSearchTest类修改为如下，主要的修改是sout之前做了一次解析，拿到我们想要的数据

package cn.itcast.hotel;import cn.itcast.hotel.pojo.HotelDoc;
import cn.itcast.hotel.service.IHotelService;
import com.alibaba.fastjson.JSON;
import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.io.IOException;@SpringBootTest
public class HotelIndexTest2 {private RestHighLevelClient client;@Autowiredprivate IHotelService hotelService;@Testvoid init(){System.out.println(client);}@BeforeEachvoid setUp(){this.client = new RestHighLevelClient(RestClient.builder(//指定你Centos7部署的es的主机地址HttpHost.create("http://192.168.229.129:9200")));}@AfterEachvoid tearDown() throws IOException {this.client.close();}@Testvoid testMatchAll() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数request.source().query(QueryBuilders.matchAllQuery());//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共有" + total + "条数据");SearchHit[] hits = searchHits.getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();//反系列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);System.out.println("hotelDoc = " + hotelDoc);}}}

二、match的三种查询

我们刚刚在第一节演示的是 match_all(也叫基本查询) 查询，下面将演示 match(也叫单字段查询) 和 multi_match(也叫多字段查询) 查询

【match 查询，也叫单字段查询】

在HotelSearchTest类添加如下

 @Testvoid testMatch() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数request.source().query(QueryBuilders.matchQuery("name","如家"));//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共有" + total + "条数据");SearchHit[] hits = searchHits.getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();//反系列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);System.out.println("hotelDoc = " + hotelDoc);}}

【multi_match 查询，也叫多字段查询】

在HotelSearchTest类添加如下

  @Testvoid testMatch() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数request.source().query(QueryBuilders.multiMatchQuery("如家","name","business"));//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共有" + total + "条数据");SearchHit[] hits = searchHits.getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();//反系列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);System.out.println("hotelDoc = " + hotelDoc);}}

总结: 要构建查询条件，只要记住一个QueryBuilders类即可

三、解析代码的抽取

我们发现对于 match、multi_match、match_all 查询，的解析部分的代码都是相同的，所以我们可以对解析部分的代码进行抽取，如下

快捷键ctrl + alt + M

  private void handleResponse(SearchResponse response) {//下面为逐层解析json数据SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共有" + total + "条数据");SearchHit[] hits = searchHits.getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();//反系列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);System.out.println("hotelDoc = " + hotelDoc);}}

之后我们在test中只专注于json的获取，解析的任务交给这段代码 

四、bool和term、rang精确查询

原理同上

我们直接演示bool复合查询 

 

 @Testvoid testBool() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();boolQuery.must(QueryBuilders.termQuery("city","杭州"));boolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));request.source().query(boolQuery);//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);handleResponse(response);}

五、排序和分页

 @Testvoid testPageAndSort() throws IOException {int pageNum = 1;int pageSize = 5;//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数//查询所有request.source().query(QueryBuilders.matchAllQuery());//排序request.source().sort("price", SortOrder.ASC);//分页request.source().from(pageNum - 1).size(pageSize);//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);handleResponse(response);}

六、高亮显示

 高亮API包括请求DSL构建和结果解析两部分，API和对应的DSL语句如下图，下图只是构建，再下面还有解析，高亮必须由构建+解析才能实现

解析，如下图 

  @Testvoid testHighLight() throws IOException {//准备RequestSearchRequest request = new SearchRequest("hotel");//组织DSL参数//查询所有request.source().query(QueryBuilders.matchQuery("name","如家"));//设置高亮匹配方式request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));//发送请求，得到响应结果SearchResponse response = client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共有" + total + "条数据");SearchHit[] hits = searchHits.getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();//反系列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);//解析，获取高亮结果Map<String, HighlightField> highlightFields = hit.getHighlightFields();if(!CollectionUtils.isEmpty(highlightFields)){//根据字段名获取高亮结果HighlightField highlightField = highlightFields.get("name");//判断高亮字段不为空if(highlightField!=null){//获取高亮值String name = highlightField.getFragments()[0].string();//覆盖非高亮结果hotelDoc.setName(name);}}//最终输出System.out.println("hotelDoc = " + hotelDoc);}}

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

保姆级 | Nginx编译安装

保姆级 | Nginx编译安装

0x00 前言 Nginx 是一个 HTTP 和反向代理服务器&#xff0c; 邮件代理服务器&#xff0c; 和通用 TCP/UDP 代理服务器&#xff0c; 最初由伊戈尔西索耶夫&#xff08;Igor Sysoev&#xff09;撰写。采用编译安装可以根据自身需要自定义配置&#xff0c;让服务器有更高的安全性和…
阅读更多...
OpenAI GPT-4 Turbo发布：开创AI新时代

OpenAI GPT-4 Turbo发布：开创AI新时代

&#x1f3a5; 屿小夏 &#xff1a; 个人主页 &#x1f525;个人专栏 &#xff1a; IT杂谈 &#x1f304; 莫道桑榆晚&#xff0c;为霞尚满天&#xff01; 文章目录 &#x1f4d1;前言一. GPT-4 Turbo的突破1.1上下文长度和控制手段的加强&#xff1a;1.2多模态支持&#xff1a…
阅读更多...
【教3妹学编程-java基础6】详解父子类变量、代码块、构造函数执行顺序

【教3妹学编程-java基础6】详解父子类变量、代码块、构造函数执行顺序

-----------------第二天------------------------ 本文先论述父子类变量、代码块、构造函数执行顺序的结论&#xff0c; 然后通过举例论证&#xff0c;接着再扩展&#xff0c;彻底搞懂静态代码块、动态代码块、构造函数、父子类、类加载机制等知识体系。 温故而知新&#xff…
阅读更多...
Windows下安装RabbitMQ

Windows下安装RabbitMQ

1.安装Erlang 因为RabbitMQ是用Erlang语言编写的&#xff0c;所以在安装RabbitMQ之前需要先安装Erlang。 如果还未安装Erlang&#xff0c;官方下载安装包&#xff0c;点击Download Windows installer下载Erlang Downloads - Erlang/OTP 下载Erlang/OTP后&#xff0c;双击otp的…
阅读更多...
系统韧性研究（5）| 常用的系统韧性技术

系统韧性研究（5）| 常用的系统韧性技术

如果不利事件或条件导致系统无法正常运行&#xff0c;则它们可能会对有价值的资产造成各种形式的损害。正如我在本系列的前几篇文章中概述的那样&#xff0c;系统韧性很重要&#xff0c;因为没有人想要一个无法克服“不可避免的逆境”的脆弱系统。 在本系列的第一篇文章中&…
阅读更多...
Express.js 与 Nest.js对比

Express.js 与 Nest.js对比

Express.js 与 Nest.js对比 自从 Node.js 发布以来&#xff0c;Javascript 在后端领域的使用有所增加。由于 Node.js 的使用越来越多&#xff0c;每天都会有新的框架和工具发布。Express 和 Nest 是使用 Node.js 创建后端应用程序的最著名的框架之一&#xff0c;在本文中&…
阅读更多...
JVM判断对象是否存活之引用计数法、可达性分析

JVM判断对象是否存活之引用计数法、可达性分析

目录 前言 引用计数法 概念 优点 缺点 可达性分析 概念 缺点&#xff1a; 扩展&#xff1a; 1.GC Roots 概念 2.STW (Stop the world) 前言 JVM有两种算法来判断对象是否存活&#xff0c;分别是引用计数法和可达性分析算法&#xff0c;针对可达性分析算法STW时间长、…
阅读更多...
阿里AoneFlow分支管理

阿里AoneFlow分支管理

分支模式 1.TrunkBased模式 工作方式 TrunkBased 模式是持续集成思想所崇尚的工作方式&#xff0c;它由单个主干分支和许多发布分支组成&#xff0c;每个发布分支在特定版本的提交点上从主干创建出来&#xff0c;用来进行上线部署和 Hotfix&#xff08;补丁&#xff09;。 …
阅读更多...
workman使用手册1.0

workman使用手册1.0

workman官网地址&#xff1a;高性能PHP应用容器 workerman 1&#xff1a;把workman项目放到linux服务器后&#xff0c;需要启动你的php文件&#xff0c;才可以使用 定位到项目根目录&#xff1a;例&#xff1a;cd /mnt/workman 启动代码&#xff1a;php outin.php start -d 停…
阅读更多...
Python小白之PyCharm仍然显示“No module named ‘xlwings‘”

Python小白之PyCharm仍然显示“No module named ‘xlwings‘”

Python小白之“没有名称为xlwings‘的模块”-CSDN博客文章浏览阅读8次。cmd 打开命令行&#xff0c;输入python出现>>>的提示格&#xff0c;输入import xlwings 回车&#xff0c;正常报错&#xff1a;No module named xlwings。输入python 回车后&#xff0c;再输入im…
阅读更多...
单片机，0.07

单片机，0.07

阅读更多...
mongodb使用简单文档

mongodb使用简单文档

1、mongodb安装与卸载 1.1、安装 python -m pip install pymongo 或 pip install pymongo如果要安装指定版本&#xff1a; python -m pip install pymongo3.5.1对已有的版本进行升级&#xff1a; python -m pip install --upgrade pymongo1.2、卸载 pip uninstall pymongo…
阅读更多...
环境配置 | Git的安装及配置[图文详情]

环境配置 | Git的安装及配置[图文详情]

Git是一个开源的分布式版本控制系统&#xff0c;可以有效、高速地处理从小到大的项目版本管理。下面介绍了基础概念及详细的用图文形式介绍一下git安装过程. 目录 1.Git基础概念 2.Git的下载及安装 3.常见的git命令 Git高级技巧 Git与团队协作 1.Git基础概念 仓库&#…
阅读更多...
我认为除了HelloWorld之外，Python的三大数据转换实例可以作为开始学习Python的入门语言。

我认为除了HelloWorld之外，Python的三大数据转换实例可以作为开始学习Python的入门语言。

Python的三大数据转换实例 一、反转三位数 class Solution:def funtcion(self,number):hint(number/100)tint(number%100/10)zint(number%10)return 100*z10*th if __name____main__:solution Solution()num123new_num solution.funtcion(num)print("输入:{}".fo…
阅读更多...
制作Go程序的Docker容器

制作Go程序的Docker容器

今天突然遇到需要将 Go 程序制作成 Docker 的需求&#xff0c;所以进行了一些研究。方法很简单&#xff0c;但是官方文档和教程有些需要注意的地方&#xff0c;所以写本文进行记录。 源程序 首先介绍一下示例程序&#xff0c;示例程序是一个 HTTP 服务器&#xff0c;会显示si…
阅读更多...
基于DOTween插件实现金币飞行到指定位置功能

基于DOTween插件实现金币飞行到指定位置功能

文章目录 前言一、DOTween是什么&#xff1f;二、使用步骤1.导入DOTween插件在Unity官方插件商店找到DOTween插件导入DOTween插件启用DOTween插件 2.代码逻辑金币飞行代码控制飞行效果代码 3.物体配置1.物体上装配CoinEffect脚本2.在金币预制体上装配FlyControl脚本 三、效果展…
阅读更多...
基于SpringBoot的SSMP整合案例（消息一致性处理与表现层开发）

基于SpringBoot的SSMP整合案例（消息一致性处理与表现层开发）

消息一致性处理 在后端执行完相应的操作后&#xff0c;我们需要将执行操作后的结果与数据返回前端&#xff0c;前端 调用我们传回去的数据&#xff0c;前端是如何知道我们传回去的数据名称的&#xff1f; 答&#xff1a;前后端遵循了同一个"协议"。这个协议就是定义…
阅读更多...
单例模式（常用）

单例模式（常用）

单例模式&#xff08;单例设计模式) 在有些系统中&#xff0c;为了节省内存资源、保证数据内容的一致性&#xff0c;对某些类要求只能创建一个实例&#xff0c;这就是所谓的单例模式。 单例模式的定义与特点 单例&#xff08;Singleton&#xff09;模式的定义&#xff1a;指…
阅读更多...
Stable Diffusion1.5网络结构-超详细原创

Stable Diffusion1.5网络结构-超详细原创

目录 1 Unet 1.1详细整体结构 1.2 缩小版整体结构 1.3 时间步编码 1.4 CrossAttnDownBlock2D 1.4.1 ResnetBlock2D 1.4.2 Transformer2DModel 1.4.2.1 BasicTransformerBlock 1.4.2.1.1 SelfAttention 1.4.2.1.2 CrossAttention 1.4.2.1.3 FeedForward 1.4.3 DownS…
阅读更多...
【数据库】数据库连接池导致系统吞吐量上不去-复盘

【数据库】数据库连接池导致系统吞吐量上不去-复盘

在实际的开发中&#xff0c;我们会使用数据库连接池&#xff0c;但是如果不能很好的理解其中的含义&#xff0c;那么就可以出现生产事故。 HikariPool-1 - Connection is not available, request timed out after 30001ms.当系统的调用量上去&#xff0c;就出现大量这样的连接…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023