重学SpringBoot3-整合 Elasticsearch 8.x (三)使用Repository

更多SpringBoot3内容请关注我的专栏:《SpringBoot3》
期待您的点赞👍收藏⭐评论✍

在使用Spring Data Elasticsearch进行复杂查询时,Repository的接口方法以及定制查询能力可以帮助我们更灵活地构建高级用例。以下是几个具体示例:


1. 自定义查询方法

在Repository中,可以通过命名方法来自定义查询。Spring Data会根据方法名称自动生成查询语句。例如:

public interface ProductRepository extends ElasticsearchRepository<Product, String> {// 查找价格在特定范围内的商品List<Product> findByPriceBetween(double min, double max);// 查找包含指定关键词的商品名称List<Product> findByNameContaining(String keyword);
}

Spring Data Elasticsearch可以解析方法名并生成对应的Elasticsearch查询,不需要手动编写复杂的查询语句。

2. 使用@Query注解进行定制查询

对于更复杂的查询,@Query注解提供了自定义DSL(Domain Specific Language)查询的能力。例如,我们可以在Repository方法上使用Elasticsearch的查询语句:

public interface ProductRepository extends ElasticsearchRepository<Product, String> {@Query("{\"bool\": {\"must\": [{\"match\": {\"name\": \"?0\"}}]}}")List<Product> findByNameUsingCustomQuery(String name);
}

这样可以使查询语句更灵活,也可以与特定业务需求进行更贴合的查询逻辑设置。

3. 批量操作

在实际应用中,批量操作是常见的需求。ElasticsearchRepository 提供了批量保存和删除的接口方法:

@Autowired
private ProductRepository productRepository;public void saveAllProducts(List<Product> products) {productRepository.saveAll(products);
}public void deleteAllProducts(List<String> productIds) {productRepository.deleteAllById(productIds);
}

这对于处理大规模数据操作时能显著提升效率。

4. 高亮显示搜索结果

在很多搜索场景中,用户希望看到关键字在结果中的高亮显示,以便于理解上下文。Spring Data Elasticsearch通过HighlightBuilder实现高亮功能:

public SearchHits<Product> searchWithHighlight(String keyword) {NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchQuery("description", keyword)).withHighlightBuilder(new HighlightBuilder().field("description")).build();return elasticsearchRestTemplate.search(searchQuery, Product.class);
}

此方法会在查询结果中返回带有高亮效果的匹配内容,方便展示在用户界面中。


5. 聚合查询

聚合查询可以帮助分析数据分布、统计信息等。Spring Data Elasticsearch 支持多种类型的聚合查询,如Terms AggregationRange Aggregation等。以下示例展示了一个简单的分组统计:

public Map<String, Long> aggregateByCategory() {NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().addAggregation(AggregationBuilders.terms("categoryAgg").field("category")).build();SearchHits<Product> searchHits = elasticsearchRestTemplate.search(searchQuery, Product.class);Terms terms = (Terms) searchHits.getAggregations().get("categoryAgg");Map<String, Long> result = new HashMap<>();terms.getBuckets().forEach(bucket -> result.put(bucket.getKeyAsString(), bucket.getDocCount()));return result;
}

此代码使用 elasticsearchRestTemplate 执行聚合查询,可以统计每种category类型的文档数量,方便用于数据分析和展示。


6. 使用分页和排序

在实际应用中,查询结果往往需要分页或排序展示。Spring Data Elasticsearch提供了Pageable参数来支持分页,Sort参数来支持排序:

public Page<Product> findByCategory(String category, Pageable pageable) {return productRepository.findByCategory(category, pageable);
}

Pageable 可以指定页码和每页大小等参数,非常适合在数据量大的情况下分页查询。


7. 异步查询(使用 @Async)

在数据量较大的查询场景中,为了避免阻塞主线程,可以使用异步查询。通过添加 @Async 注解,方法会返回 CompletableFuture 类型,Spring 会自动异步执行该查询:

@Async
public CompletableFuture<List<Product>> findByCategoryAsync(String category) {return CompletableFuture.completedFuture(productRepository.findByCategory(category));
}

这种方式可以加快响应速度,特别是在Web应用中,有助于提升用户体验。


结论

