快捷導(dǎo)航

使用Spring Data R2DBC +Postgres實(shí)現(xiàn)增刪改查功能

更新時(shí)間：2021年03月03日 10:28:08 作者：banq

這篇文章主要介紹了使用Spring Data R2DBC +Postgres實(shí)現(xiàn)增刪改查功能,本文通過(guò)兩種方法給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

在本教程中，我想向您展示如何通過(guò)帶有Spring WebFlux的Spring Data R2DBC 執(zhí)行各種Postgres CRUD操作。

R2DBC代表反應(yīng)式關(guān)系數(shù)據(jù)庫(kù)連接。

像JPA（Java持久性API）一樣，R2DBC是關(guān)系數(shù)據(jù)庫(kù)的反應(yīng)性驅(qū)動(dòng)程序的規(guī)范。由于它是一個(gè)單獨(dú)的規(guī)范，因此請(qǐng)勿與JPA / Hibernate功能（如@OneToMany，@ManyToMany 等）比較。

我們將開(kāi)發(fā)一個(gè)名為product-service的Spring Boot應(yīng)用程序，該應(yīng)用程序負(fù)責(zé)創(chuàng)建新產(chǎn)品/檢索所有產(chǎn)品/刪除或更新現(xiàn)有產(chǎn)品以執(zhí)行R2DBC的各種Postgres CRUD操作。

實(shí)體類(lèi)

@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，因?yàn)檫@不是JPA。

Spring Data反應(yīng)性存儲(chǔ)庫(kù)

Spring Data照常進(jìn)行所有繁重的工作。我們需要通過(guò)擴(kuò)展ReactiveCrudRepository為我們的實(shí)體類(lèi)創(chuàng)建一個(gè)存儲(chǔ)庫(kù)。

<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操作

讓我們創(chuàng)建一個(gè)服務(wù)類(lèi)，以通過(guò)Spring Data Reactive Repository執(zhí)行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

現(xiàn)在是時(shí)候通過(guò)REST API公開(kāi)服務(wù)了：

@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反應(yīng)驅(qū)動(dòng)程序需要這樣的配置才能連接到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：公開(kāi)連接工廠(chǎng)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>

完整的源代碼在這里。

到此這篇關(guān)于使用Spring Data R2DBC +Postgres實(shí)現(xiàn)增刪改查功能的文章就介紹到這了,更多相關(guān)Spring Data R2DBC +Postgres實(shí)現(xiàn)增刪改查內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: