使用SpringBoot集成Elasticsearch实现CRUD功能
创始人
2025-01-10 05:36:00
0

添加Elasticsearch依赖

首先,在pom.xml文件中添加Spring Boot和Elasticsearch的依赖:

      org.springframework.boot     spring-boot-starter-data-elasticsearch         org.elasticsearch.client     elasticsearch-rest-high-level-client     7.16.0   

配置Elasticsearch连接信息

application.propertiesapplication.yml文件中配置Elasticsearch连接信息:

使用application.properties配置:

# Elasticsearch properties spring.elasticsearch.rest.uris=http://localhost:9200

使用application.yml配置:

spring:   elasticsearch:     rest:       uris: http://localhost:9200 

定义实体类

定义一个简单的实体类,作为索引中的文档:

import org.springframework.data.annotation.Id; import org.springframework.data.elasticsearch.annotations.Document;  @Document(indexName = "books", createIndex = true) public class Book {      @Id     private String id;      private String title;      private String author;      // 省略构造函数、getter和setter } 

创建Elasticsearch操作接口

创建一个接口来定义对Elasticsearch的操作:

import org.springframework.data.elasticsearch.annotations.Query; import org.springframework.data.elasticsearch.repository.ElasticsearchRepository; import java.util.List;  public interface BookRepository extends ElasticsearchRepository {      List findByTitle(String title);      @Query("{\"match\": {\"author\": \"?0\"}}")     List findByAuthorQuery(String author); } 

实现CRUD操作

在服务类或控制器中使用BookRepository进行CRUD操作:

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*;  @RestController @RequestMapping("/books") public class BookController {      @Autowired     private BookRepository bookRepository;      @PostMapping     public Book addBook(@RequestBody Book book) {         return bookRepository.save(book);     }      @GetMapping("/{id}")     public Book getBook(@PathVariable String id) {         return bookRepository.findById(id).orElse(null);     }      @PutMapping("/{id}")     public Book updateBook(@PathVariable String id, @RequestBody Book book) {         book.setId(id); // 设置要更新的文档的ID         return bookRepository.save(book);     }      @DeleteMapping("/{id}")     public void deleteBook(@PathVariable String id) {         bookRepository.deleteById(id);     }      @GetMapping("/title/{title}")     public List findByTitle(@PathVariable String title) {         return bookRepository.findByTitle(title);     }      @GetMapping("/author/{author}")     public List findByAuthor(@PathVariable String author) {         return bookRepository.findByAuthorQuery(author);     } } 

示例说明

  • Book:使用@Document注解指定了索引名称和是否自动创建索引。
  • BookRepository接口:继承自ElasticsearchRepository,定义了一些基本的查询方法和自定义的查询方法。
  • BookController:使用BookRepository进行CRUD操作的示例控制器,包括添加、获取、更新和删除文档,以及根据标题和作者进行查询。

注意事项

  • 确保Elasticsearch服务器已经启动,并且配置信息(如端口、主机)正确匹配。
  • 在实际项目中,你可能需要根据具体的业务需求,定义更多的查询方法或者对查询结果进行处理。
  • 需要根据你的Elasticsearch版本来选择合适的elasticsearch-rest-high-level-client版本,并进行相应的依赖管理。

通过这些步骤,你可以在Spring Boot应用程序中轻松地集成Elasticsearch,并实现对其的CRUD操作。

相关内容

热门资讯

一分钟内幕!科乐吉林麻将系统发... 一分钟内幕!科乐吉林麻将系统发牌规律,福建大玩家确实真的是有挂,技巧教程(有挂ai代打);所有人都在...
一分钟揭秘!微扑克辅助软件(透... 一分钟揭秘!微扑克辅助软件(透视辅助)确实是有挂(2024已更新)(哔哩哔哩);1、用户打开应用后不...
五分钟发现!广东雀神麻雀怎么赢... 五分钟发现!广东雀神麻雀怎么赢,朋朋棋牌都是是真的有挂,高科技教程(有挂方法)1、广东雀神麻雀怎么赢...
每日必看!人皇大厅吗(透明挂)... 每日必看!人皇大厅吗(透明挂)好像存在有挂(2026已更新)(哔哩哔哩);人皇大厅吗辅助器中分为三种...
重大科普!新华棋牌有挂吗(透视... 重大科普!新华棋牌有挂吗(透视)一直是有挂(2021已更新)(哔哩哔哩)1、完成新华棋牌有挂吗的残局...
二分钟内幕!微信小程序途游辅助... 二分钟内幕!微信小程序途游辅助器,掌中乐游戏中心其实存在有挂,微扑克教程(有挂规律)二分钟内幕!微信...
科技揭秘!jj斗地主系统控牌吗... 科技揭秘!jj斗地主系统控牌吗(透视)本来真的是有挂(2025已更新)(哔哩哔哩)1、科技揭秘!jj...
1分钟普及!哈灵麻将攻略小,微... 1分钟普及!哈灵麻将攻略小,微信小程序十三张好像存在有挂,规律教程(有挂技巧)哈灵麻将攻略小是一种具...
9分钟教程!科乐麻将有挂吗,传... 9分钟教程!科乐麻将有挂吗,传送屋高防版辅助(总是存在有挂)1、完成传送屋高防版辅助透视辅助安装,帮...
每日必看教程!兴动游戏辅助器下... 每日必看教程!兴动游戏辅助器下载(辅助)真是真的有挂(2025已更新)(哔哩哔哩)1、打开软件启动之...