前言:

本文不赘述Elasticsearch的相关基础知识点和部署,只介绍如何在SpringBoot如何集成Elasticsearch并进行数据操作

Spring Data项目中提供了操作es的框架Spring Data Elasticsearch,目前框架最新版本为4.0

根据Spring Data Elasticsearch的官方文档描述,4.0版本的框架支持Elasticsearch版本最新为7.6,更新的版本应该是不支持的

我自己在学习Elasticsearch过程中,发现网上SpringBoot集成es操作的相关博客资料不是很多,而且大多数版本比较旧、普通都很简略(可能过个一年半载我这篇文章也会被淘汰了hh),Elasticsearch的版本迭代是很快的,所以建议大家在学习一些比较新的技术或框架的时候,最好是配合官方文档进行资料查阅,英文不好可以借助翻译工具,有时能够避免很多弯路


1、创建SpringBoot项目,引入Spring Data Elasticsearch依赖,目前默认版本是4.0

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

2、配置文件

spring:
application:
name: es-demo
elasticsearch:
rest:
uris: http://localhost:9200 #es服务器地址(默认) server:
port: 8080

3、创建一个Book类,相当于Elasticsearch中的文档,用于演示

@Document(indexName = "book")
public class Book { //@Id注解表明该字段是文档id
@Id
private Integer id; private String title; private BigDecimal price; @Field(type = FieldType.Keyword)
private List<String> tag; //此处省略getter、setter、toString...
}

项目构建并配置完成后,就可以使用Spring Data Elasticsearch框架提供的各种类进行操作了


