ElasticSearch 7.4学习记录(DSL语法)

上文和大家一起初次了解了很多ES相关的基础知识,本文的内容将会是实际企业中所需要的吗,也是我们需要熟练应用的内容。
面对ES,我们最多使用的就是查询,当我负责这个业务时,现不需要我去考虑如何创建索引,添加文档等,只需要根据复杂业务实现查询即可,本文的重点也会在如何使用ES进行查询,并给出很多实际案例进行补充解释和演示

本次案例演示说明所需要的数据-----------student数据信息:

属性数值
id001
namezjh
address中国陕西省延安市
brief喜欢足球的男生
age28
属性数值
id002
namewxx
address中国陕西省渭南市
brief喜欢zjh的女生
age18

  • 1 DSL查询语法
    • 1.1 什么是DSL
    • 1.2 查询所有
    • 1.3 全文检索
    • 1.4 精确查询
    • 1.5 复合查询
    • 1.6 搜索结果处理
      • 1.6.1 结果排序+分页查询
      • 1.6.2 结果高亮
  • 2 DSL语法对应Java代码的实现
    • 2.1 match_all
    • 2.1' 核心代码梳理
    • 2.2 match与multi_match
    • 2.3 term和range
    • 2.4 boolean
    • 2.5 排序和分页
  • 3 聚合索引
    • 3.1 初体验聚合效果(buckets聚合案例)
    • 3.2 优化聚合效果
    • 3.3 Metrics聚合案例
    • 3.4 DSL语法对应Java代码的实现
    • 3.5 多条件的聚合
    • 3.6 理解聚合

1 DSL查询语法

1.1 什么是DSL

就是在这个环境下查询语句,有自己的语法格式要求,需要我们熟练掌握。
或者你可以想一下,在mysql环境下的sql语法,这就是在ES环境下的DSL语法,都是为了实现查询功能。
在这里插入图片描述

一个简化的查询模版GET /索引库名/_search
{"query":{"查询类型":{"查询条件":"条件值"}}
}

查询类型可以实现不同的查询效果,下面的案例很好的解释给了大家。

1.2 查询所有

match_all:查询全部的数据

GET /student/_search
{"query":{"match_all":{}}
}

1.3 全文检索

match查询:利用分词器进行查询,比如:传入“男生”,会将其分词取倒排索引库查询,找到含有“男”与“生”数据,即找到zjh和wxx的全部数据

这是一个模板
GET /student/_search
{"query":{"match":{"field":"text"}}
}实际案例:拆分“男生”去brief字段中查找有无”男“与”生“,最终找到zjh和wxx
GET /student/_search
{"query":{"match":{"biref":"男生"}}
}升级案例:现在不想指定一个字段去查找,想查询所有的字段中的数据是否有匹配的
GET /student/_search
{"query":{"match":{"all":"跑步工资"}}
}
这个all就表示会在所有字段id,name,address,brief的值中去匹配”跑步工资“

multi_match查询:允许同时查询多个字段

这是一个模板
GET /student/_search
{"query":{"multi_match":{"query":"text","fields":["field1","field2"]}}
}
实际案例:找到address含有“延安”且brief含有”喜欢“的数据,最终找到zjh和wxx
GET /student/_search
{"query":{"multi_match":{"query":"延安喜欢","fields":["address","brief"]}}
}

需要注意的是multi_match设置的字段越多,效率越慢,推荐优先使用match

1.4 精确查询

当查询条件是不可分的:keyword,数值,日期,boolean等,不会对其分词,即为精确查询

  • term:根据词条精确值查询
  • range:根据值范围查询

案例:
当查询内容传入:上海,就希望匹配到含有“上海”的数据,而不是含有“上”与“海”的这种数据。此乃term

当查询内容传入:100-300元,就希望匹配到在这个范围内的数据。此乃range

在这里插入图片描述

这是一个term模板
GET /student/_search
{"query":{"term":{"field":{“value”:“value”}}}
}
实际案例:找到address含有“男生”的数据,找到空数据,因为必须精准为男生,才能找到zjh
GET /student/_search
{"query":{"term":{"field":{“brief”:“男生延安”}}}
}
这是一个range模板
GET /student/_search
{"query":{"range":{"field":{“gte”:“value”,“lte”:“value”}}}
}
实际案例:找到年龄在10-20之间的人,最终找到wxx
GET /student/_search
{"query":{"range":{"age":{“gte”:10,“lte”:20}}}
}

注意:gte是大于等于;gt是大于

1.5 复合查询

Boolean Query
布尔查询是一个或者多个查询字句的组合。组合方式有

  • must : 必须匹配每个子查询(与)
  • should:选择性匹配子查询(或)
  • must_not:必须不匹配(非)不参与算分
  • filter:必须匹配 不参与算分
