ElasticSearch学习5-- 使用RestClient查询文档

1、查询基本步骤

1、创建SearchRequest对象
2、准备Request.source()，也就是DSL。
        QueryBuilders来构建查询条件
       传入Request.source() 的 query() 方法
3、发送请求，得到结果
4、解析结果（参考JSON结果，从外到内，逐层解析）

RestAPI中其中构建DSL是通过HighLevelRestClient中的resource()返回的SearchSourceBuilder来实现的，其中包含了查询、排序、分页、高亮等所有功能

SearchSourceBuilder 进行查询、排序、分页、高亮

RestAPI中其中构建查询条件的核心部分是由一个名为QueryBuilders的工具类提供的，其中包含了各种查询方法。

QueryBuilders 进行match_all /match /multi_match /term /range/boolmatch等查询

查询所有

    @Testpublic void testMatchAll() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是所有查询MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery();//将查询条件赋值给查询语句request.source().query(matchAllQueryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}

2、多种检索查询

match、multi_match查询

    @Testpublic void testMatchQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是所有查询MatchQueryBuilder queryBuilder = QueryBuilders.matchQuery("fileId","赎吧");//将查询条件赋值给查询语句request.source().query(queryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}
@Testpublic void testMultiMatchQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是所有查询MultiMatchQueryBuilder queryBuilder = QueryBuilders.multiMatchQuery("B端赎吧","fileId","caseDes");//将查询条件赋值给查询语句request.source().query(queryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}

term 、range查询

@Testpublic void testTermQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是所有查询TermQueryBuilder queryBuilder = QueryBuilders.termQuery("oa","lilan04");//将查询条件赋值给查询语句request.source().query(queryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}@Testpublic void testRangeQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("test_1");//构建查询条件，下边是所有查询RangeQueryBuilder queryBuilder = QueryBuilders.rangeQuery("age").gte(10).lte(20);//将查询条件赋值给查询语句request.source().query(queryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}

布尔查询

 @Testpublic void testBooleanQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是所有查询BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();queryBuilder.must(QueryBuilders.matchQuery("oa","lilan04"));queryBuilder.should(QueryBuilders.rangeQuery("editTime").gte(1684740000000L).lte(1684740070219l));queryBuilder.filter(QueryBuilders.termQuery("isDelete",1));//将查询条件赋值给查询语句request.source().query(queryBuilder);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}

分页、排序、高亮查询

@Testpublic void testSortQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是布尔查询BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();queryBuilder.must(QueryBuilders.matchQuery("oa","lilan04"));queryBuilder.should(QueryBuilders.rangeQuery("editTime").gte(1684740000000L).lte(1684740070219l));queryBuilder.filter(QueryBuilders.termQuery("isDelete",1));//将查询条件赋值给查询语句request.source().query(queryBuilder);//排序request.source().sort("editTime", SortOrder.ASC);//分页request.source().from(1).size(10);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);}@Testpublic void testHightLightQuery() throws IOException {//创建查询请求，指定要查询的索引库SearchRequest request = new SearchRequest("case_management");//构建查询条件，下边是布尔查询BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();queryBuilder.must(QueryBuilders.matchQuery("oa","lilan04"));queryBuilder.should(QueryBuilders.rangeQuery("editTime").gte(1684740000000L).lte(1684740070219l));queryBuilder.filter(QueryBuilders.termQuery("isDelete",1));//将查询条件赋值给查询语句request.source().query(queryBuilder);//自定义高亮 查找HighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.preTags("<font color='red'>");highlightBuilder.postTags("</font>");highlightBuilder.field("oa");// highlightBuilder.requireFieldMatch(false); //多字段时，需要设置为false// request.source().highlighter(highlightBuilder);//排序request.source().sort("editTime", SortOrder.ASC);//分页request.source().from(1).size(10);//进行查询SearchResponse response = client.search(request, RequestOptions.DEFAULT);System.out.println("respon话费时间 " + response.getTook());//对结果进行处理SearchHits hits = response.getHits();//返回结果列表SearchHit[] hitsList = hits.getHits();//总数long totalHits = hits.getTotalHits();System.out.println(totalHits);SearchHit documentFields = hitsList[0];String json = documentFields.getSourceAsString();System.out.println(json);//获取到高亮字段System.out.println(documentFields.getHighlightFields());}

3、错误解决

场景

    ES对text类型的字段进行聚合操作的时候, 报 Fielddata is disabled on text fields by default. Set fielddata=true on [make] in order to load fielddata in memory by uninverting the inverted index. Note that this can however use significant memory. Alternatively use a keyword field instead.

