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

news/2025/1/20 11:30:47/

更多SpringBoot3内容请关注我的专栏：《SpringBoot3》
期待您的点赞??收藏评论

整合 Elasticsearch 8.x （二）使用Repository
  • 1. 环境准备
    • 1.1 项目依赖
    • 1.2 Elasticsearch 配置
  • 2. 使用Repository的基本步骤
    • 2.1 创建实体类
    • 2.2 创建 Repository 接口
      • 2.2.1 主要作用和优点
      • 2.2.2 使用场景
    • 2.3 服务层实现
    • 2.4 控制器层
  • 3. 测试应用
    • 3.1 启动 Elasticsearch
    • 3.2 启动 Spring Boot 应用
    • 3.3 测试 API
  • 4. 总结

上一篇文章介绍了 Spring Boot 3 整合 Elasticsearch 8.x 的几种客户端形式，除此之外，Spring Data 对 Elasticsearch 还提供了 Repository 支持，与前面讨论的JPA Repository 一样，其基本原理是根据方法名称自动为你构建查询，提供了更简便的数据搜索和分析功能。本文将介绍如何使用 Spring Data Elasticsearch Repository 来构建一个简单的搜索应用。

1. 环境准备

1.1 项目依赖

在 pom.xml 中添加以下依赖：

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

确保 spring-boot-starter-data-elasticsearch 的版本与 Spring Boot 3 兼容。

1.2 Elasticsearch 配置

在 application.properties 或 application.yml 中配置 Elasticsearch 的连接信息：

spring:elasticsearch:uris: "http://localhost:9200"socket-timeout: "10s"username: "user"password: "secret"

2. 使用Repository的基本步骤

2.1 创建实体类

我们定义一个 Product 实体类，表示产品信息：

package com.coderjia.boot318es.bean;import lombok.AllArgsConstructor;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;/*** @author CoderJia* @create 2024/11/3 下午 04:37* @Description**/
@Data
@Document(indexName = "products")
@AllArgsConstructor
public class Product {@Idprivate String id;private String name;private String description;private double price;
}

2.2 创建 Repository 接口

ElasticsearchRepository 是 Spring Data Elasticsearch 提供的一个接口，用于简化与 Elasticsearch 交互的操作。它继承自 CrudRepository 和 PagingAndSortingRepository，扩展了基本的 CRUD（创建、读取、更新、删除）功能，支持分页和排序，还提供了对 Elasticsearch 特有的操作支持。使用 ElasticsearchRepository，开发者可以快速构建功能全面的数据访问层，而无需编写复杂的 Elasticsearch 客户端代码。

2.2.1 主要作用和优点
  1. 简化数据操作：提供了基础的 CRUD 方法，如 save()、findById()、findAll() 和 deleteById() 等，方便开发者直接使用。
  2. 自定义查询：通过定义接口中的方法（如 findByName(String name)），可以自动生成符合方法命名规范的查询。
  3. 分页与排序：内置了分页和排序支持，方法如 findAll(Pageable pageable) 可以直接返回分页数据。
  4. 与 Spring 无缝集成：使用 Spring 的依赖注入和配置机制，无需手动创建或管理客户端连接。
  5. 减少代码复杂度：自动实现常用的数据库操作，减少重复代码，提高开发效率。
2.2.2 使用场景
  • 需要快速实现基于 Elasticsearch 的应用程序，且不希望编写底层客户端调用代码。
  • 开发中涉及到简单或中等复杂度的查询，使用方法命名约定生成查询即可满足需求。
  • 项目中需要分页、排序功能而不想手动处理分页逻辑。

定义 ProductRepository 接口，继承 ElasticsearchRepository：

package com.coderjia.boot318es.dao;import com.coderjia.boot318es.bean.Product;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;import java.util.List;/*** @author CoderJia* @create 2024/11/4 下午 09:29* @Description**/
public interface ProductRepository extends ElasticsearchRepository<Product, String> {/*** 自定义通过name查询** @param name* @return*/List<Product> findByName(String name);
}

2.3 服务层实现

在服务层中实现增删改查的业务逻辑：

package com.coderjia.boot318es.service;import com.coderjia.boot318es.bean.Product;
import com.coderjia.boot318es.dao.ProductRepository;
import jakarta.annotation.Resource;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;import java.util.List;
import java.util.Optional;/*** @author CoderJia* @create 2024/11/4 下午 09:29* @Description**/
@Service
public class ProductService {@Resourceprivate ProductRepository productRepository;// 创建或更新产品public Product saveProduct(Product product) {return productRepository.save(product);}// 根据 ID 查询产品public Optional<Product> findById(String id) {return productRepository.findById(id);}// 根据名称查询产品public List<Product> findByName(String name) {return productRepository.findByName(name);}// 获取所有产品public Page<Product> findAll(Pageable pageable) {return productRepository.findAll(pageable);}// 删除产品public void deleteProduct(String id) {productRepository.deleteById(id);}
}

2.4 控制器层

在控制器层实现 REST API 接口，处理增删改查请求：

package com.coderjia.boot318es.controller;import com.coderjia.boot318es.bean.Product;
import com.coderjia.boot318es.service.ProductService;
import jakarta.annotation.Resource;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Optional;/*** @author CoderJia* @create 2024/11/4 下午 09:30* @Description**/
@RestController
@RequestMapping("/products")
public class ProductController {@Resourceprivate ProductService productService;// 创建或更新产品@PostMappingpublic Product createOrUpdateProduct(@RequestBody Product product) {return productService.saveProduct(product);}// 根据 ID 查询产品@GetMapping("/{id}")public Optional<Product> getProductById(@PathVariable String id) {return productService.findById(id);}// 根据名称查询产品@GetMapping("/search")public List<Product> searchByName(@RequestParam String name) {return productService.findByName(name);}// 获取所有产品@GetMappingpublic List<Product> getAllProducts(@RequestParam(defaultValue = "0") int page,@RequestParam(defaultValue = "10") int size) {Pageable pageable = PageRequest.of(page, size);Page<Product> products = productService.findAll(pageable);return products.getContent();}// 删除产品@DeleteMapping("/{id}")public String deleteProduct(@PathVariable String id) {productService.deleteProduct(id);return "Product deleted successfully!";}
}

