当前位置: 首页 > news >正文

SpringBoot与ES7实现多条件搜索

SpringBoot与ES7实现多条件搜索
利用Kibana内置的航班数据,查询从威尼斯到中国按票价升序排列的前10条航班数据。
第一步,新建SpringBoot功能,pom.xml引入四个依赖。

<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch‐rest‐high‐level‐client</artifactId><version>7.9.3</version></dependency><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch‐rest‐client</artifactId><version>7.9.3</version></dependency><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.9.3</version></dependency><dependency><groupId>com.google.code.gson</groupId><artifactId>gson</artifactId><version>2.8.6</version>
</dependency>

elasticsearch-rest-high-level-client是Elastic官方提供的高级REST客户端,它对ES的RESTful API进行封装,使用最简化的方式处理Java与ES之间的交互。相较SpringBoot提供的spring-boot-starter-data-elasticsearch,elasticsearch-rest-high-level-client提供了更灵活的使用方法以及与官方同步更新的支持。

第二步,开发ES应用程序,实现业务逻辑。

@SpringBootTest
public class FlightIndexQueryTestor {@Testpublic void query() {//声明RestHighLevelClient对象RestHighLevelClient client = null;try {//********************Part1 构建客户端,创建请求 ********************//实例化RestHighLevelClient对象,传入IP端口client = new RestHighLevelClient(RestClient.builder(new HttpHost("192.1 68.31.105", 9200)));//构建查询请求,指定索引为kibana_sample_data_flightsSearchRequest request = neSearchRequest("kibana_sample_data_flights");//********************Part2 组织查询条件,设置排序、分页等选项 ******************//构建BoolQueryBuilder即布尔查询,组织多条件检索BoolQueryBuilder booleanQueryBuilder = QueryBuilders.boolQuery();//设置起始城市为威尼斯booleanQueryBuilder.must(QueryBuilders.termQuery("OriginCityName", "Veice"));//设置终点站为中国,两个条件必须同时成立,因此使用must22booleanQueryBuilder.must(QueryBuilders.termQuery("DestCountry", "CN"));//利用SearchSourceBuilder构建附加选项,如排序、分页、汇总等SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();//将Boolean查询代入searchSourceBuildersearchSourceBuilder.query(booleanQueryBuilder);//分页选项,起始0行searchSourceBuilder.from(0);//截取前10行searchSourceBuilder.size(10);//开启命中统计(不分页时总行数),这一项设置为true,否则默认ES的记录总数上限为10000searchSourceBuilder.trackTotalHits(true);//按平均票价升序排列searchSourceBuilder.sort("AvgTicketPrice", SortOrder.ASC);//设置当前查询请求的筛选、分页、排序条件request.source(searchSourceBuilder);//********************Part3 执行查询,封装离线集合 ********************//执行查询,得到查询响应对象SearchResponse response = client.search(requestRequestOptions.DEFAULT);//得到查询命中的文档集合SearchHit[] hits = response.getHits().getHits();//离线集合List<Map<String, Object>> list = new ArrayList();//序列化工具类Gson gson = new Gson();//遍历结果for (SearchHit hit : hits) {//得到每一份文档的JSON数据String json = hit.getSourceAsString();//利用Gson的TypeToken类将JSON反序列化为Map对象Map<String, Object> doc = gson.fromJson(json, new TypeToken<LinkedHashMap<String, Object>>() {}.getType());//将Map放入集合list.add(doc);//打印结果System.out.println(doc);}//查询不分页时命中的记录总数long count = response.getHits().getTotalHits().value;System.out.println("符合条件文档总量为:" + count);} catch (IOException e) {throw new IllegalStateException(e);} finally {if (client != null) {try {//********************Part4 关闭数据连接 ********************//关闭客户端连接client.close();} catch (IOException e) {}}}}
}

相关文章:

SpringBoot与ES7实现多条件搜索

SpringBoot与ES7实现多条件搜索 利用Kibana内置的航班数据&#xff0c;查询从威尼斯到中国按票价升序排列的前10条航班数据。 第一步&#xff0c;新建SpringBoot功能&#xff0c;pom.xml引入四个依赖。 <dependency><groupId>org.elasticsearch.client</groupI…...

【排序算法】 快速排序(快排)!图解+实现详解!

&#x1f3a5; 屿小夏 &#xff1a; 个人主页 &#x1f525;个人专栏 &#xff1a; 算法—排序篇 &#x1f304; 莫道桑榆晚&#xff0c;为霞尚满天&#xff01; 文章目录 &#x1f4d1;前言&#x1f324;️快速排序的概念☁️快速排序的由来☁️快速排序的思想☁️快速排序的实…...

急招开发、安全工程师实习生

信息安全工程师-实习生 公司&#xff1a;四川久远银海软件股份有限公司 工作职责 1、负责对公司WEB应用、APP、小程序、公众号等产品进行安全渗透测试&#xff1b; 2、负责对参与攻防演练、护网行动的项目组提供安全技术支撑&#xff1b; 3、负责提供基线核查、风险评估、主…...

数据结构与算法—插入排序选择排序

目录 一、排序的概念 二、插入排序 1、直接插入排序 直接插入排序的特性总结&#xff1a; 2、希尔排序 希尔排序的特性总结&#xff1a; 三、选择排序 1、直接选择排序 时间复杂度 2、堆排序—排升序(建大堆) 向下调整函数 堆排序函数 代码完整版&#xff1a; …...

基于词云图的短信热词数据可视化

热词统计&#xff1a;短信、邮件、微信、QQ、微博、电商评价、新闻、各行业热词&#xff08;旅游、世界杯、战争、考研等&#xff09;、热点事件等场景。 展示模型&#xff1a;给定多段文本&#xff0c;绘制出词云图。 核心思想&#xff1a;根据样本集中的文本包含的高频词…...

Linux/centos上如何配置管理Web服务器?

Linux/centos上如何配置管理Web服务器&#xff1f; 1 Web简单了解2 关于Apache3 如何安装Apache服务器&#xff1f;3.1 Apache服务安装3.2 httpd服务的基本操作 4 如何配置Apache服务器&#xff1f;4.1 关于httpd.conf配置4.2 常用指令 5 简单实例 1 Web简单了解 Web服务器称为…...

Java EE进阶2

包如果下载不下来怎么办? 1,确认包是否存在 2.如果包存在就多下载几次 3.如果下载了很多次都下载不下来,看看是不是下面几步出现了问题? 1)是否配置了国内源 settings.xml 2)目录是否为全英文,存在中文的话就修改路径 3)删除本地仓库的 jar 包,重新下载(可能由于网络的原…...

最新AI系统ChatGPT源码+AI绘画系统源码+支持GPT4.0+Midjourney绘画+搭建部署教程+附源码

一、AI创作系统 SparkAi创作系统是基于OpenAI很火的ChatGPT进行开发的Ai智能问答系统和Midjourney绘画系统&#xff0c;支持OpenAI-GPT全模型国内AI全模型。本期针对源码系统整体测试下来非常完美&#xff0c;可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如…...

大厂面试题-为什么一线互联网公司严禁使用存储过程

之所以互联网公司不让用&#xff0c;主要有几个方面的原因&#xff1a; 1.存储过程不好调试&#xff0c;一旦涉及到非常复杂的逻辑&#xff0c;定位问题的时候比较麻烦 2.存储过程的一致性很差&#xff0c;如果从Oracle迁移到MySQL&#xff0c;涉及到部分数据库独有特性的时候…...

SpringBoot+Swagger详细使用方法

一、接口文档概述 swagger是当下比较流行的实时接口文文档生成工具。接口文档是当前前后端分离项目中必不可少的工具&#xff0c;在前后端开发之前&#xff0c;后端要先出接口文档&#xff0c;前端根据接口文档来进行项目的开发&#xff0c;双方开发结束后在进行联调测试。 二…...

[动态规划] (十二) 简单多状态 LeetCode 213.打家劫舍II

[动态规划] (十二) 简单多状态: LeetCode 213.打家劫舍II 文章目录 [动态规划] (十二) 简单多状态: LeetCode 213.打家劫舍II题目解析解题思路状态表示状态转移方程初始化和填表顺序返回值提醒 代码实现总结 213. 打家劫舍 II 题目解析 本题是对打家劫舍和按摩师的升级题型&am…...

算法与数据结构之链表

链表的定义&#xff0c;相信大家都知道&#xff0c;这里就不赘述了只是链表分单向链表和双向链表&#xff0c;废话不多说&#xff0c;直接上代码 链表节点的定义&#xff1a; public class Node {int val;Node next;Node pre;public Node(int val, Node next, Node pre) {thi…...

深入剖析React Hooks中的 useCallback

前言 自 React 16.8 版本引入 Hooks 以来&#xff0c;useCallback 成为了前端开发者们越来越青睐的一个功能。useCallback 可以有效优化组件性能&#xff0c;尤其在处理函数式组件中的状态更新时。本文将详细介绍 useCallback 的用法及其注意事项。 1. useCallback 简介 use…...

微服务中配置文件(YAML文件)和项目依赖(POM文件)的区别与联系

实际上涉及到了微服务架构中的两个重要概念&#xff1a;服务间通信和项目依赖管理。在微服务架构中&#xff0c;一个项目可以通过两种方式与另一个项目建立依赖关系&#xff1a;通过配置文件&#xff08;如YAML文件&#xff09;和通过项目依赖&#xff08;如POM文件&#xff09…...

Java快速排序算法、三路快排(Java算法和数据结构总结笔记)[7/20]

一、什么是快速排序算法 快速排序的基本思想是选择一个基准元素&#xff08;通常选择最后一个元素&#xff09;将数组分割为两部分&#xff0c;一部分小于基准元素&#xff0c;一部分大于基准元素。 然后递归地对两部分进行排序&#xff0c;直到整个数组有序。这个过程通过 par…...

【React】05.JSX语法使用上的细节

水水水水水...

LeetCode 1759. 统计同质子字符串的数目【字符串】1490

本文属于「征服LeetCode」系列文章之一&#xff0c;这一系列正式开始于2021/08/12。由于LeetCode上部分题目有锁&#xff0c;本系列将至少持续到刷完所有无锁题之日为止&#xff1b;由于LeetCode还在不断地创建新题&#xff0c;本系列的终止日期可能是永远。在这一系列刷题文章…...

FPGA UDP RGMII 千兆以太网(2)IDDR

1 xilinx原语 在 7 系列 FPGA 中实现 RGMII 接口需要借助 5 种原语,分别是:IDDR、ODDR、IDELAYE2、ODELAYE2(A7 中没有)、IDELAYCTRL。其中,IDDR和ODDR分别是输入和输出的双边沿寄存器,位于IOB中。IDELAYE2和ODELAYE2,分别用于控制 IO 口输入和输出延时。同时,IDELAYE2 …...

chrome安装vue devtools

不能访问应用商店 如果可以访问应用商店可以往下看 插件源代码 选择shell-chrome&#xff0c;这是官方的插件源码 下载源代码打包 参考教程 点击扩展按钮->管理扩展程序->打开开发者模式->把crx文件拖拽进去即可 可以访问chrome应用商店 插件地址 官方文档地址 选…...

【Docker】iptables命令的使用

iptables是一个非常强大的Linux防火墙工具&#xff0c;你可以使用它来控制网络流量的访问和转发。 前面已经学习了iptables的基本原理&#xff0c;四表五链的基本概念&#xff0c;也已经安装好了iptables&#xff0c;下面我们主要学习iptables命令的基本使用。 可以使用iptable…...

【HALCON 实战入门】12. 边缘检测与轮廓提取

欢迎订阅【HALCON 实战入门】专栏&#xff1a; 1. HALCON 简介与安装 5. 相机接入与图像采集 10. 阈值分割与目标提取 11. 区域处理与分析 12. 边缘检测与轮廓提取 13. 轮廓分析与几何特征 【HALCON 实战入门】12. 边缘检测与轮廓提取一、什么是边缘与轮廓&#xff1f;二、边缘…...

地理标志 vs 地理标志资产:一字之差,本质之别

地理标志 vs 地理标志资产&#xff1a;一字之差&#xff0c;本质之别解读《地理标志资产成熟度认证白皮书》中的核心概念区分在《地理标志资产成熟度认证白皮书》中&#xff0c;专知智库首次系统区分了“地理标志”与“地理标志资产”两个概念。这并非文字游戏&#xff0c;而是…...

终极指南:3种简单方法快速解密RPG Maker游戏资源

终极指南&#xff1a;3种简单方法快速解密RPG Maker游戏资源 【免费下载链接】RPGMakerDecrypter Tool for decrypting and extracting RPG Maker XP, VX and VX Ace encrypted archives and MV and MZ encrypted files. 项目地址: https://gitcode.com/gh_mirrors/rp/RPGMak…...

从NeRF到Instant-NGP:我是如何在个人电脑(RTX 4060)上实现秒级3D场景重建的

从NeRF到Instant-NGP&#xff1a;RTX 4060上的秒级3D重建实战手册 当我在RTX 4060笔记本上首次看到15秒完成的高质量3D场景重建时&#xff0c;传统NeRF需要数小时训练的认知被彻底颠覆。这不仅是算法效率的飞跃&#xff0c;更意味着消费级硬件也能承担实时神经渲染任务。本文将…...

清理Ubuntu系统空间?小心误删!用apt-mark auto/manual区分‘有用’和‘无用’软件包

Ubuntu系统清理指南&#xff1a;用apt-mark守护你的关键软件包 上周五下午&#xff0c;当我正准备用VS Code调试一个Python项目时&#xff0c;突然发现几个关键插件莫名其妙消失了。一番排查后才发现&#xff0c;罪魁祸首是三天前那次"例行"的sudo apt autoremove操作…...

Rust的闭包中的生成代码

Rust闭包中的生成代码探秘 Rust的闭包是一种强大的语言特性&#xff0c;它允许开发者以简洁的方式捕获环境变量并生成高效的匿名函数。闭包背后的生成代码却隐藏着许多精妙的设计&#xff0c;从类型推断到内存管理&#xff0c;每一步都体现了Rust对性能与安全的极致追求。本文…...

GPON与EPON技术对比:光纤接入网的核心选择

1. 光纤接入网的技术十字路口&#xff1a;当GPON遇上EPON在光纤到户&#xff08;FTTH&#xff09;的部署现场&#xff0c;我经常被运营商工程师问到一个经典问题&#xff1a;"GPON和EPON到底该选哪个&#xff1f;"这个看似简单的选择题背后&#xff0c;其实涉及光接入…...

不止于起飞降落:用ROS话题和MAVROS深度操控你的PX4仿真无人机

不止于起飞降落&#xff1a;用ROS话题和MAVROS深度操控PX4仿真无人机 当你第一次看到Gazebo里的无人机成功起飞时&#xff0c;那种成就感就像看着自己组装的航模冲上蓝天。但很快你会发现&#xff0c;反复输入commander takeoff和commander land就像只会用开关控制电灯——我们…...

树莓派CM4工业一体机:硬件解析与应用实践

1. 产品概述&#xff1a;基于树莓派CM4的工业级一体机Chipsee AIO-CM4-156是一款面向工业场景设计的全功能一体式计算机&#xff0c;其核心采用了树莓派Compute Module 4&#xff08;CM4&#xff09;作为运算单元。作为前代10.1英寸型号的升级版本&#xff0c;这款15.6英寸设备…...

3个高效技巧解决显卡驱动残留难题:DDU工具实战指南

3个高效技巧解决显卡驱动残留难题&#xff1a;DDU工具实战指南 【免费下载链接】display-drivers-uninstaller Display Driver Uninstaller (DDU) a driver removal utility / cleaner utility 项目地址: https://gitcode.com/gh_mirrors/di/display-drivers-uninstaller …...