Spring Data Elasticsearch Repository 提供了多样化的查询、定制化的操作和高效的数据处理方式。结合Spring Boot 3,用户可以利用它来实现丰富的搜索功能,从而为业务应用提供强大的搜索与数据分析能力。

使用上述方法,可以将Elasticsearch集成到应用中,不仅提升了系统的数据处理能力,还能满足复杂的业务需求。

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

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

相关文章

数据结构-并查集专题(2)

一、前言 接&#xff08;1&#xff09;完成剩余题目和了解并查集运用求解最小生成树的Kruskal算法 二、专题训练 2.1 题目总览 前四题见&#xff08;1&#xff09; 2.2 1568: 并查集-家谱 思路 首先这个题目的描述就有问题&#xff0c;它说每一组的父子关系由两行组成&…

吾店云介绍 – 中国人的WordPress独立站和商城系统平台

经过多年在WordPress建站领域的摸索和探索&#xff0c;能轻松创建和管理各种类型网站的平台 – 吾店云建站平台诞生了。 应该说这是一个艰苦卓绝的过程&#xff0c;在中国创建一个能轻松创建和使用WordPress网站的平台并不容易&#xff0c;最主要是网络环境和托管软件的限制。…

测试实项中的偶必现难测bug--<pre>标签问题

问题描述: 用户从网上copy的简介信息可能带有<pre>标签,导致安卓上的内容只能一行滑动展示,但是ios有对这个标签做特殊处理: 分析: <pre> 标签是 HTML 中用于表示预格式化文本的标签,它的作用是保留文本中的空格、换行和缩进。它的全称是 preformatted text…

管理 Elasticsearch 变得更容易了,非常容易!

作者&#xff1a;来自 Elastic Ken Exner Elasticsearch 用户&#xff0c;我们听到了你的心声。管理 Elasticsearch 有时会变得很复杂&#xff0c;面临的挑战包括性能调整、问题检测和资源优化。我们一直致力于简化你的体验。今天&#xff0c;我们宣布了自收购 Opster 以来的一…

微波无源器件 OMT1 一种用于倍频程接收机前端的十字转门四脊正交模耦合器(24-51GHz)

摘要&#xff1a; 我们报道了一种用于天文学射电望远镜的毫米波波长接收机的一种十字转门四脊OMT的设计&#xff0c;制造和实测结果。此四脊OMT被直接兼容到一个四脊馈电喇叭来实现可以拓展矩形波导单模带宽的双极化低噪声接收机。使用了24-51GHz的带宽&#xff0c;OMT证实了0.…

CCS 学习记录

1.导入项目 在CCS菜单中选择Project->Import Existing CCS Eclipse Project&#xff0c;点击Browse找到CCS workspace所在文件夹&#xff0c;点击OK&#xff0c;CCS会自动将所选文件夹及其子文件夹下所有的CCS Projects列出。从列表中找到所要导入的项目文件夹&#xff0c;…

【在Typora中绘制用户旅程图和甘特图】

在 Typora 中可以使用 Mermaid 绘制用户旅程图&#xff08;User Journey Map&#xff09;&#xff0c;但由于 Mermaid 并不直接支持用户旅程图&#xff0c;我们可以通过一些图表的变通方式&#xff08;比如流程图或甘特图&#xff09;来表示用户旅程图的结构。用户旅程图通常展…

如何使用IDEA创建Maven/SSM工程?

鉴于很多学校还在教授SSMJSP&#xff0c;很多同学不会使用IDEA创建Maven工程&#xff0c;这里进行说明 windows下安装jdk并配置环境 添加链接描述Windows下安装Maven并配置环境 首先你要本地安装jdk&#xff0c;Maven并配置基础环境变量&#xff0c;然后对IDEA进行jdk、Mave…

网络安全常见面试题--含答案

本文面试题汇总&#xff1a; 防范常见的 Web 攻击 重要协议分布层 arp协议的工作原理rip协议是什么&#xff1f;rip的工作原理 什么是RARP&#xff1f;工作原理OSPF协议&#xff1f;OSPF的工作原理 TCP与UDP区别总结 什么是三次握手四次挥手&#xff1f; tcp为什么要三次握手&…

