脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot3整合 Elasticsearch 8.x

SpringBoot3整合 Elasticsearch 8.x 使用Repository构建增删改查示例应用

 更新时间：2024年11月06日 09:54:13   作者：CoderJia  
我们构建了一个完整的 Spring Boot 3 和 Elasticsearch 8.x 的增删改查示例应用,使用 Spring Data Elasticsearch Repository,我们能够快速实现对 Elasticsearch 的基本 CRUD 操作,简化了开发流程,希望这个示例能够帮助你理解如何在项目中有效使用 Elasticsearch！

上一篇文章介绍了 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 {
    @Id
    private 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 主要作用和优点

  • 简化数据操作：提供了基础的 CRUD 方法，如 save()、findById()、findAll() 和 deleteById() 等，方便开发者直接使用。
  • 自定义查询：通过定义接口中的方法（如 findByName(String name)），可以自动生成符合方法命名规范的查询。
  • 分页与排序：内置了分页和排序支持，方法如 findAll(Pageable pageable) 可以直接返回分页数据。
  • 与 Spring 无缝集成：使用 Spring 的依赖注入和配置机制，无需手动创建或管理客户端连接。
  • 减少代码复杂度：自动实现常用的数据库操作，减少重复代码，提高开发效率。

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 {
    @Resource
    private 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 {
    @Resource
    private ProductService productService;
    // 创建或更新产品
    @PostMapping
    public 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);
    }
    // 获取所有产品
    @GetMapping
    public 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

根据名称查询产品：

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！

到此这篇关于SpringBoot3整合 Elasticsearch 8.x 使用Repository构建增删改查示例应用的文章就介绍到这了,更多相关SpringBoot3整合 Elasticsearch 8.x内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Spring Cloud学习教程之Zuul统一异常处理与回退

    Spring Cloud学习教程之Zuul统一异常处理与回退

    Spring Cloud Zuul对异常的处理整体来说还是比较方便的，流程也比较清晰，下面这篇文章主要给大家介绍了关于Spring Cloud学习教程之Zuul统一异常处理与回退的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧。
    2018-04-04
  • 详解springMVC之与json数据交互方法

    详解springMVC之与json数据交互方法

    本篇文章主要介绍了详解springMVC之与json数据交互方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • Spring AOP高级应用与源码剖析

    Spring AOP高级应用与源码剖析

    Spring AOP通过动态代理,在不修改原有业务逻辑的情况下增强横切逻辑,如权限校验、日志记录、事务控制和性能监测,本文介绍Spring AOP高级应用与源码剖析,感兴趣的朋友跟随小编一起看看吧
    2025-12-12
  • SpringBoot项目中遇到的BUG问题及解决方法

    SpringBoot项目中遇到的BUG问题及解决方法

    这篇文章主要介绍了SpringBoot项目中遇到的BUG问题及解决方法,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2020-11-11
  • SpringBoot通过Nginx代理获取真实IP

    SpringBoot通过Nginx代理获取真实IP

    springboot作为后台代码,获取到的登录IP是前台的代理服务器地址,并不是用户的真实IP地址,本文主要介绍了SpringBoot通过Nginx代理获取真实IP,具有一定的参考价值,感兴趣的可以了解一下
    2024-01-01
  • sin(x)如何求解的java代码实现方法

    sin(x)如何求解的java代码实现方法

    这篇文章主要为大家介绍了sin(x)如何求解的java代码实现方法示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-04-04
  • 从零开始Mybatis连接数据库的方法

    从零开始Mybatis连接数据库的方法

    这篇文章主要介绍了Mybatis连接数据库的方法，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-02-02
  • Java Classloader机制用法代码解析

    Java Classloader机制用法代码解析

    这篇文章主要介绍了Java Classloader机制用法代码解析，涉及JDK默认ClassLoader，双亲委托模型，自定义ClassLoader等相关内容，具有一定借鉴价值,需要的朋友可以参考下
    2018-01-01
  • 解决springboot 2.x集成log4j2调试日志无法关闭的问题

    解决springboot 2.x集成log4j2调试日志无法关闭的问题

    这篇文章主要介绍了解决springboot 2.x集成log4j2调试日志无法关闭的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • springboot切面添加日志功能实例详解

    springboot切面添加日志功能实例详解

    在本篇文章里小编给大家整理的是关于springboot 切面添加日志功能的相关知识点内容，有需要的朋友们可以参考下。
    2019-09-09

最新评论