【Elasticsearch】spring-boot-starter-data-elasticsearch的使用以及Elasticsearch集群的连接

更多有关博主写的往期Elasticsearch文章

标题地址
【ElasticSearch 集群】Linux安装ElasticSearch集群(图文解说详细版)https://masiyi.blog.csdn.net/article/details/131109454
基于SpringBoot+ElasticSearch 的Java底层框架的实现https://masiyi.blog.csdn.net/article/details/121534307
ElasticSearch对标Mysql,谁能拔得头筹?https://masiyi.blog.csdn.net/article/details/122661822
同事说关键字查询用Mysql,我上去就是一个高压锅,用ElasticSearch不香吗?https://masiyi.blog.csdn.net/article/details/122701654
新年第一天,老板让升级ElasticSearch版本,我说得加钱https://masiyi.blog.csdn.net/article/details/122819455
使用了ElasticSearch之后,公司系统查询速度快了50倍,工资直接翻一倍https://masiyi.blog.csdn.net/article/details/122819455
ElasticSearch实战教程PostMan版(超级详细版)https://masiyi.blog.csdn.net/article/details/123048119
Linux安装ElasticSearch以及Ik分词器(图文解说详细版)https://masiyi.blog.csdn.net/article/details/121509681

文章目录

    • 🐝第一步,创建一个springboot项目
    • 🐝第二步,导入spring-boot-starter-data-elasticsearch依赖
    • 🐝第三步,配置yml文件
    • 🐝第四步,编写es索引对应的实体类
    • 🐝第五步,编写实体类对应的mapper
    • 🐝第六步,使用框架自带的增删改查
      • 🐝增
        • 🐝使用ElasticsearchRestTemplate
        • 🐝使用mapper
        • 🐝设置指定的id
        • 🐝批量保存
      • 🐝删
        • 🐝传入实体类删
        • 🐝传入id删
        • 🐝删除索引里面所有的数据(慎用)
      • 🐝改
        • 🐝实体改
        • 🐝实体改全部
        • 🐝先查再update
        • 🐝直接使用局部更新
      • 🐝查
        • 🐝根据id查
        • 🐝根据id列表查
        • 🐝查询全部数据
        • 🐝排序查-正序
        • 🐝排序查-倒序
        • 🐝分页查
        • 🐝自定义复杂的查询
    • 🐝第七步,使用JPA风格的查询方式
        • 🐝根据age查询
        • 🐝查询所有符合age的数据
        • 🐝查询最top的数据

导语

发现很多公司都是自己导入原生的jar包自己去封装一套Elasticsearch的框架,这样虽然可以自定义业务,但是需要花费很多的时间,其实spring官方有一套springboot的starter,帮助大家快速入手官网的starter,这篇博客也会介绍使用该starter连接Elasticsearch的集群。该starter有点像mybatisplus+Jpa,如果熟悉这两个框架的同学应该很快就会上手。

官网地址:
https://docs.spring.io/spring-data/elasticsearch/docs/4.0.x/reference/html/#preface

本文所有的代码都已经提交到git仓库中,仓库地址:
https://gitee.com/WangFuGui-Ma/spring-boot-elasticSearch

在这里插入图片描述

现在我们开始按照步骤进行spring-boot-starter-data-elasticsearch的使用,本文中使用的spring boot版本为2.7.x 对于的elasticsearch客户端版本为7.17.x

🐝第一步,创建一个springboot项目

在这里插入图片描述

🐝第二步,导入spring-boot-starter-data-elasticsearch依赖

		<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId></dependency>

其他依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--json--><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.76</version></dependency><!--json-->

在这里插入图片描述

🐝第三步,配置yml文件

spring:elasticsearch:uris:- 192.168.75.128:9200- 192.168.75.129:9200- 192.168.75.130:9200
server:port: 8889

uris这里填的是集群的地址,如果你的es是单机版的,直接填一个就行了

