Adapter un pilote JDBC réactif à Reactor JDBC:réactif

Dans cette section, nous montrons à titre expérimental l’utilisation d’une solution RxJava ou RxJava 2 avec un adaptateur vers Reactor. Ces exemples ont vocation à montrer le système d’adaptation vers Reactor. RxJava RxJava 2 Reactor

Pour utiliser la conversion Reactor avec RxJava, nous pouvons utiliser la librairie reactor-adapter. La documentation est sommaire et disponible sur GitHub (https://github.com/reactor/reactor-addons).

Pour en disposer dans notre projet, nous devons ajouter la dépendance Maven :

<dependency> 
 <groupId>io.projectreactor.addons</groupId> 
 <artifactId>reactor-adapter</artifactId> 
 <version>3.1.0.RC1</version> 
</dependency> 

Le projet reactor-adapter nous apporte un pont entre RxJava 1 ou 2 Observable, Completable, Flowable, Single, Maybe, Scheduler, ainsi que SWT Scheduler et Akka Scheduler.

Nous utilisons le pont RxJava 2 vers les types Flux avec la méthode flowableToFlux de la classe RxJava2Adapter pour convertir un Flowable en Flux. flowableToFlux RxJava2Adapter

Flux<Integer> titi = toto.to(RxJava2Adapter::flowableToFlux); 

Il existe des méthodes pour faire toutes les conversions.

1. Solution avec rxjava2-jdbc rxjava2-jdbc

Cet exemple est expérimental et n’a pas été testé en production. Il vise à montrer une adaptation.

Pour utiliser cette librairie, nous devons...

Pour consulter la suite, découvrez le livre suivant :
couv_EPREAJASP.png
60-signet.svg
En version papier
20-ecran_lettre.svg
En version numérique
41-logo_abonnement.svg
En illimité avec l'abonnement ENI
130-boutique.svg
Sur la boutique officielle ENI
Précédent
Isoler la partie JDBC
Suivant
Conclusion sur les pilotes JDBC asynchrones