GET /student/_search
{"query":{“bool”:{“must”:[  {"term":{“address”:“中国”} }{"term":{“name”:“zjh”} }],"should":[ {"term":{“brief”:“喜欢”} },{"term":{“brief”:“足球”} }],“must_not”:[{"range":{“age”:{"gte:20"} } },],“filter”:[{"term":{“brief”:“生”}}]}}
}

这串代码表示:
must:(address必须含有中国) 且 (name必须含有zjh)
should:(brief含有喜欢) 或者 (brief含有足球)二选一
mustnot:(年龄大于等于20)相反-----(年龄小于20)

这个案例仅仅告诉你如何理解must等,下面介绍一个贴切的案例

查询名字包含“麦当劳”,地点在北京,人均消费不高于100元,周一到周天营业的快餐店

1.6 搜索结果处理

1.6.1 结果排序+分页查询

这是一个range模板
GET /student/_search
{"query":{“查询类型”:{}},"sort":[{"fileld":”value“}]
}
实际案例:全部查询,将结果按照年龄倒序,若相等按照id升序排
GET /student/_search
{"query":{"match_all":{}},"sort":[{”age“:”desc“},{”id“:”asc“}],“from”:0,“size”:10}}
}

es查询结果默认只显示10条数据。from:0--------size:10,表示从0开始,显示10条数据

实际上,如我们会将一批数据分成10批,存在10台服务器的ES上。如果我们需要查询价格由低到高排序前100条,底层执行的逻辑是:每一台ES由低到高排序,查出前100,然后聚合10台机器的数据(10*100),从聚合结果1000中再找到前100的数据。
不过呢,当我们执行数据读取时候,一定是会扫描所有的ES节点,不需要担心查询的时候会不会只查询当前服务器上es的数据,是不会的。

1.6.2 结果高亮

浏览器搜索java,可以看到查询结果中含有java部分高亮显示,这是如何实现的?
在这里插入图片描述
是ES帮忙做的,我们只需要告诉ES需要高亮显示的字段和内容即可

