实用篇-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.mzph.cn/news/145052.shtml

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

相关文章

【flutter】使用getx下的GetMaterialApp创建路由和使用时间选择器国际化问题

【flutter】使用getx下的GetMaterialApp创建路由和使用时间选择器国际化问题

GetMaterialApp是啥 网上解释说是 MaterialApp Getx properties GetMaterialApp 问题 在使用showDateRangePicker组件的时候&#xff0c; 一直报错 No MaterialLocalizations found 我就愁思是不是GetMaterialApp跟MaterialApp方法不一样的问题&#xff0c;结果不是&#…
阅读更多...
Spark数据倾斜_产生原因及定位处理办法_生产环境

Spark数据倾斜_产生原因及定位处理办法_生产环境

在最近的项目中&#xff0c;历史和实时数据进行关联平滑时出现了数据倾斜&#xff0c;产生了笛卡尔积&#xff0c;具体现象如下&#xff1a;运行内存175GB&#xff0c;核数64&#xff0c;运行代码时&#xff0c;查看SparkUI界面的active jobs &#xff0c;数据输入是1G&#xf…
阅读更多...
java初探之代理模式

java初探之代理模式

代理模式 代理模式一般有三种角色&#xff1a; 没有使用代理模式的话可能就会直接去操作真实的对象 加入代理模式就是加入了 隔离 把我们的真实对象与调用者隔离了一下(代理对象) 代理对象的好处&#xff1f; 使用者(client)跟真实的对象是没有直接的交集的。不会直接操作到…
阅读更多...
Bash openldap同步AD组织数据

Bash openldap同步AD组织数据

将AD的ou同步到openldap&#xff08;可支持全量同步和增量同步&#xff09; 整体思路如下&#xff1a; 从ad导出所有的数据&#xff0c;然后进行参数替换以及处理&#xff0c;处理后的文件称为A&#xff1b;从openldap导出所有的数据&#xff0c;然后进行参数替换以及处理&am…
阅读更多...
国内crm解决方案的主要提供商有哪些？对比7家

国内crm解决方案的主要提供商有哪些？对比7家

目前国内CRM服务商1410家&#xff0c;今年1-7月CRM服务商新注册19家。如何从众多服务商中挑选出合适的一家&#xff0c;无疑是一项耗时耗力的大工程。为此&#xff0c;本文将为根据国内外知名机构、媒体、网站发布、百度指数、行业知名度等维度考量&#xff0c;选择出7大CRM系统…
阅读更多...
Go语言常用库

Go语言常用库

Go语言常用库 文本主要介绍Go常用的一些系统库&#xff1a; sort、math、copy、strconv、crypto 1、sort package mainimport ("fmt""sort" )// sort // int排序 // sort.Ints([]int{}) // 字符串排序 // sort.Strings([]string{}) // 自定义排序 // s…
阅读更多...
【Proteus仿真】【51单片机】锂电池管理系统

【Proteus仿真】【51单片机】锂电池管理系统

文章目录 一、功能简介二、软件设计三、实验现象联系作者 一、功能简介 本项目使用Proteus8仿真51单片机控制器&#xff0c;使用LCD1602显示模块、DS18B20温度传感器、PCF8691 ADC模块、按键、LED蜂鸣器模块等。 主要功能&#xff1a; 系统运行后&#xff0c;LCD1602显示温度…
阅读更多...
MFC保存窗口客户区为图片

MFC保存窗口客户区为图片

首先的窗口输出一些内容&#xff1b; 菜单单击函数代码&#xff1b; void CgetmypicView::OnTestGetmypic() {// TODO: 在此添加命令处理程序代码HWND hwnd this->GetSafeHwnd();HDC hDC ::GetWindowDC(hwnd);//获取DC RECT rect;::GetClientRect(hwnd, &rect)…
阅读更多...
C/C++输出整数部分 2021年12月电子学会青少年软件编程（C/C++）等级考试一级真题答案解析

C/C++输出整数部分 2021年12月电子学会青少年软件编程（C/C++）等级考试一级真题答案解析

目录 C/C输出整数部分 一、题目要求 1、编程实现 2、输入输出 二、算法分析 三、程序编写 四、程序说明 五、运行结果 六、考点分析 C/C输出整数部分 2021年12月 C/C编程等级考试一级编程题 一、题目要求 1、编程实现 输入一个双精度浮点数f&#xff0c; 输出其整…
阅读更多...
【0234】PgBackendStatus 记录当前postgres进程的活动状态

【0234】PgBackendStatus 记录当前postgres进程的活动状态