3. 测试应用

3.1 启动 Elasticsearch

确保 Elasticsearch 8.x 正在运行，并且可以通过 http://localhost:9200 访问。

3.2 启动 Spring Boot 应用

运行 Spring Boot 应用，确保没有错误。

3.3 测试 API

创建产品：

POST http://localhost:8080/products
Content-Type: application/json{"id": "1","name": "coderjia","description": "desc v1","price": 1.0
}

创建产品

更新产品：

POST http://localhost:8080/products
Content-Type: application/json{"id": "1","name": "coderjia","description": "desc v2","price": 2.0
}

更新产品

根据 ID 查询产品：

GET http://localhost:8080/products/1

根据 ID 查询产品

根据名称查询产品：

GET http://localhost:8080/products/search?name=coderjia

根据名称查询产品

获取所有产品（分页）：

GET http://localhost:8080/products?page=0&size=3

分页查询

删除产品：

DELETE http://localhost:8080/products/1

删除产品

4. 总结

通过以上步骤，我们构建了一个完整的 Spring Boot 3 和 Elasticsearch 8.x 的增删改查示例应用。使用 Spring Data Elasticsearch Repository，我们能够快速实现对 Elasticsearch 的基本 CRUD 操作，简化了开发流程。希望这个示例能够帮助你理解如何在项目中有效使用 Elasticsearch！


http://www.ppmy.cn/news/1564647.html

相关文章

python实现批量视频提取音频

python实现批量视频提取音频

1、安装依赖库 首先需要安装依赖库moviepy pip install moviepy 2、找到对应目录 利用listdir列出目标文件夹以下文件&#xff0c;利用os.path.join进行路径拼接&#xff0c;os.path.splitext()[0]扣掉。MP4后缀&#xff0c;加入所需形式&#xff0c;&#xff08;这里用的是…
阅读更多...
浅谈云计算16 | 存储虚拟化技术

浅谈云计算16 | 存储虚拟化技术

存储虚拟化技术 一、块级存储虚拟化基础2.1 LUN 解析2.1.1 LUN 概念阐释2.1.2 LUN 功能特性 2.2 Thick LUN与Thin LUN2.2.1 Thick LUN特性剖析2.2.2 Thin LUN特性剖析 三、块级存储虚拟化技术实现3.1 基于主机的实现方式3.1.1 原理阐述3.1.2 优缺点评估 3.2 基于存储设备的实现…
阅读更多...
使用 Python 开发一个 AI Agent 自媒体助手示例

使用 Python 开发一个 AI Agent 自媒体助手示例

1. 项目背景 随着自媒体行业的快速发展&#xff0c;内容创作者需要处理大量重复性任务&#xff0c;例如撰写文章、生成标题、优化关键词、分析数据等。通过开发一个 AI Agent 自媒体助手&#xff0c;可以帮助创作者高效完成这些任务&#xff0c;节省时间并提升内容质量。 本文…
阅读更多...
使用 ChatGPT 生成和改进你的论文

使用 ChatGPT 生成和改进你的论文

文章目录 零、前言一、操作引导二、 生成段落或文章片段三、重写段落四、扩展内容五、生成大纲内容六、提高清晰度和精准度七、解决特定的写作挑战八、感受 零、前言 我是虚竹哥&#xff0c;目标是带十万人玩转ChatGPT。 ChatGPT 是一个非常有用的工具&#xff0c;可以帮助你…
阅读更多...
【机器学习】机器学习引领数学难题攻克：迈向未知数学领域的新突破

【机器学习】机器学习引领数学难题攻克：迈向未知数学领域的新突破

我的个人主页 我的领域&#xff1a;人工智能篇&#xff0c;希望能帮助到大家&#xff01;&#xff01;&#xff01;&#x1f44d;点赞 收藏❤ 一、引言 在数学的浩瀚领域中&#xff0c;存在着诸多长期未解的难题&#xff0c;这些难题犹如高耸的山峰&#xff0c;吸引着无数数…
阅读更多...
多线程中的上下文切换

多线程中的上下文切换

多线程中的上下文切换 上下文切换是指 CPU 从一个线程转到另一个线程时&#xff0c;需要保存当前线程的上下文状态&#xff0c;恢复另一个线程的上下文状态&#xff0c;以便于下一次恢复执行该线程时能够正确地运行。在多线程中&#xff0c;上下文切换的开销比直接用单线程大&…
阅读更多...
reverse学习总结-查表代换

reverse学习总结-查表代换

一.easygui-查表代换-整体循环位移 是exe文件,先运行一下 猜测是输入flag让后验证的, 查壳是64位的,ida直接打开 int __stdcall WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nShowCmd) {HWND Window; // rbxWNDCLASSW WndClass; // [rsp60…
阅读更多...
13-1类与对象

13-1类与对象

&#xff08;一&#xff09;封装-属性和行为作为 定义语法&#xff1a;class 类名{访问权限:属性/行为}; 类中的属性和行为统称为成员 属性称成员属性、成员变量 行为称为成员函数、成员方法 #include <iostream> using namespace std; const double pai3.14; cl…
阅读更多...
最新文章

Copyright @ 2022~2023