🐝第四步,编写es索引对应的实体类

import lombok.Data;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.WriteTypeHint;/*** @Author masiyi* @Date 2023/6/14 13:46* @PackageName:com.masiyi.springbootstarterdataelasticsearch.doman* @ClassName: ElasticTest* @Description: TODO* @Version 1.0*/
@Data
@Document(indexName = "elastic_test",writeTypeHint = WriteTypeHint.FALSE)
public class ElasticTest {private Long id;private String name;private Integer age;private Boolean isMan;
}

注:

  • id这个类型一定要写,否则会报错
  • indexName对应es中的索引
  • writeTypeHint如果为false则不会自动创建索引

🐝第五步,编写实体类对应的mapper

类似mybatis一样,我们需要创建对应的mapper

public interface ElasticTestMapper extends ElasticsearchRepository<ElasticTest,Long> {}

继承ElasticsearchRepository类,第一个泛型添es对应的实体类,第二个泛型添id的类型

🐝第六步,使用框架自带的增删改查

我们这次用单元测试的方法跟大家演示框架的用法

在这里插入图片描述

注入刚刚创建的mapper和框架的ElasticsearchRestTemplate

🐝增

🐝使用ElasticsearchRestTemplate

   @Testvoid save() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("李四");elasticTest.setAge(23);elasticTest.setIsMan(true);elasticsearchTemplate.save(elasticTest);}

🐝使用mapper

    @Testvoid insert() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("李四");elasticTest.setAge(23);elasticTest.setIsMan(true);elasticTestMapper.save(elasticTest);}

🐝设置指定的id

   @Testvoid insertId() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("掉头发的王富贵");elasticTest.setAge(25);elasticTest.setIsMan(true);elasticTest.setId(2434235L);elasticTestMapper.save(elasticTest);}

🐝批量保存

    @Testvoid saveAll() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("李四");elasticTest.setAge(24);elasticTest.setIsMan(true);elasticTestMapper.saveAll(Arrays.asList(elasticTest));}

🐝删

🐝传入实体类删

    @Testvoid delete() {ElasticTest elasticTest = new ElasticTest();elasticTest.setId(2342342L);elasticTestMapper.delete(elasticTest);}

🐝传入id删

    @Testvoid deleteById() {elasticTestMapper.deleteById(2342342L);}

🐝删除索引里面所有的数据(慎用)

    @Testvoid deleteAll() {elasticTestMapper.deleteAll();}

🐝改

🐝实体改

    @Testvoid update() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("掉头发的王富贵hh");elasticTest.setId(2434235L);elasticTestMapper.save(elasticTest);}

这里改会把其他的不在实体里面为null的数据清空

在这里插入图片描述

🐝实体改全部

 @Testvoid updateAll() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("掉头发的王富贵");elasticTest.setAge(24);elasticTest.setIsMan(true);elasticTest.setId(2434234L);elasticTestMapper.save(elasticTest);}

如果我们只需要局部更新,可以使用下面的两种方法

🐝先查再update

    @Testvoid updateNow() {ElasticTest elasticTest = elasticTestMapper.findById(2434234L).get();elasticTest.setName("不掉头发的王富贵");elasticTestMapper.save(elasticTest);}

但是这个方法会消耗性能,所以推荐用下面的方法

🐝直接使用局部更新

    @Testvoid updateNow2() {ElasticTest elasticTest = new ElasticTest();elasticTest.setName("掉头发的王富贵h");Map map = JSONObject.parseObject(JSONObject.toJSONString(elasticTest), Map.class);UpdateQuery updateQuery = UpdateQuery.builder("0ZUv7okBcQy9f7u_tXkH").withDocument(Document.from(map)).build();elasticsearchTemplate.update(updateQuery, IndexCoordinates.of("elastic_test"));}

在这里插入图片描述

🐝查