1. 关于PgBackendStatus 每个存活的后端进场在共享内存中维护一个PgBackendStatus结构体，显示其当前活动状态。(结构体是根据BackendId分配的，但这并不重要。) 请注意： 进场状态收集器进程不参与、甚至不访问这些结构。 每个辅助进程还在共享内存中维护一个PgBackendStatu…
阅读更多...
【918.环形子数组的最大和】

【918.环形子数组的最大和】

目录 一、题目描述二、算法原理三、代码实现 一、题目描述 二、算法原理 三、代码实现 class Solution { public:int maxSubarraySumCircular(vector<int>& nums) {int sum0;for(auto x:nums) sumx;vector<int> f(nums.size());vector<int> g(nums.size…
阅读更多...
JS-项目实战-点击水果名修改特定水果库存记录

JS-项目实战-点击水果名修改特定水果库存记录

1、fruit.js function $(name) {if (name) {//假设name是 #fruit_tblif (name.startsWith("#")) {name name.substring(1); //fruit_tblreturn document.getElementById(name);} else {return document.getElementsByName(name); //返回的是NodeList类型}} }//当…
阅读更多...
2源码安装网络协议

2源码安装网络协议

2.2源码安装/网络协议 一、源码包应用场景 有时我们所用的内核版本太旧&#xff0c;系统自带的库&#xff08;如libstdc.so.6&#xff09;版本低或者依赖的其他软件版 本较低&#xff0c;导致无法安装目标软件。 软件/库其实是对机器汇编指令集的封装&#xff0c;在X86体系下…
阅读更多...
机器视觉公司怎么可能养我这闲人，连软件加密狗都用不起，项目都用盗版，为什么​？

机器视觉公司怎么可能养我这闲人，连软件加密狗都用不起，项目都用盗版，为什么​？

正版价值观我是认同的&#xff0c;但是同行也不用软件加密狗&#xff0c;你让我承担过多的设备成本&#xff0c;终端客户不愿意承担加密狗的成本&#xff0c;公司更不愿意去承担&#xff0c;许多机器视觉公司“零元购”&#xff0c;机器视觉软件加密狗都用不起&#xff0c;项目…
阅读更多...
48v变12v同步转换芯片

48v变12v同步转换芯片

48v变12v同步转换芯片 以下是一篇关于48V变12V同步转换器WD5105ic的文章正文&#xff1a;48V变12V同步转换器WD5105ic是一种电源管理芯片&#xff0c;它可以将48V的直流电压转换为12V的直流电压。这款芯片具有广泛的应用范围&#xff0c;包括车载充电器件、电动车仪表器件、电…
阅读更多...
基于SSM的智慧养老平台设计与实现

基于SSM的智慧养老平台设计与实现

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;采用JSP技术开发 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#x…
阅读更多...
C#特性Attribute

C#特性Attribute

C# 特性&#xff08;Attributes&#xff09;是用于在运行时为程序元素&#xff08;如类、方法、属性等&#xff09;添加声明性信息的一种方式。这些信息可以在程序运行时通过反射&#xff08;Reflection&#xff09;访问。特性可以用来控制程序行为、添加元数据或者影响程序的运…
阅读更多...
郑州大学2020级信息安全专业——保研小结

郑州大学2020级信息安全专业——保研小结

最终上岸 夏令营&#xff1a; 夏令营开始的时间一般比较早&#xff0c;在期末考试之前就已经开始了&#xff0c;需要提前联系导师&#xff0c;有的学校是弱com&#xff0c;导师愿意要你入营的概率和优营的概率就会比较大&#xff0c;因此要提前联系导师&#xff0c;复习好项目…
阅读更多...
51单片机应用从零开始（五）·加减乘除运算

51单片机应用从零开始（五）·加减乘除运算

51单片机应用从零开始&#xff08;一&#xff09;-CSDN博客 51单片机应用从零开始&#xff08;二&#xff09;-CSDN博客 51单片机应用从零开始&#xff08;三&#xff09;-CSDN博客 51单片机应用从零开始&#xff08;四&#xff09;-CSDN博客 详解 KEIL C51 软件的使用建立工程…
阅读更多...
conan 入门指南

conan 入门指南

conan 新手入门 1 需要注意的事项2 使用 Poco 库的 MD5 哈希计算器2.1 创建源文件2.2 搜索poco conan 库2.3 获取poco/1.9.4的元数据2.4 创建conanfile.txt2.5 安装依赖2.6 创建编译文件2.7 构建和运行程序 3 安装依赖程序4 检查依赖关系5 搜索软件包6 与其他配置一起构建 该篇…
阅读更多...
最新文章

Copyright @ 2022~2023