分析

    官方文档
    sort, aggregate, or access values from a script on a text field 这些行为会需要从内存中加载数据, 但是text类型的数据可能会消耗非常多内存, 另外可能会导致查询延迟, 所以默认不允许对text字段这样操作
所以最好对非text类型字段进行排序等操作

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

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

相关文章

国标视频融合云平台EasyCVR视频汇聚平台关于远程控制的详细介绍

国标视频融合云平台EasyCVR视频汇聚平台关于远程控制的详细介绍

EasyCVR国标视频融合云平台是一个能在复杂网络环境下统一汇聚、整合和集中管理各类分散视频资源的平台。该平台提供了多种视频能力和服务&#xff0c;包括视频监控直播、云端录像、云存储、录像检索与回看、智能告警、平台级联、集群、电子地图、H.265视频自动转码和智能分析等…
阅读更多...
几种Go版本管理工具

几种Go版本管理工具

缘起: 编译下面这段代码时,在Mac上没有什么问题,正常运行, 点击查看代码: package mainimport ( "bytes" "encoding/binary" "encoding/json" "fmt" "log" "math/rand" "net/http" "time")fu…
阅读更多...
C++包含整数各位重组

C++包含整数各位重组

void 包含整数各位重组() {//缘由https://bbs.csdn.net/topics/395402016int shu 100000, bs 4, bi shu * bs, a 0, p 0, d 0;while (shu < 500000)if (a<6 && (p to_string(shu).find(to_string(bi)[a], p)) ! string::npos && (d to_string(bi…
阅读更多...
C++ 获取进程信息

C++ 获取进程信息

1. 概要 通常对于一个正在执行的进程而言&#xff0c;我们会关注进程的内存/CPU占用&#xff0c;网络连接&#xff0c;启动参数&#xff0c;映像路径&#xff0c;线程&#xff0c;堆栈等信息。 而通过类似任务管理器&#xff0c;命令行等方式可以轻松获取到这些信息。但是&…
阅读更多...
实现一个简单的控制台版用户登陆程序, 程序启动提示用户输入用户名密码. 如果用户名密码出错, 使用自定义异常的方式来处理

实现一个简单的控制台版用户登陆程序, 程序启动提示用户输入用户名密码. 如果用户名密码出错, 使用自定义异常的方式来处理

//密码错误异常类 public class PasswordError extends Exception {public PasswordError(String message){super(message);} }//用户名错误异常类 public class UserError extends Exception{public UserError(String message){super(message);} }import java.util.Scanner;pu…
阅读更多...
Vue之html中特殊符号的展示

Vue之html中特殊符号的展示

Vue之html中特殊符号的展示 在html中使用特殊字符时直接展示会报错&#xff0c;需要使用实体名称或者实体编号才能展示。 最常用的字符实体 显示结果 描述 实体名称 实体编号空格 < 小于号 < &…
阅读更多...
代码随想录 - Day32 - 回溯：组合问题

代码随想录 - Day32 - 回溯：组合问题

代码随想录 - Day32 - 回溯&#xff1a;组合问题 39. 组合总和 做题的时候遇到一点疑问&#xff1a; 为什么必须是result.append(path[:])而不能写成result.append(path)呢&#xff1f; 原因&#xff1a; result.append(path)往result中添加的是path这个参数&#xff0c;后续…
阅读更多...
java内存溢出问题分析记录

java内存溢出问题分析记录

最好找到必现流程在idea-VMOption中输入参数&#xff1a; -XX:HeapDumpOnOutOfMemoryError将会在内存溢出发生时&#xff0c;在项目根目录生成dump文件。 打开jdk自带的分析工具java visualVM&#xff0c;可以打开该文件&#xff0c;定位到内存溢出发生的代码位置。 分析该位…
阅读更多...
【CicadaPlayer】seek ：SeekInCache(int64_t pos)的实现

【CicadaPlayer】seek ：SeekInCache(int64_t pos)的实现

SuperMediaPlayer::SeekInCache(int64_t pos) 的实现 seek的pos就是pts值。缓冲是list，那么插入的包是按照到达的顺序插入到list的，也就是无排序的。包的pts 正常应该单调连续，即使不单调连续，缓存也不在意。seek的操作主要是先比较pos与mCurrentPos ，pos 比 mCurrentPos …
阅读更多...
WPF数据模板

WPF数据模板

样式提供了基本的格式化能力&#xff0c;但它们不能消除到目前为止看到的列表的最重要的局限性&#xff1a;不管如何修改ListBoxItem&#xff0c;它都只是ListBoxItem&#xff0c;而不是功能更强大的元素组合。并且因为每个ListBoxItem只支持单个绑定字段&#xff0c;所以不可能…
阅读更多...
springboot实现发送短信验证码

springboot实现发送短信验证码

目录 一、选择并注册短信服务提供商&#xff1a; 二、添加依赖&#xff1a; 三、配置短信服务信息&#xff1a; 四、编写发送短信验证码的方法&#xff1a; 五、调用发送短信验证码的方法&#xff1a; 一、选择并注册短信服务提供商&#xff1a; 1、选择一个可靠的短信服…
阅读更多...
【微服务部署】07-调用链追踪

【微服务部署】07-调用链追踪

文章目录 集成SkyWalking实现调用链追踪1. SkyWalking架构图2. 代码集成SkyWalking 集成SkyWalking实现调用链追踪 1. SkyWalking架构图 Receiver是SkyWalking的入口&#xff0c;支持gRPC和HTTP协议。 SkyWalking内部有分析和查询两个部分 存储方面SkyWalking支持Elasticsearc…
阅读更多...
跟我学c++中级篇—c++11时间库实现定时器和延时

跟我学c++中级篇—c++11时间库实现定时器和延时

一、C11时间库 先简单介绍一下C11中有三类时钟&#xff1a; 1、system_clock&#xff1a;可以理解为壁钟&#xff0c;可调整&#xff08;向前或向后&#xff09;&#xff0c;是系统时间。它可以 与C语言风格的时间进行映射。 2、steady_clock&#xff1a;类似于秒表的单调时钟…
阅读更多...
Windows下Git Bash调用rsync

Windows下Git Bash调用rsync

rsync 提供了补充只需要在git安装目录下放入对应的文件即可。 需要将这个三个文件放到git的bin目录下 如果是默认安装路径是如下&#xff1a; C:\Program Files\Git\usr\bin 然后大功告成。
阅读更多...
【Vue2】 axios库

【Vue2】 axios库

网络请求库-axios库 认识Axios库为什么选择Axios库安装Axios axios发送请求常见的配置选项简单请求可以给Axios设置公共的基础配置发送多个请求 axios创建实例为什么要创建axios的实例 axios的拦截器请求拦截器响应拦截器 axios请求封装 认识Axios库 为什么选择Axios库 在游览…
阅读更多...
105. 从前序与中序遍历序列构造二叉树

105. 从前序与中序遍历序列构造二叉树

给定两个整数数组 preorder 和 inorder &#xff0c;其中 preorder 是二叉树的先序遍历&#xff0c; inorder 是同一棵树的中序遍历&#xff0c;请构造二叉树并返回其根节点。 思路&#xff1a;题目给出了先序遍历和中序遍历的结果&#xff0c;因为先序遍历遵循根–>左–>…
阅读更多...
21 自定义miniweb框架|闭包装饰器|log输出

21 自定义miniweb框架|闭包装饰器|log输出

文章目录 前情知识介绍WSIG-miniWeb框架服务器动态资源请求浏览器请求动态页面的全流程WSGIWSGI接口的定义 静态服务器回顾以及改造web 服务器 和 逻辑处理代码 分离 web动态服务器的基本实现带参数的web动态服务器 闭包装饰器闭包闭包的基础使用函数、匿名函数、闭包、对象修改…
阅读更多...
python相关

python相关

1、更改用户名之后&#xff0c;C盘下的文件夹下名称没有改&#xff1f;这样设置 https://blog.csdn.net/qq_56088882/article/details/127470766 2、安装python和pycharm 链接 3、vscod中import requests出错&#xff1a;亲测有效&#xff1a; 链接
阅读更多...
【Nginx21】Nginx学习：FastCGI模块（三）缓冲区与响应头

【Nginx21】Nginx学习：FastCGI模块（三）缓冲区与响应头

Nginx学习&#xff1a;FastCGI模块&#xff08;三&#xff09;缓冲区与响应头 缓存相关的内容占了 FastCGI 模块将近一小半的内容&#xff0c;当然&#xff0c;用过的人可能不多。而今天的内容说实话&#xff0c;我平常也没怎么用过。第一个是缓冲区相关的知识&#xff0c;其实…
阅读更多...
Nat. Commun.2023 | AI-Bind+：提高蛋白质配体结合预测的通用性

Nat. Commun.2023 | AI-Bind+：提高蛋白质配体结合预测的通用性

论文标题&#xff1a;Improving the generalizability of protein-ligand binding predictions with AI-Bind 论文地址&#xff1a;Improving the generalizability of protein-ligand binding predictions with AI-Bind | Nature Communications 代码&#xff1a; Barabasi…
阅读更多...
最新文章

Copyright @ 2022~2023