用法一:基于JPA Repository的方式,继承ElasticsearchRepository接口后,方法名按照框架要求的命名规则,就能创建各种各样的条件查询,适合一些比较简单的查询操作,更详细的可以参考文档(https://docs.spring.io/spring-data/elasticsearch/docs/4.0.2.RELEASE/reference/html/#elasticsearch.query-methods.criterions

1、创建用于Book对象的增删改查接口

@Repository
public interface BookRepository extends ElasticsearchRepository<Book, Integer> { //findById()和save()之类的方法父接口已经写了,这里无需重复编写 //按价格区间查询
List<Book> findByPriceBetween(BigDecimal min, BigDecimal max); //按书名查询,因为使用了中文分词器ik,所以这里并不是精确查询
List<Book> findByTitle(String title); //按标签匹配查询
List<Book> findByTagIn(List<String> tags);
}

接口写好后,使用@Autowired注解自动注入即可使用,具体测试这里不赘述

用法二:高级Rest接口,使用ElasticsearchRestTemplate类操作,除了支持简单数据增删改查之外,还支持对索引进行操作;配合查询条件/聚合构造器NavtiveQueryBuilder、QueryBuilders、AggregationBuilders,可以进行一些复杂的查询和聚合操作,但需要对Elasticsearch的Query DSL比较熟悉

@SpringBootTest
public class EsRestTemplateTest { //自动注入即可使用
@Autowired
private ElasticsearchRestTemplate esRestTemplate; //按id查询
@Test
void testQueryBookById() {
Book book = esRestTemplate.get("1", Book.class);
Assertions.assertNotNull(book);
System.out.println(book.toString());
} //按书名查询
@Test
void testQueryBookByTitle() {
NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(QueryBuilders.matchQuery("title", "Java"))
.build();
SearchHits<Book> searchHits = esRestTemplate.search(searchQuery, Book.class);
//SearchHits就是查询的结果集
searchHits.get().forEach(hit -> {
System.out.println(hit.getContent());
});
} //聚合操作-计算所有书籍的平均价格
@Test
void testAggregationBookAvgPrice() {
//聚合名为avg_price,对price字段进行聚合,计算平均值
NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
.addAggregation(AggregationBuilders.avg("avg_price").field("price"))
.build();
SearchHits<Book> searchHits = esRestTemplate.search(searchQuery, Book.class);
searchHits.get().forEach(hit -> {
System.out.println(hit.getContent());
});
//获取聚合结果
if (searchHits.hasAggregations()) {
ParsedAvg parsedAvg = searchHits.getAggregations().get("avg_price");
Assertions.assertNotNull(parsedAvg, "无聚合结果");
System.out.println(parsedAvg.getValue());
}
} //......
}

以上是ElasticsearchRestTemlpate类的简单用法,其他用法可以自行探索,构造器的方法名都和Elasticsearch的Query DSL基本一致,所以如果对Query DSL比较熟悉的话,用起来也不会很难


项目代码:https://github.com/ahrenJ/springboot-es

SpringBoot集成Elasticsearch7.6的更多相关文章

  1. 【springBoot】springBoot集成redis的key,value序列化的相关问题

    使用的是maven工程 springBoot集成redis默认使用的是注解,在官方文档中只需要2步; 1.在pom文件中引入即可 <dependency> <groupId>o ...

  2. SpringBoot集成security

    本文就SpringBoot集成Security的使用步骤做出解释说明.

  3. springboot集成Actuator

    Actuator监控端点,主要用来监控与管理. 原生端点主要分为三大类:应用配置类.度量指标类.操作控制类. 应用配置类:获取应用程序中加载的配置.环境变量.自动化配置报告等与SpringBoot应用 ...

  4. SpringBoot集成Shiro并用MongoDB做Session存储

    之前项目鉴权一直使用的Shiro,那是在Spring MVC里面使用的比较多,而且都是用XML来配置,用Shiro来做权限控制相对比较简单而且成熟,而且我一直都把Shiro的session放在mong ...

  5. SpringBoot集成redis的key,value序列化的相关问题

    使用的是maven工程 springBoot集成redis默认使用的是注解,在官方文档中只需要2步; 1.在pom文件中引入即可 <dependency> <groupId>o ...

  6. springboot集成mybatis(二)

    上篇文章<springboot集成mybatis(一)>介绍了SpringBoot集成MyBatis注解版.本文还是使用上篇中的案例,咱们换个姿势来一遍^_^ 二.MyBatis配置版(X ...

  7. springboot集成mybatis(一)

    MyBatis简介 MyBatis本是apache的一个开源项目iBatis, 2010年这个项目由apache software foundation迁移到了google code,并且改名为MyB ...

  8. springboot集成redis(mybatis、分布式session)

    安装Redis请参考:<CentOS快速安装Redis> 一.springboot集成redis并实现DB与缓存同步 1.添加redis及数据库相关依赖(pom.xml) <depe ...

  9. SpringBoot集成jsp

    一.springBoot集成jsp: 1.修改pom文件 <!--集成jsp所需jar包--> <!--jsp页面使用jstl标签--> <dependency> ...

  10. springboot集成schedule(深度理解)

    背景 在项目开发过程中,我们经常需要执行具有周期性的任务.通过定时任务可以很好的帮助我们实现. 我们拿常用的几种定时任务框架做一个比较: 从以上表格可以看出,Spring Schedule框架功能完善 ...

随机推荐

  1. RSA算法详解及C语言实现

    RSA算法它是第一个既能用于数据加密也能用于数字签名的算法.它易于理解和操作,也很流行.算法的名字以发明者的名字命名:Ron Rivest, Adi Shamir 和Leonard Adleman.但 ...

  2. 华为oj 统计字符串不同字符

    #include <stdio.h> #include <string.h> int firstSingle(char *str) { int hash[128]={0}; f ...

  3. SQL2-子查询、join查询

    SQL常用高级查询包括:Join查询.子查询. 子查询: USE flowershopdb --子查询:在一个select语句使用另一个select 语句作为条件或数据来源. --查询块:一个sele ...

  4. WinMM.dll 函数汇总

    #include "MMSystem.h" auxGetDevCaps                  查询指定的辅助输出设备以确定其性能 auxGetNumDevs       ...

  5. 2.13.2. 对结果集进行筛选(Core Data 应用程序实践指南)

    Core Data通过谓词(NSPredicate)来筛选,比如限定获取的数量等.谓词基本对存储区不敏感,但也有例外,比如:matches可用在 in-memory存储区,但是不能用在SQLite存储 ...

  6. OO第三次博客

    规格化设计的发展历史 在计算机的早期发展中,软件开发没有可以遵循的系统方法,往往只有源代码而没有软件说明书等文档,因此这段时期的软件通用性时很有限的.后来到了20世纪60年代,软件开始被广泛使用,软件 ...

  7. python编码,赋值和is的区别

    1. == 与 is 的区别 赋值 == 比较值是否相等,is 比较,比较的是内存地址. 小数据池的作用是节省内存空间 数字的范围:-5 到 256 共用一个数据池 字符串范围:1.不能有特殊字符.2 ...

  8. React Router 用法

    React Router 用法 一.DEMO import React from "react"; import { HashRouter as Router, Route, Li ...

  9. 01背包问题之2(dp)

    01背包问题之2 有n个物品,重量和价值分别为wi和vi,从这些物品中挑选出重量不超过W的物品,求所有挑选方案中物品价值总和的最大值 限制条件: 1 <= n <= 100; 1 < ...

  10. 软件测试基础Ⅲ(osi7层协议,测试模型,LoadRunner组件,软件质量模型)

    osi7层开放式系统互连网络模型 1.物理层:主要定义物理设备标准,如网线的接口类型.光纤的接口类型.各种传输介质的传输速率等.它的主要作用是传输比特流(就是由1.0转化为电流强弱来进行传输,到达目的 ...