C++内存泄漏检查工具——Valgrind(--tool = memcheck)

在写c程序中通常遇到程序崩溃&#xff0c;我们首先想到的是内存问题 如果代码量少看几遍就能看得出来&#xff0c;如果代码量多起来我们就得借助一些工具了比如gdb调试和valgrind中得memcheck来解决内存问题 我用的ubuntu&#xff0c;先安装valgrind sudo apt update sudo a…

原生 JavaScript基本内容和常用特性详解

原生 JavaScript&#xff08;也称为 Vanilla JS&#xff09;指的是不依赖于任何框架或库的纯 JavaScript。以下是原生 JavaScript 的一些基本内容和常用特性详解。 目录 1. 数据类型 2. 变量声明 3. 控制结构 4. 函数 5. 对象和数组 6. 事件处理 7. DOM 操作 8. Promi…

库打包工具 rollup

库打包工具 rollup 摘要 **概念&#xff1a;**rollup是一个模块化的打包工具 注&#xff1a;实际应用中&#xff0c;rollup更多是一个库打包工具 与Webpack的区别&#xff1a; 文件处理&#xff1a; rollup 更多专注于 JS 代码&#xff0c;并针对 ES Module 进行打包webpa…

基于promtail+loki+grafana搭建日志系统

文章目录 Promtail安装promtail创建配置文件创建systemd 服务文件启动promtail服务 loki下载loki服务创建config.yml文件创建systemd服务文件启动loki grafana下载grafana 本文基于promtaillokigrafanaprometheus&#xff08;可选&#xff09; 搭建一个轻量快速的日志系统&…

微服务容器化部署实践(FontConfiguration.getVersion)

文章目录 前言一、整体步骤简介二、开始实战1.准备好微服务2.将各个微服务打包为镜像第一种第二种3. 将各个打包好的镜像,通过docker-compose容器编排,运行即可总结前言 docker容器化部署微服务: 将微服务容器化部署到 Docker 容器中是一个常见的做法,可以提高应用的可移…

人工智能(AI)和机器学习(ML)技术学习流程

目录 人工智能(AI)和机器学习(ML)技术 自然语言处理(NLP): Word2Vec: Seq2Seq(Sequence-to-Sequence): Transformer: 范式、架构和自注意力: 多头注意力: 预训练、微调、提示工程和模型压缩: 上下文学习、思维链、全量微调、量化、剪枝: 思维树、思维…

Python 操作数据库:读取 Clickhouse 数据存入csv文件

import pandas as pd from clickhouse_driver import Client import timeit import logging import threading from threading import Lock from queue import Queue from typing import List, Dict, Set from contextlib import contextmanager import os import time# 配置参…

SCP收容物211~215

注 &#xff1a;此文接SCP收容物201~210,本文只供开玩笑 ,与steve_gqq_MC合作 --------------------------------------------------------------------------------------------------------------------------------- 目录 scp-211 scp-212 scp-213 scp-214 scp-215 s…

带你读懂什么是AI Agent智能体

一、智能体的定义与特性 定义&#xff1a;智能体是一个使用大语言模型&#xff08;LLM&#xff09;来决定应用程序控制流的系统。然而&#xff0c;智能体的定义并不唯一&#xff0c;不同人有不同的看法。Langchain的创始人Harrison Chase从技术角度给出了定义&#xff0c;但更…

docker-compose在阿里云服务器上部署https所踩的各种坑(已成功部署)

前言 购买服务器&#xff0c;申请域名&#xff0c;申请证书&#xff0c;下载nginx证书&#xff0c;这些操作我就不说了&#xff0c;百度一大把&#xff0c;我只说一下部署中碰到的问题 问题 我们是docker-compose上部署的后台前台环境&#xff0c;配置https证书&#xff0c;…

Qt_day3_信号槽

目录 信号槽 1. 概念 2. 函数原型 3. 连接方式 3.1 自带信号 → 自带槽 3.2 自带信号 → 自定义槽 3.3 自定义信号 4. 信号槽传参 5. 对应关系 5.1 一对多 5.2 多对一 信号槽 1. 概念 之前的程序界面只能看&#xff0c;不能交互&#xff0c;信号槽可以让界面进行人机…