【ES常用查询】基于ElasticsearchRestTemplate及NativeSearchQuery的查询

包含当前es所有的查询,

需要什么代码直接照搬,改个参数就行!

用的好请务必给我点赞!!!感谢爱你们!!!

(周末更  筒)

为啥写这篇文章呢:

大概是因为目前公司用的api跟以前的不太一样,

以前我们是基于高标准客户端直接做的,

但是目前这边同事是基于ElasticsearchRestTemplate跟NativeSearchQuery做的。


import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.common.lucene.search.function.CombineFunction;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.MatchAllQueryBuilder;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.MultiMatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.index.query.WildcardQueryBuilder;
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilder;
import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortBuilder;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.SearchHit;
import org.springframework.data.elasticsearch.core.SearchHits;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Map;@Slf4j
@RestController
@RequestMapping("/v/k/t/query")
public class EsTestController {/*** 测试es各种查询方法**/@AutowiredElasticsearchRestTemplate elasticsearchRestTemplate;//通配符查询@PostMapping("/es/wildcard")public void wildcard() {//*:匹配任意数量的字符(包括零个字符)。 *x*: 对x做前后N位做模糊查询,前后有多少值都可以查到(也可以左模糊或者右模糊)//?:用于匹配单个字符.    user?a: user?a   匹配user1a,但不匹配user123a//^:必须以某个字符开头,如^user*:必须以user开头//$:必须以某个字符结尾,如user$:必须以user结尾BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();//wildcardQuery:通配符查询WildcardQueryBuilder bsVersion = QueryBuilders.wildcardQuery("bsVersion", "*1*");WildcardQueryBuilder bsVersion2 = QueryBuilders.wildcardQuery("type", "*j*");boolQueryBuilder.must(bsVersion).should(bsVersion2);NativeSearchQuery dsl = new NativeSearchQueryBuilder()}//高亮//默认情况下:只能对查询字段高亮!!!//加了.requireFieldMatch(false) 可以对非查询字段高亮,具体看下文@PostMapping("/es/highlight")public void highlight() {BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();//wildcardQuery:通配符查询WildcardQueryBuilder bsVersion = QueryBuilders.wildcardQuery("bsVersion", "*1*");WildcardQueryBuilder bsVersion2 = QueryBuilders.wildcardQuery("type", "*j*");boolQueryBuilder.must(bsVersion).should(bsVersion2);NativeSearchQuery dsl = new NativeSearchQueryBuilder().withQuery(boolQueryBuilder).withHighlightFields(//.requireFieldMatch(false) : 加了可以对非查询字段高亮new HighlightBuilder.Field("bsVersion").preTags("<em>").postTags("</em>").requireFieldMatch(false),new HighlightBuilder.Field("provinceNameCn").preTags("<em>").postTags("</em>").requireFieldMatch(false),new HighlightBuilder.Field("isp").preTags("<em>").postTags("</em>").requireFieldMatch(false),new HighlightBuilder.Field("type").preTags("<em>").postTags("</em>").requireFieldMatch(false),new HighlightBuilder.Field("agentId").preTags("<em>").postTags("</em>").requireFieldMatch(false)).build();SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {// 高亮字段是个大MAP  高亮字段集合 = {bsVersion=[<em>115</em>]}  //K=字段名 V=高亮了的数据集合Map<String, List<String>> highlightFields = searchHit.getHighlightFields();System.out.println("获取高亮字段集合:bsVersion =  " + highlightFields.get("bsVersion"));System.out.println("获取高亮字段集合:provinceNameCn =  " + highlightFields.get("provinceNameCn"));System.out.println("获取高亮字段集合:isp =  " + highlightFields.get("isp"));System.out.println("获取高亮字段集合:type =  " + highlightFields.get("type"));System.out.println("获取高亮字段集合:agentId =  " + highlightFields.get("agentId"));List<String> bsVersionResult = highlightFields.get("bsVersion");for (String s : bsVersionResult) {System.out.println("bsVersion集合每一个值为 = " + s);}//            highlightFields.forEach((k, v) -> {
//                //获取高亮字段:k = bsVersion v = [<em>115</em>]
//                System.out.println("获取高亮字段:k = " + k + " v = " + v);
//            });}log.info("总条数:{}", search.getTotalHits());System.out.println("search.getSearchHits().size() = " + search.getSearchHits().size());}//排序@PostMapping("/es/sort")public void sort() {MatchAllQueryBuilder matchAllQuery = QueryBuilders.matchAllQuery();//备注:这里用的是NativeSearchQueryBuilder:xxxBuilder。最后一定要.build();,不然条件用不了NativeSearchQuery dsl = new NativeSearchQueryBuilder().withQuery(matchAllQuery)//备注:应该是要keyword,paasword这一类才能排序。我用text类型排序报:非法字段异常.withSorts(SortBuilders.fieldSort("appId").order(SortOrder.ASC)) //排序:根据bsVersion升序排序.build();SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//分页@PostMapping("/es/page")public void page() {Integer page = 1;Integer size = 10;MatchAllQueryBuilder matchAllQuery = QueryBuilders.matchAllQuery();NativeSearchQuery dsl = new NativeSearchQuery(matchAllQuery);//分页Pageable pageable = PageRequest.of((page - 1) * size, size);dsl.setPageable(pageable);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());// 获取当前页数log.info("当前页数:{}", page);// 获取当前页的条数int currentSize = search.getSearchHits().size();log.info("当前页条数:{}", currentSize);//数据列表:search.getSearchHits()  for出每一条,然后加到list中for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//布尔查询@PostMapping("/es/boolQueryBuilder")public void boolQueryBuilder() {BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();//must 必须满足且参与算分boolQueryBuilder.must(QueryBuilders.matchQuery("bsVersion", "114"));//mustNot 必须不满足   appID 300-700之间不参与查询(就是直接筛掉了)boolQueryBuilder.mustNot(QueryBuilders.rangeQuery("appId").gte("300").lte("700"));//filter 必须满足,且不参与算分
//        boolQueryBuilder.filter(QueryBuilders.termQuery("agentId", "298_ead348abbaf30f48"));NativeSearchQuery dsl = new NativeSearchQuery(boolQueryBuilder);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//算分函数查询@PostMapping("/es/FunctionScoreQueryBuilder")public void FunctionScoreQueryBuilder() {FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(//原始查询QueryBuilders.matchAllQuery(),//算分数组new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{//第一个元素new FunctionScoreQueryBuilder.FilterFunctionBuilder(//过滤器QueryBuilders.matchQuery("bsVersion", "114"),//权重ScoreFunctionBuilders.weightFactorFunction(10)),//第二个元素new FunctionScoreQueryBuilder.FilterFunctionBuilder(//过滤器QueryBuilders.matchQuery("bsVersion", "115"),//权重ScoreFunctionBuilders.weightFactorFunction(10))}).boostMode(CombineFunction.REPLACE);NativeSearchQuery dsl = new NativeSearchQuery(functionScoreQueryBuilder);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//范围查询@PostMapping("/es/rangeQuery")public void rangeQuery() {//范围查询 appId字段  >=0   <=200   的数据RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("appId").gte("0").lte("200");NativeSearchQuery dsl = new NativeSearchQuery(rangeQueryBuilder);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//精确查询@PostMapping("/es/termQuery")public void termQuery() {//根据isp字段 精确查询 内网IPTermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("isp", " 内网IP ");NativeSearchQuery dsl = new NativeSearchQuery(termsQueryBuilder);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//多字段查询@PostMapping("/es/multiMatchQuery")public void multiMatchQuery() {//备注:字段必须是text类型,可以分词类型!!!!//查找keyword、数值、日期、boolean等会报错!!!//如果放入精确类型的字段,会报错!!!!MultiMatchQueryBuilder multiMatchQuery = QueryBuilders.multiMatchQuery("114", "bsVersion", "type");//查询114根据"bsVersion","type"NativeSearchQuery dsl = new NativeSearchQuery(multiMatchQuery);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//单字段查询@PostMapping("/es/matchQuery")public void matchQuery() {MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("bsVersion", "114");NativeSearchQuery dsl = new NativeSearchQuery(matchQuery);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档的原数据 = " + searchHit.getContent());System.out.println("单条文档的id = " + searchHit.getId());System.out.println("单条文档的评分 = " + searchHit.getScore());System.out.println("单条文档索引名(表名) = " + searchHit.getIndex());//298_ops-web-js_1就是你输入的索引库名}}//查询所有@PostMapping("/es/matchAllQuery")public void matchAllQuery() {MatchAllQueryBuilder matchAllQuery = QueryBuilders.matchAllQuery();NativeSearchQuery dsl = new NativeSearchQuery(matchAllQuery);SearchHits<Map> search = elasticsearchRestTemplate.search(dsl, Map.class, IndexCoordinates.of("298_ops-web-js_1"));log.info("总条数:{}", search.getTotalHits());log.info("查询原始对象:{}", search.getSearchHits());log.info("分数值:{}", search.getMaxScore());log.info("有无聚合:{}", search.hasAggregations());log.info("返回搜索命中数量的关系,例如精确值、估计值:{}", search.getTotalHitsRelation());log.info("判断是否存在搜索命中结果:{}", search.hasSearchHits());//原始结果的每一条数据for (SearchHit<Map> searchHit : search.getSearchHits()) {System.out.println("单条文档 = " + searchHit);System.out.println("单条文档的原数据 = " + searchHit.getContent());}}}

————————————————————————————————————

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

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

相关文章

Pytorch torch.normal()的用法

该函数原型如下&#xff1a; normal(mean, std, *, generatorNone, outNone) 该函数返回从单独的正态分布中提取的随机数的张量&#xff0c;该正态分布的均值是mean&#xff0c;标准差是std。 用法如下&#xff1a;我们从一个标准正态分布N&#xff5e;(0,1)&#xff0c;提取…

uniapp实现下载图片到本地

uniapp实现下载图片到本地 在uniapp开发中&#xff0c;可以使用uni.downloadFile方法实现下载文件功能&#xff0c;客户端直接发起一个 HTTP GET 请求&#xff0c;返回文件的本地临时路径。 const urlPath http://192.168.0.1:8080/fileApi/logo.png uni.downloadFile({url:…

Python如何实现模板方法设计模式?什么是模板方法设计模式?Python 模板方法设计模式示例代码

什么是模板方法&#xff08;Template Method&#xff09;设计模式&#xff1f; 模板方法&#xff08;Template Method&#xff09;是一种行为型设计模式&#xff0c;它定义了一个算法的骨架&#xff0c;将一些步骤延迟到子类中实现。这种模式允许子类为一个算法的特定步骤提供…

前后端黄金组合:Django+Vue+Element UI,助你构建完美平台!

这是一篇什么文章&#xff1f; 一篇你对测试开发工作感兴趣&#xff0c;想了解系统工作逻辑的文章。 一篇是你在开始动手搭建环境前需要了解各工具原理的文章。 这是一篇你真正开始前需要查阅的文章。 本文介绍了前后端工作原理&#xff0c;前后端搭建的流程、搭建过程中需…

防御DDOS的方法是什么?

DDOS攻击是现在很常见的一种网络攻击方式&#xff0c;如果服务器遭到DDOS攻击的话会导致服务器崩溃导致企业用户信息的泄露&#xff0c;选择服务器租用&#xff0c;IDC服务器商家专业的技术人员会有哪些防范措施&#xff0c;今天小编就给大家讲一讲吧&#xff01; 1、采用高防服…

SQLMAP --TAMPER的编写

跟着师傅的文章进行学习 sqlmap之tamper脚本编写_sqlmap tamper编写-CSDN博客 这里学习一下tamper的编写 这里的tamper 其实就是多个绕过waf的插件 通过编写tamper 我们可以学会 在不同过滤下 执行sql注入 我们首先了解一下 tamper的结构 这里我们首先看一个最简单的例子…

Excel数据可视化—波士顿矩阵图【四象限图】

EXCEL系列文章目录 Excel系列文章是本人亲身经历职场之后萌发的想法&#xff0c;为什么Excel覆盖如此之广&#xff0c;几乎每个公司、学校、家庭都在使用&#xff0c;但是它深藏的宝藏功能却很少被人使用&#xff0c;PQ、BI这些功能同样适用于数据分析&#xff1b;并且在一些需…

Kubernetes(k8s)进阶

文章目录 Kubernetes进阶一、Namespace&#xff08;名称空间&#xff09;1.namespace介绍2.管理namespace查看namespace创建namespace删除namespaceyaml文件配置namespace 二、Pod&#xff08;最小基本部署单元&#xff09;1.pod介绍2.管理pod创建并运行pod查看pod信息访问pod删…

一周互联网简讯 | 本周互联网发生了啥?(第3期)

1.百度T7跳槽字节3-1&#xff0c;总包145万&#xff0c;压力太大想降级 硕士毕业工作10年&#xff0c;一百度T7大头兵发文称&#xff0c;自己最近拿到字节3-1的offer&#xff0c;年包从现有的110万涨30%到145万。但是担心去字节后因为定的职级高需要带人&#xff0c;压力会很大…

【Highway-env】IntersectionEnv代码阅读

文章目录 主要完成任务代码结构1.action space2.default_config3.reward_agent_rewards_agent_reward_reward_rewards小结 4.terminated & truncated5.reset_make_road_make_vehicles_spawn_vehicle 6.step 主要完成任务 IntersectionEnv继承自AbstractEnv,主要完成以下4个…

【django+vue】项目搭建、解决跨域访问

笔记为自我总结整理的学习笔记&#xff0c;若有错误欢迎指出哟~ 【djangovue】项目搭建、解决跨域访问 djangovue介绍vue环境准备vue框架搭建1.创建vue项目2.配置vue项目3.进入项目目录4.运行项目5.项目文件讲解6.vue的扩展库或者插件 django环境准备django框架搭建1.使用conda…

selenium长截图,截图整个页面

"""翻页截图整个页面"""# 获取页面的宽度和高度page_width web_driver.execute_script("return document.body.scrollWidth")page_height web_driver.execute_script("return document.body.scrollHeight")# 开启设备模拟…

day29_Servlet

今日内容 零、 复习昨日 一、Servlet 零、 复习昨日 一、Servlet 1.1 Servlet介绍 javaweb开发,就是需要服务器接收前端发送的请求,以及请求中的数据,经过处理(jdbc操作),然后向浏览器做出响应. 我们要想在服务器中写java代码来接收请求,做出响应,我们的java代码就得遵循tomca…

k8s ingress高级用法一

前面的文章中&#xff0c;我们讲述了ingress的基础应用&#xff0c;接下来继续讲解ingress的一些高级用法 一、ingress限流 在实际的生产环境中&#xff0c;有时间我们需要对服务进行限流&#xff0c;避免单位时间内访问次数过多&#xff0c;常用的一些限流的参数如下&#x…

工作电压范围,转换速率高,相位补偿等特性的双运算放大器芯片D4510的描述

D4510是一块双运算放大器&#xff0c;具有较宽的工作电压范围&#xff0c;转换速率高&#xff0c;相位补偿等特性。电路能在低电源电压下:工作,电源电压范围:双电源为1V-3.5V和单电源电压为2V~7V。 主要特点&#xff1a; ● 低电压工作 ● 转换速率高 ● 动态输…

docker中怎么启动容器

1、首先在linux中使用以下命令来启动 Docker 服务&#xff1a; sudo systemctl start docker2、然后下面的命令显示所有的容器列表&#xff0c;包括正在运行和已停止的容器。 docker ps -a然后找到容器ID 3、使用 docker start 启动一个已停止的容器&#xff1a; docker s…

简单模拟 Spring 创建的动态代理类(解释一种@Transactional事务失效的场景)

模拟 Spring 创建的动态代理类 本文主要目的是从父类和子类继承的角度去分析为什么在 Service 标注的业务类中使用 this 调用方法会造成事务失效。解释在这种情况下 this 为什么是原始类对象而不是代理类对象。 问题描述 在 Service 标注的业务类中&#xff0c;如果调用本类…

深入理解强化学习——马尔可夫决策过程:马尔可夫奖励过程-[计算马尔可夫奖励过程价值的动态规划方法]

分类目录&#xff1a;《深入理解强化学习》总目录 文章《深入理解强化学习——马尔可夫决策过程&#xff1a;马尔可夫奖励过程-[计算马尔可夫奖励过程价值的蒙特卡洛方法]》介绍了计算马尔可夫奖励过程价值的蒙特卡洛方法&#xff0c;同时我们也可以用动态规划的方法&#xff0…

YOLOv8 加持 MobileNetv3,目标检测新篇章

🗝️YOLOv8实战宝典--星级指南:从入门到精通,您不可错过的技巧   -- 聚焦于YOLO的 最新版本, 对颈部网络改进、添加局部注意力、增加检测头部,实测涨点 💡 深入浅出YOLOv8:我的专业笔记与技术总结   -- YOLOv8轻松上手, 适用技术小白,文章代码齐全,仅需 …

【狂神说Java】redis入门

✅作者简介&#xff1a;CSDN内容合伙人、信息安全专业在校大学生&#x1f3c6; &#x1f525;系列专栏 &#xff1a;【狂神说Java】 &#x1f4c3;新人博主 &#xff1a;欢迎点赞收藏关注&#xff0c;会回访&#xff01; &#x1f4ac;舞台再大&#xff0c;你不上台&#xff0c…