使用Spring Data R2DBC +Postgres实现增删改查功能

更新时间：2021年03月03日 10:28:08 作者：banq

这篇文章主要介绍了使用Spring Data R2DBC +Postgres实现增删改查功能,本文通过两种方法给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

在本教程中，我想向您展示如何通过带有Spring WebFlux的Spring Data R2DBC 执行各种Postgres CRUD操作。

R2DBC代表反应式关系数据库连接。

像JPA（Java持久性API）一样，R2DBC是关系数据库的反应性驱动程序的规范。由于它是一个单独的规范，因此请勿与JPA / Hibernate功能（如@OneToMany，@ManyToMany 等）比较。

我们将开发一个名为product-service的Spring Boot应用程序，该应用程序负责创建新产品/检索所有产品/删除或更新现有产品以执行R2DBC的各种Postgres CRUD操作。

实体类

@Data
@ToString
<b>public</b> <b>class</b> Product {

 @Id
 <b>private</b> Integer id;
 <b>private</b> String description;
 <b>private</b> Double price;
 
}

我们不能在此处添加@Entity，因为这不是JPA。

Spring Data反应性存储库

Spring Data照常进行所有繁重的工作。我们需要通过扩展ReactiveCrudRepository为我们的实体类创建一个存储库。

<b>import</b> org.springframework.data.repository.reactive.ReactiveCrudRepository;
<b>import</b> org.springframework.stereotype.Repository;

@Repository
<b>public</b> <b>interface</b> ProductRepository <b>extends</b> ReactiveCrudRepository<Product, Integer> {
}

CRUD操作

让我们创建一个服务类，以通过Spring Data Reactive Repository执行Postgres CRUD操作。

@Service
<b>public</b> <b>class</b> ProductService {

 @Autowired
 <b>private</b> ProductRepository repository;

 <b>public</b> Flux<Product> getAllProducts(){
 <b>return</b> <b>this</b>.repository.findAll();
 }

 <b>public</b> Mono<Product> getProductById(<b>int</b> productId){
 <b>return</b> <b>this</b>.repository.findById(productId);
 }

 <b>public</b> Mono<Product> createProduct(<b>final</b> Product product){
 <b>return</b> <b>this</b>.repository.save(product);
 }

 <b>public</b> Mono<Product> updateProduct(<b>int</b> productId, <b>final</b> Mono<Product> productMono){
 <b>return</b> <b>this</b>.repository.findById(productId)
  .flatMap(p -> productMono.map(u -> {
   p.setDescription(u.getDescription());
   p.setPrice(u.getPrice());
   <b>return</b> p;
  }))
  .flatMap(p -> <b>this</b>.repository.save(p));
 }

 <b>public</b> Mono<Void> deleteProduct(<b>final</b> <b>int</b> id){
 <b>return</b> <b>this</b>.repository.deleteById(id);
 }

}

REST API

现在是时候通过REST API公开服务了：

@RestController
@RequestMapping(<font>"product"</font><font>)
<b>public</b> <b>class</b> ProductController {

 @Autowired
 <b>private</b> ProductService productService;

 @GetMapping(</font><font>"all"</font><font>)
 <b>public</b> Flux<Product> getAll(){
 <b>return</b> <b>this</b>.productService.getAllProducts();
 }

 @GetMapping(</font><font>"{productId}"</font><font>)
 <b>public</b> Mono<ResponseEntity<Product>> getProductById(@PathVariable <b>int</b> productId){
 <b>return</b> <b>this</b>.productService.getProductById(productId)
    .map(ResponseEntity::ok)
    .defaultIfEmpty(ResponseEntity.notFound().build());
 }

 @PostMapping
 <b>public</b> Mono<Product> createProduct(@RequestBody Mono<Product> productMono){
 <b>return</b> productMono.flatMap(<b>this</b>.productService::createProduct);
 }

 @PutMapping(</font><font>"{productId}"</font><font>)
 <b>public</b> Mono<Product> updateProduct(@PathVariable <b>int</b> productId,
     @RequestBody Mono<Product> productMono){
 <b>return</b> <b>this</b>.productService.updateProduct(productId, productMono);
 }

 @DeleteMapping(</font><font>"/{id}"</font><font>)
 <b>public</b> Mono<Void> deleteProduct(@PathVariable <b>int</b> id){
 <b>return</b> <b>this</b>.productService.deleteProduct(id);
 }

}
</font>

配置

Spring Data反应驱动程序需要这样的配置才能连接到Postgres DB。

方法1：使用application.properties

spring.r2dbc.url=r2dbc:postgresql:<font><i>//localhost:5432/productdb</i></font><font>
spring.r2dbc.username=vinsguru
spring.r2dbc.password=admin
</font>

方法2：公开连接工厂bean

@Configuration
<b>public</b> <b>class</b> R2DBCConfig {

 @Bean
 <b>public</b> ConnectionFactory connectionFactory() {
 <b>return</b> ConnectionFactories.get(
  ConnectionFactoryOptions.builder()
   .option(DRIVER, <font>"postgresql"</font><font>)
   .option(HOST, </font><font>"localhost"</font><font>)
   .option(PORT, 5432)
   .option(USER, </font><font>"vinsguru"</font><font>)
   .option(PASSWORD, </font><font>"admin"</font><font>)
   .option(DATABASE, </font><font>"productdb"</font><font>)
   .option(MAX_SIZE, 40)
   .build());
 }

}
</font>

完整的源代码在这里。

到此这篇关于使用Spring Data R2DBC +Postgres实现增删改查功能的文章就介绍到这了,更多相关Spring Data R2DBC +Postgres实现增删改查内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

spring boot 使用 @Scheduled 注解和 TaskScheduler 接口实现定时任务
这篇文章主要介绍了spring boot 使用 @Scheduled 注解和 TaskScheduler 接口实现定时任务,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-06-06
Java线程在什么情况下可以终止
Thread线程类自带的stop方法，但是jdk不建议使用，因为stop方法终止线程只是强行终止，内存中部分值可能已发生变化，并未保证数据的一致性，将会导致线程安全问题，那么在什么情况下可以终止线程呢，本篇带你探究一下
2022-04-04
Java if(boolean)和if(boolean=true)区别解析
这篇文章主要介绍了Java if(boolean)和if(boolean=true)区别解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-02-02
java中log使用小结
本文主要介绍了java中log使用小结,一文搞清楚java所有日志框架,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
2023-09-09
Hibernate中实现增删改查的步骤详解
本篇文章主要介绍了Hibernate中实现增删改查的步骤与方法，具有很好的参考价值，下面跟着小编一起来看下吧
2017-02-02
一篇超详细的SpringBoot整合MybatisPlus的文章
这篇文章主要介绍了springboot整合Mybatis-plus的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-07-07
开发工具EesyCode使用方法解析
这篇文章主要介绍了开发工具EesyCode使用方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-04-04
关于在IDEA热部署插件JRebel使用问题详解
这篇文章主要介绍了关于在IDEA热部署插件JRebel使用问题详解,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-12-12
Java Swing实现的定制TextField功能示例
这篇文章主要介绍了Java Swing实现的定制TextField功能,结合实例形式分析了java swing组件TextField相关属性功能与设置操作技巧,需要的朋友可以参考下
2018-01-01
Java设计模式之桥模式（Bridge模式）介绍
这篇文章主要介绍了Java设计模式之桥模式（Bridge模式）介绍,本文讲解了为什么使用桥模式、如何实现桥模式、Bridge模式在EJB中的应用等内容,需要的朋友可以参考下
2015-03-03