GET /student/_search
{"query":{“match”:{“all”:“中国”},“highlight”:{“fields”:{  //高亮字段“address”:{"requeire.field_match":“false”,//是否需要与查询字段匹配“pre_tags”:"<em>", //用来标记高亮字段的前置标签,“post_tags”:“</em>”  //用来标记高亮字段的后置标签}}}
}

2 DSL语法对应Java代码的实现

2.1 match_all

在这里插入图片描述

 RestHighLevelClient client 注意前面我已经获取了client关于代码实现,可以理解为四个部分,不同业务需要变动代码的部分只有2,4@Testvoid testMatchAll() throws IOException {//1.准备requestSearchRequest request = new SearchRequest("student");//2.准备DSLrequest.source().query(QueryBuilders.matchAllQuery());//3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);//4.解析响应中的hitsSearchHits searchHits = response.getHits();long value = searchHits.getTotalHits().value; //获取value值(参考ES)System.out.println(value);SearchHit[] hits = searchHits.getHits(); //获取文档数据for (SearchHit hit : hits) {String json = hit.getSourceAsString();System.out.println(json);}}

为什么解析response呢,因为其全部内容如下图,我们需要选出需要的即可
在这里插入图片描述

2.1’ 核心代码梳理

这里梳理一下上述java代码的对应关系,帮助理解
source()方法中存在操作类型,有查询query,有结果排序sort,有分页form,size等
在这里插入图片描述

在这里插入图片描述

QueryBuilders()里面有查询类型,包括前面科普的精确查询term,全部查询match_all,复合查询bool等
在这里插入图片描述
在这里插入图片描述

2.2 match与multi_match

在这里插入图片描述

2.3 term和range

在这里插入图片描述

2.4 boolean

在这里插入图片描述

2.5 排序和分页

在这里插入图片描述

3 聚合索引

理解什么是聚合索引:类似于group by的概念,下图前两个常用。先看看聚合怎么用,文末会有个案例更清楚的解释聚合的概念
在这里插入图片描述

3.1 初体验聚合效果(buckets聚合案例)

比如我现在需要统计酒店的品牌数量有几种,则可以根据品牌数量进行聚合,就会得到名为“七天酒店” 34家 ;“如家” 30家 ;“速8” 20家的返回结果

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

3.2 优化聚合效果

对价格在200元以内的酒店进行聚合,这个案例表示query和aggs是平级。

在这里插入图片描述

3.3 Metrics聚合案例

在这里插入图片描述
也就是在Buckets聚合上再加了一层,很好记住,(sorce字段是酒店评分)注意观察下图,发现多了count、min、max、avg,sum。什么意思呢,就是说我们对酒店评分进行聚合,得到了最大值,最小值,平均值等等。
在这里插入图片描述

3.4 DSL语法对应Java代码的实现

在这里插入图片描述
在这里插入图片描述

3.5 多条件的聚合

就是同时聚合多个字段:城市、星级、品牌
在这里插入图片描述
如何理解这个业务
前面提到的精确查询,根据上海就可以查出city字段中含有”上海“的所有文档,但是我们仅仅停留在粗暴的找出信息的阶段,若我需要对上海这一类文档求平均价格,计数等,term的功能就显得捉襟见肘了。所以这里需要聚合处理。理解了业务需求在看看如何实现

1.准备request
2.准备DSL2.1 多个聚合字段
3.发出请求
4.解析结果4.1 分别处理聚合名称的数据

2.1内容
在这里插入图片描述
4.1内容,有几个集合字段就实现几次
在这里插入图片描述
实际上,你只需要清楚一个字段的聚合实现流程,那么当你写多个字段的聚合时,仅仅需要重复2和4的代码,那这些代码你可以封装成函数更优雅。

3.6 理解聚合

现在我们需要搜索城市是上海的数据
直接使用精确查询:找到city字段含有”上海“的文档;(注意理解ES中文档的概念)
聚合city字段:对city字段进行聚合,得到“上海”“北京”“深圳”的聚合结果,注意,只是聚合结果,不是具体的文档数据。此外我可以对聚合结果进行求和,求平均值等操作。

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

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

相关文章

Go:测试框架GoConvey 简介

快速开始 GoConvey是一个完全兼容官方Go Test的测试框架&#xff0c;一般来说这种第三方库都比官方的功能要强大、更加易于使用、开发效率更高&#xff0c;闲话少说&#xff0c;先看一个example&#xff1a; package utils import (. "github.com/smartystreets/goconvey…

【Redis】Redis哨兵模式

【Redis】Redis哨兵模式 Redis主从模式当主服务器宕机后&#xff0c;需要手动把一台从服务器切换为主服务器&#xff0c;需要人工干预费事费力&#xff0c;为了解决这个问题出现了哨兵模式。 哨兵模式是是一个管理多个 Redis 实例的工具&#xff0c;它可以实现对 Redis 的监控…

NC65 树表型参照 搜索全部 按钮点击事件后获取sql的方法

NC65 树表型参照 搜索全部 按钮点击事件后获取sql的方法。 /*** 返回 UIbtnLocQuery 特性值。* * return nc.ui.pub.beans.UIButton*/ /* 警告&#xff1a;此方法将重新生成。 */ private nc.ui.pub.beans.UIButton getUIbtnLocQuery() {// 搜索全部 按钮return getButtonPan…

探究HTTP API接口测试:工具、方法与自动化

本文将深入探讨HTTP API接口测试的重要性&#xff0c;并介绍了相关工具、方法以及自动化测试的实施&#xff0c;同时比较了HTTP和API接口测试的区别。从不同角度解析这一关键测试领域&#xff0c;帮助读者更好地理解和应用于实际项目中。 在如今数字化的世界中&#xff0c;软件…

【JavaEE】面向切面编程AOP是什么-Spring AOP框架的基本使用

【JavaEE】Spring AOP&#xff08;1&#xff09; 文章目录 【JavaEE】Spring AOP&#xff08;1&#xff09;1. Spring AOP 是什么1.1 AOP 与 Spring AOP1.2 没有AOP的世界是怎样的1.3 AOP是什么 2. Spring AOP 框架的学习2.1 AOP的组成2.1.1 Aspect 切面2.1.2 Pointcut 切点2.1…

【算法日志】贪心算法刷题:单调递增数列,贪心算法总结(day32)

代码随想录刷题60Day 目录 前言 单调递增数列 贪心算法总结 前言 今天是贪心算法刷题的最后一天&#xff0c;今天本来是打算刷两道题&#xff0c;其中的一道hard题做了好久都没有做出来(主要思路错了)。然后再总结一下。 单调递增数列 int monotoneIncreasingDigits(int n…

CST HFSS MATLAB参数方程定义曲面绘制

CST HFSS 函数定义曲面绘制 简介环境HFSSCSTMATLAB 简介 若在柱坐标系中半径r随z和phi都会变&#xff0c;无法使用一般的方法绘制&#xff0c;这时可以使用参数方程定义的曲面来绘制。举一个例子如下&#xff0c; r 100 0.5 ( c o s ( 0.2 ∗ p i ∗ z ) − 1 ) c o s ( φ …

初识网络原理(笔记)

目录 ​编辑局域网 网络通信基础 IP 地址 端口号 协议 协议分层 TCP / IP 五层网络模型 网络数据传输的基本流程 发送方的情况&#xff1a; 接收方的情况 局域网 搭建网络的时候&#xff0c;需要用到 交换机 和 路由器 路由器上&#xff0c;有 lan 口 和 wan 口 虽…

苍穹外卖 day2 反向代理和负载均衡

一 前端发送的请求&#xff0c;是如何请求到后端服务 前端请求地址&#xff1a;http://localhost/api/employee/login 路径并不匹配 后端接口地址&#xff1a;http://localhost:8080/admin/employee/login 二 查找前端接口 在这个页面上点击f12 后转到networ验证&#xff0…

K8s学习笔记4

场景&#xff1a; 项目研发部门最近要进行应用运行基础环境迁移&#xff0c;需要由原先的虚拟机环境迁移到K8s集群环境中&#xff0c;以便应对开发快速部署和快速测试的需要&#xff0c;因此&#xff0c;需要准备一套可以用于开发需求的K8s集群&#xff0c;但是对于仅有容器基…

Redis企业级解决方案

缓存预热 “ 宕机 ” 服务器启动后迅速宕机 问题排查 1. 请求数量较高 2. 主从之间数据吞吐量较大&#xff0c;数据同步操作频度较高 , 因为刚刚启动时&#xff0c;缓存中没有任何数据 解决方案 准备工作&#xff1a; 1. 日常例行统计数据访问记录&#xff0c;统计访…

Docker的基本使用

Docker 概念 Docker架构 docker分为客户端&#xff0c;Docker服务端&#xff0c;仓库 客户端 Docker 是一个客户端-服务器&#xff08;C/S&#xff09;架构程序。Docker 客户端只需要向 Docker 服务端发起请求&#xff0c;服务端将完成所有的工作并返回相应结果。 Docker …

Midjourney API 国内申请及对接方式

在人工智能绘图领域&#xff0c;想必大家听说过 Midjourney 的大名吧&#xff01; Midjourney 以其出色的绘图能力在业界独树一帜。无需过多复杂的操作&#xff0c;只要简单输入绘图指令&#xff0c;这个神奇的工具就能在瞬间为我们呈现出对应的图像。无论是任何物体还是任何风…

(排序) 剑指 Offer 51. 数组中的逆序对 ——【Leetcode每日一题】

❓剑指 Offer 51. 数组中的逆序对 难度&#xff1a;困难 在数组中的两个数字&#xff0c;如果前面一个数字大于后面的数字&#xff0c;则这两个数字组成一个逆序对。输入一个数组&#xff0c;求出这个数组中的逆序对的总数。 示例 1: 输入: [7,5,6,4] 输出: 5 限制&#xff…

铜矿人员定位安全方案

针对铜矿中的人员定位安全需求&#xff0c;可以采用以下方案&#xff1a; 1.实时人员定位系统&#xff1a;建立一个实时人员定位系统&#xff0c;通过在矿工的工作服或安全帽上安装UWB或RFID定位设备&#xff0c;以及相应的接收器和基站&#xff0c;实时跟踪和定位矿工的位置。…

设计模式——桥接模式

引用 桥我们大家都熟悉&#xff0c;顾名思义就是用来将河的两岸联系起来的。而此处的桥是用来将两个独立的结构联系起来&#xff0c;而这两个被联系起来的结构可以独立的变化&#xff0c;所有其他的理解只要建立在这个层面上就会比较容易。 基本介绍 桥接模式&#xff08;Br…

ceph集群的扩容缩容

文章目录 集群扩容添加osd使用ceph-deploy工具手动添加 添加节点新节点前期准备新节点安装ceph&#xff0c;出现版本冲突 ceph-deploy增加节点 集群缩容删除osd删除节点 添加monitor节点删除monitor节点使用ceph-deploy卸载集群 实验所用虚拟机均为Centos 7.6系统&#xff0c;8…

Spring5学习笔记—AOP编程

✅作者简介&#xff1a;大家好&#xff0c;我是Leo&#xff0c;热爱Java后端开发者&#xff0c;一个想要与大家共同进步的男人&#x1f609;&#x1f609; &#x1f34e;个人主页&#xff1a;Leo的博客 &#x1f49e;当前专栏&#xff1a; Spring专栏 ✨特色专栏&#xff1a; M…

完美解决微信小程序van-field left-icon自定义图片

实现效果&#xff1a; <view class"userName"><van-field left-icon"{{loginUserNameIcon}}" clearable class"fieldName" value"{{ loginUserName }}" placeholder"请输入账号" border"{{ false }}" &g…

APP上线为什么要提前部署安全产品呢?

一般平台刚上线或者日活跃量比较高的时候&#xff0c;很容易成为攻击者的目标&#xff0c;服务器如果遭遇黑客攻击&#xff0c;资源耗尽会导致平台无法访问&#xff0c;业务也无法正常开展&#xff0c;服务器一旦触发黑洞机制&#xff0c;就会被拉进黑洞很长一段时间&#xff0…