🐝根据id查

    @Testvoid select() {Optional<ElasticTest> byId = elasticTestMapper.findById(2434234L);byId.ifPresent(System.out::println);}

🐝根据id列表查

  @Testvoid findAllById() {Iterable<ElasticTest> allById = elasticTestMapper.findAllById(Arrays.asList(2434234L));allById.forEach(System.out::println);}

🐝查询全部数据

    @Testvoid findAll() {Iterable<ElasticTest> allById = elasticTestMapper.findAll();allById.forEach(System.out::println);}

🐝排序查-正序

    @Testvoid findAllSort() {Sort age = Sort.by("age").ascending();Iterable<ElasticTest> all = elasticTestMapper.findAll(age);all.forEach(System.out::println);}

🐝排序查-倒序

    @Testvoid findAllSortDE() {Sort age = Sort.by("age").descending();Iterable<ElasticTest> all = elasticTestMapper.findAll(age);all.forEach(System.out::println);}

🐝分页查

    @Testvoid findAllPage() {PageRequest pageRequest = PageRequest.of(0, 10);Page<ElasticTest> all = elasticTestMapper.findAll(pageRequest);all.forEach(System.out::println);System.out.println(JSON.toJSONString(all));}

🐝自定义复杂的查询

 @Testvoid findMyStyle() {TermQueryBuilder termQueryBuilder = new TermQueryBuilder("name.keyword", "掉头发的王富贵");NativeSearchQuery nativeSearchQuery = new NativeSearchQuery(termQueryBuilder);SearchHits<ElasticTest> search = elasticsearchTemplate.search(nativeSearchQuery, ElasticTest.class);List<SearchHit<ElasticTest>> hitList = search.getSearchHits();for (SearchHit<ElasticTest> hit : hitList) {ElasticTest entity = hit.getContent(); // 获取实体对象System.out.println(entity);String index = hit.getIndex(); // 获取索引名System.out.println(index);}}

🐝第七步,使用JPA风格的查询方式

如果会用jpa的同学看到这个可能会非常得熟悉

在这里插入图片描述
可以自定义查询方法find...

🐝根据age查询

    ElasticTest findByAge(Integer age);

🐝查询所有符合age的数据

    List<ElasticTest> findAllByAge(Integer age);

🐝查询最top的数据

    ElasticTest findTopByAge(Integer age);

如果你使用的是idea这种高级的编辑器,你在mapper写方法的时候会自动提示你。

在这里插入图片描述

通过本文的学习,我们探索了在Spring Boot应用中使用Elasticsearch的方法以及如何连接到Elasticsearch集群。Elasticsearch作为一款强大的搜索和分析引擎,在现代应用开发中扮演着至关重要的角色。借助于Spring Boot和spring-boot-starter-data-elasticsearch,我们能够以更加便捷的方式将Elasticsearch集成到我们的项目中,实现高效的数据搜索与分析。

通过配置简单明了的属性,我们能够快速地将Spring Boot应用连接到Elasticsearch集群,实现数据的索引、搜索和分析。借助于Spring Data Elasticsearch提供的强大功能,我们能够轻松地定义实体类、进行CRUD操作,并且利用Elasticsearch的全文搜索和分词等特性,让我们的应用具备更高效的查询和检索能力。

在这里插入图片描述

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

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

相关文章

STM32 定时器复习

12MHz晶振的机器周期是1us&#xff0c;因为单片机的一个机器周期由6个状态周期组成&#xff0c;1个机器周期6个状态周期12个时钟周期&#xff0c;因此机器周期为1us。 51单片机常用 for(){__nop(); //执行一个机器周期&#xff0c;若想循环n us&#xff0c;则循环n次。 }软件…

Streamlit项目:基于讯飞星火认知大模型开发Web智能对话应用

文章目录 1 前言2 API获取3 官方文档的调用代码4 Streamlit 网页的搭建4.1 代码及效果展示4.2 Streamlit相关知识点 5 结语 1 前言 科大讯飞公司于2023年8月15日发布了讯飞认知大模型V2.0&#xff0c;这是一款集跨领域知识和语言理解能力于一体的新一代认知智能大模型。前日&a…

Stable Diffusion原理详解

Stable Diffusion原理详解 最近AI图像生成异常火爆&#xff0c;听说鹅厂都开始用AI图像生成做前期设定了&#xff0c;小厂更是直接用AI替代了原画师的岗位。这一张张丰富细腻、风格各异、以假乱真的AI生成图像&#xff0c;背后离不开Stable Diffusion算法。 Stable Diffusion…

java 微信小程序授权获取用户手机号码 (完整demo)

1. 前端获取动态令牌 code https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/getPhoneNumber.html 2. 后端接收令牌code, 调用微信获取手机号接口 POST https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_tokenACCESS_TOKEN 3. con…

[附源码]计算机毕业设计-JAVA火车票订票管理系统-springboot-论-文-ppt

PPT论文 文章目录 前言一、主要技术javaMysql数据库JSP技术 二、系统设计三、功能截图总结 前言 本论文主要论述了如何使用JAVA语言开发一个火车订票管理系统 &#xff0c;本系统将严格按照软件开发流程进行各个阶段的工作&#xff0c;采用B/S架构&#xff0c;面向对象编程思想…

ORB-SLAM2学习笔记7之System主类和多线程

文章目录 0 引言1 整体框架1.1 整体流程 2 System主类2.1 成员函数2.2 成员变量 3 多线程3.1 ORB-SLAM2中的多线程3.2 加锁 0 引言 ORB-SLAM2是一种基于特征的视觉SLAM&#xff08;Simultaneous Localization and Mapping&#xff09;系统&#xff0c;它能够从单个、双目或RBG…

线性代数的学习和整理7:各种特殊矩阵(草稿-----未完成)

目录 1 单位矩阵 为什么单位矩阵I是 [1,0;0,1]T 而不是[1,1;1,1]T 2 旋转矩阵 3 伸缩矩阵 放大缩小倍数矩阵 4 镜像矩阵 5 剪切矩阵 1 矩阵 1.1 1维的矩阵 行向量列向量 1.2 2维的矩阵 一般2维表都可以看作矩阵。矩阵的每个维度可以是1个数字&#xff0c;也可以是多个…

Appium-移动端自动测试框架,如何入门?

Appium是一个开源跨平台移动应用自动化测试框架。 既然只是想学习下Appium如何入门&#xff0c;那么我们就直奔主题。文章结构如下&#xff1a; 1、为什么要使用Appium&#xff1f; 2、如何搭建Appium工具环境?(超详细&#xff09; 3、通过demo演示Appium的使用 4、Appium如何…

通讯录的实现

> 作者简介&#xff1a;დ旧言~&#xff0c;目前大一&#xff0c;现在学习Java&#xff0c;c&#xff0c;c&#xff0c;Python等 > 座右铭&#xff1a;松树千年终是朽&#xff0c;槿花一日自为荣。 > 望小伙伴们点赞&#x1f44d;收藏✨加关注哟&#x1f495;&#x1…

深入理解分布式架构,构建高效可靠系统的关键

深入探讨分布式架构的核心概念、优势、挑战以及构建过程中的关键考虑因素。 引言什么是分布式架构&#xff1f;分布式架构的重要性 分布式系统的核心概念节点和通信数据分区与复制一致性与一致性模型负载均衡与容错性 常见的分布式架构模式客户端-服务器架构微服务架构事件驱动…

[国产MCU]-W801开发实例-GPIO输入与中断

GPIO输入与中断 文章目录 GPIO输入与中断1、硬件准备2、软件准备3、驱动实现4、驱动测试W801的GPIO支持软件配置中断,中断触发方式包含:上升沿触发、下降沿触发、高电平触发、低电平触发。本文在前面[ 国产MCU]-W801开发实例-按键与GPIO输入的基础上实现GPIO中断配置。 1、硬…

分布式 | 如何搭建 DBLE 的 JVM 指标监控系统

本篇文章采用 Docker 方式搭建 Grafana Prometheus 实现对 DBLE 的 JVM 相关指标的监控系统。 作者&#xff1a;文韵涵 爱可生 DBLE 团队开发成员&#xff0c;主要负责 DBLE 需求开发&#xff0c;故障排查和社区问题解答。 本文来源&#xff1a;原创投稿 爱可生开源社区出品&a…

亚马逊点击广告对于卖家有什么好处

亚马逊点击广告对卖家来说有许多好处&#xff0c;它们可以帮助卖家增加产品曝光、提高销售量&#xff0c;并改善他们在亚马逊平台上的竞争地位。以下是一些卖家可能从亚马逊点击广告中获益的好处&#xff1a; 1、增加产品曝光度&#xff1a;通过在关键搜索结果页面上投放广告&…

MySQL8.0.26-Linux版安装

MySQL8.0.26-Linux版安装 1. 准备一台Linux服务器 云服务器或者虚拟机都可以; Linux的版本为 CentOS7; 2. 下载Linux版MySQL安装包 MySQL :: Download MySQL Community Server (Archived Versions) 3. 上传MySQL安装包 4. 创建目录,并解压 mkdir mysql ​ tar -xvf mysql-8…

Flink 数据集成服务在小红书的降本增效实践

摘要&#xff1a;本文整理自实时引擎研发工程师袁奎&#xff0c;在 Flink Forward Asia 2022 数据集成专场的分享。本篇内容主要分为四个部分&#xff1a; 小红书实时服务降本增效背景Flink 与在离线混部实践实践过程中遇到的问题及解决方案未来展望 点击查看原文视频 & 演…

Spring Clould 负载均衡 - Ribbon

视频地址&#xff1a;微服务&#xff08;SpringCloudRabbitMQDockerRedis搜索分布式&#xff09; Ribbon-负载均衡原理&#xff08;P14&#xff09; 具体实现时通过LoaBalanced注解实现&#xff0c;表示RestTemplate要被Ribbon拦截处理 orderservice调用user时候&#xff0c…

FPGA原理与结构——RAM IP核的使用与测试

目录 一、前言 二、RAM IP核定制 1、RAM IP核 step1 打开vivado工程&#xff0c;点击左侧栏中的IP Catalog step2 在搜索栏搜索RAM&#xff0c;找到Block Memory Generator IP核&#xff1a; 2、IP核定制 step3 Baisc界面定制 step4 端口定制 step5 Other Options st…

八种架构演进

日升时奋斗&#xff0c;日落时自省 目录 1、单机架构 2、应用数据分离架构 3、应用服务集群架构 4、读写分离/主从分离架构 5、冷热分离架构 6、垂直分库架构 7、微服务架构 8、容器编排架构 9、小结 1、单机架构 特征&#xff1a;应用服务和数据库服务器公用一台服务…

【vim 学习系列文章 5 - cscope 过滤掉某些目录】

文章目录 cscope 过滤目录介绍 cscope 过滤目录介绍 第一步创建自己的cscope脚本~/.local/bin/cscope.sh&#xff0c;如下&#xff1a; function my_cscope() {CODE_PATHpwdecho "$CODE_PATH"echo "start cscope...."if [ ! -f "$CODE_PATH/cscope.…

图片速览 FlashAttention+Softmax的安全计算形式(暂记)

FlashAttention最基础的方案来自使用高速的share memory来加速Softmax操作&#xff0c;实现Softmax的tiling方案。&#xff08;Q,K,V之间的乘法可由gemm实现。&#xff09; 左侧为GPU各部分的访问速度比较 FlashAttention使用平铺来防止大型实体化&#x1d441; &#x1d44…