ElasticSearch的DSL查询

ElasticSearch的DSL查询

准备工作

创建测试方法,初始化测试结构。

import org.apache.http.HttpHost;
import org.apache.lucene.search.TotalHits;
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.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;import java.io.IOException;
import java.util.Map;public class DemoTest {private RestHighLevelClient client;/*** * 因为下面会重复使用输出语句所以就单独抽出来封装了** @param response 查询结果响应体*/public static void handelResponse(SearchResponse response) {// 查询的总数TotalHits total = response.getHits().getTotalHits();System.out.println("total===>" + total);SearchHits searchHits = response.getHits();// 输出查询结果searchHits.forEach(hit -> {// 查询时JSON数据,可以使用实体将其转换。String json = hit.getSourceAsString();System.out.println(json);// 高亮返回体Map<String, HighlightField> map = hit.getHighlightFields();if (map != null) {System.out.println("-----------------高亮显示---------------");HighlightField highlightField = map.get("name");System.out.println("name===>" + highlightField.getName());System.out.println("fragments===>" + highlightField.getFragments()[0]);}});}@BeforeEachvoid setup() {this.client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://192.168.3.98:9200")));}@AfterEachvoid teardown() throws IOException {this.client.close();}
}

DSL查询

普通查询全部

new SearchRequest("hotel")查询索引库名称。

@Test
void testMatchAll() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询全部内容request.source().query(QueryBuilders.matchAllQuery());// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# 查询所有
GET /_search
{"query": {"match_all": {}}
}

match查询-单字段查询

// match查询-单字段查询
@Test
void testMatch() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容request.source().query(QueryBuilders.matchQuery("all", "如家"));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# match,根据单字段查询,推荐使用
GET /hotel/_search
{"query": {"match": {"all": "外滩如家"}}
}

match查询-多字段查询

@Test
void testMultiMatchQuery() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容request.source().query(QueryBuilders.multiMatchQuery("如家", "name", "business"));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# multi_match 多字段查询,不推荐,性能低
GET /hotel/_search
{"query": {"multi_match": {"query": "外滩如家","fields": ["name","brand","business"]}}
}

精确查询

@Test
void termQuery() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容-精确查找request.source().query(QueryBuilders.termQuery("city", "深圳"));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# 精确查找-term,不会分词
GET /hotel/_search
{"query": {"term": {"city": {"value": "上海"}}}
}

范围查找

@Test
void testRange() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容request.source().query(QueryBuilders.rangeQuery("price").gte(100).lt(150));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# range 范围查询
GET /hotel/_search
{"query": {"range": {"price": {"gte": 100,"lte": 300}}}
}

布尔查询

@Test
void testBoolean() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容BoolQueryBuilder query = QueryBuilders.boolQuery();query.must(QueryBuilders.termQuery("city", "杭州"));query.filter(QueryBuilders.rangeQuery("price").lt(250));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# 不等于gt,lt不等于
GET /hotel/_search
{"query": {"range": {"FIELD": {"gt": 10,"lt": 20}}}
}

排序、分页

@Test
void testFrom() throws IOException {// 页码,每页大小int page = 1, size = 5;// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容request.source().query(QueryBuilders.matchAllQuery());request.source().from((page - 1) * size).size(5);request.source().sort("price", SortOrder.ASC);// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

高亮

@Test
void testHighLighter() throws IOException {// 指定查询的索引库SearchRequest request = new SearchRequest("hotel");// 查询内容request.source().query(QueryBuilders.matchQuery("all", "如家"));request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));// 得到查询返回体,传入返回体到封装的返回体输出SearchResponse response = client.search(request, RequestOptions.DEFAULT);handelResponse(response);
}

对应控制台。

# 搜索结果高亮显示,默认字段必须与高亮字段一致,默认是em标签
GET /hotel/_search
{"query": {"match": {"all": "如家"}},"highlight": {"fields": {"name": {"require_field_match": "false","pre_tags": "<i>","post_tags": "</i>"}}}, "from": 0,"size": 20
}

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

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

相关文章

AcWing22. 旋转数组的最小数字

把一个数组最开始的若干个元素搬到数组的末尾&#xff0c;我们称之为数组的旋转。 输入一个升序的数组的一个旋转&#xff0c;输出旋转数组的最小元素。 例如数组 {3,4,5,1,2}为 {1,2,3,4,5} 的一个旋转&#xff0c;该数组的最小值为 1。 数组可能包含重复项。 注意&#x…

【LeetCode】三月题解

文章目录 [2369. 检查数组是否存在有效划分](https://leetcode.cn/problems/check-if-there-is-a-valid-partition-for-the-array/)思路&#xff1a;代码&#xff1a; [1976. 到达目的地的方案数](https://leetcode.cn/problems/number-of-ways-to-arrive-at-destination/) 思路…

C++教学——从入门到精通 5.单精度实数float

众所周知&#xff0c;三角形的面积公式是(底*高)/2 那就来做个三角形面积计算器吧 到吗如下 #include"bits/stdc.h" using namespace std; int main(){int a,b;cin>>a>>b;cout<<(a*b)/2; } 这不对呀&#xff0c;明明是7.5而他却是7&#xff0c;…

ntp服务器搭建

1、手动修改时区 CST可以为如下4个不同的时区的缩写&#xff1a; 美国中部时间&#xff1a;Central Standard Time (USA) UT-6:00 澳大利亚中部时间&#xff1a;Central Standard Time (Australia) UT9:30 中国标准时间&#xff1a;China Standard Time UT8:00 古巴标准时间&a…

二分查找算法刷题记录 -LC34

前言 接上文&#xff0c;本文记录LC34 排序数组中查找元素的第一个和最后一个位置题解。 该题是基于LC704的拓展题&#xff0c;也是二分查找的各个细节点所在&#xff0c;做透这个题&#xff0c;二分查找的题基本上都可以解决。 正文 在做本题前&#xff0c;请确保你已经掌…

让IIS支持.NET Web Api PUT和DELETE请求

前言 有很长一段时间没有使用过IIS来托管应用了&#xff0c;今天用IIS来托管一个比较老的.NET Fx4.6的项目。发布到线上后居然一直调用不同本地却一直是正常的&#xff0c;关键是POST和GET请求都是正常的&#xff0c;只有PUT和DELETE请求是有问题的。经过一番思考忽然想起来了I…

YOLOv9改进策略 :主干优化 | 极简的神经网络VanillaBlock 实现涨点 |华为诺亚 VanillaNet

💡💡💡本文改进内容: VanillaNet,是一种设计优雅的神经网络架构, 通过避免高深度、shortcuts和自注意力等复杂操作,VanillaNet 简洁明了但功能强大。 💡💡💡引入VanillaBlock GFLOPs从原始的238.9降低至 165.0 ,保持轻量级的同时在多个数据集验证能够高效涨点…

Java文件操作(从创建文件到简单输入输出流)

目录 前言 起步&#xff1a;创建文件 File类 尝试创建一个文件 代码展示 输出结果 基础文件写入与输出&#xff1a;输入输出流 stream流 FileInputStream类 基本读取实现 代码展示 输出结果 FileOutputStream类 基本写入实现 代码展示 输出结果 后言 前言 在…

C++ 容器使用指南

C 容器使用指南 一.迭代器 当使用 C 中的容器&#xff08;如 std::vector、std::list、std::map 等&#xff09;时&#xff0c;迭代器是一种非常重要的工具 它们提供了一种通用的方式来访问容器中的元素&#xff0c;允许我们对容器进行遍历、访问、修改和删除操作 1.开始和结束…

给手机换电池、贴膜:VIVO服务还是非常好的

1月的时候去过一次售后&#xff0c;想了解一下手机电池情况&#xff0c;结果说这个型号无法检查。手机已经两年半了&#xff0c;电池容量估计不到80%了。这个手机很满意&#xff08;轻&#xff09;&#xff0c;新出的手机也没有明显优势&#xff0c;于是决心换个电池。一看售后…

每日学习笔记:C++ STL算法分类

非更易型 更易型 移除型 变序型 排序型 已排序区间算法 数值型算法

C++实现函数柯里化

1. 代码 需要c17特性。 #include <tuple>template <typename Function, typename... CapturedArgs> class curried { private:using CapturedArgsTuple std::tuple<std::decay_t<CapturedArgs>...>;template <typename... Args>static auto c…

【滑动窗口】Leetcode 将 x 减到 0 的最小操作数

题目解析 1658. 将 x 减到 0 的最小操作数 算法讲解 这道题按照题目要求的话会变得很难&#xff0c;因为不仅需要考虑数字减到0&#xff0c;还需要考虑最小的操作数。正难则反&#xff0c;按照这个思路&#xff0c;我们来解析题目 这道题本质上无非就是在左边寻找一段区间&a…

HCIP第三次作业(综合)

一、实验要求 二、实验步骤 1、配置IP地址部分 PC1&#xff1a; PC2&#xff1a; PC3&#xff1a; PC4&#xff1a; R1&#xff1a; R2&#xff1a; R3&#xff1a; R4&#xff1a; R5&#xff1a; 环回&#xff1a; 2.通过配置缺省路由让公网互通 [R1]ip route-static 0.0.…

Lambda 表达式

Lambda 表达式详细文档 简介 Lambda 表达式是一种匿名函数&#xff0c;允许您在不定义函数的情况下将代码块传递给其他函数或方法。Lambda 表达式通常用于简化代码&#xff0c;并使代码更具可读性。 语法 Lambda 表达式的语法如下&#xff1a; [capture-list] (parameter-…

代码随想录第27天| 39. 组合总和

39. 组合总和 39. 组合总和 - 力扣&#xff08;LeetCode&#xff09; 代码随想录 (programmercarl.com) 带你学透回溯算法-组合总和&#xff08;对应「leetcode」力扣题目&#xff1a;39.组合总和&#xff09;| 回溯法精讲&#xff01;_哔哩哔哩_bilibili 给你一个 无重复元…

思考:开启MMU瞬间可能出现的多种问题以及多种解决方案

快速链接: 【精选】ARMv8/ARMv9架构入门到精通-[目录] &#x1f448;&#x1f448;&#x1f448; (说明本文的介绍都是基于armv8-aarch64或armv9硬件架构) 在mmu未开启阶段&#xff0c;PC操作的都是物理地址执行程序&#xff0c;这样看起来一切正常&#xff0c;没啥问题。 例如…

Windows Server 2022 使用ApacheDS用户远程桌面登录服务器

Windows Server 2022 使用ApacheDS用户远程桌面登录服务器 1、接上篇 Windows Server 2022 使用ApacheDS用户认证 使用Administrator用户远程登录192.168.1.100windows server&#xff0c;打开pGina软件 2、输入刚刚在ApacheDS中的新添加的用户测试一下&#xff0c;会自动添加…

嵌入式Linux:fcntl()和ioctl()函数

目录 1、fcntl()函数 2、ioctl()函数 fcntl()和ioctl()是用于对文件描述符进行控制的两个系统调用&#xff0c;它们在不同的情况下有不同的用途和功能。 1、fcntl()函数 fcntl()函数提供了对已打开文件描述符执行各种控制操作的功能&#xff0c;例如复制文件描述符&#xf…

汽车电子行业知识:什么是车联网V2X技术

文章目录 一、V2X是什么?二、V2X功能有哪些?三、V2X的发展现状四、V2X包含哪些技术?五、V2X与哪些领域相关?六、V2X的未来趋势七、有哪些研发V2X技术的公司八、V2X技术应用的困境九、V2X技术应用的需求 自动驾驶、汽车互联等新一代信息技术和汽车产业融合发展已经成为…