Otra cosa, se que existe RDBC que básicamente ofrece un conjunto de funcionalidades reactivas para utilizar base de datos relacionales y esta bien, pero pero tiene sabor a poco. Dado que este conector tiene como objetivo simular un origen de datos reactivo que en realidad no es tan así …
En fin, una base de datos reactiva debería cumplir el manifiesto reactivo :
- Responsivos
- Resilientes
- Elásticos
- Orientados a Mensajes
No quiero detallar como implementar estos puntos, existen muchas bases de datos nosql que intentan implementarlo y a su modo lo hacen muy bien.
Dado los siguientes puntos y supongamos que los cumpla. Una base reactiva debería retornar siempre un Observer (si utilizamos RxJava, o puede ser un Flux o Mono si utilizamos spring) , por ahora no estoy agregando nada de conocimento esto es igual que R2DBC, vamos a soñar …
Lo que podríamos hacer es trasmitir datos por ejemplo :
Preparestatement ps = con.createPreparestatement(“select * from Persona”);
ps.subscribe( rs => System.out.println(rs.getString(“name”); );
Cada vez que se inserte un registro nuevo se imprimirá el nombre.
Le podríamos poner un delay, por ejemplo :
Preparestatement ps = con.createPreparestatement(“select * from Persona”);
ps.delay(100);
ps.subscribe( rs => System.out.println(rs.getString(“name”); );
Si tuviéramos que hacer esto, de forma tradicional, deberíamos, revisar la base de datos cada tanto tiempo para ver si insertaron un dato nuevo. En cambio, si hubiera una base reactiva, la base nos retornará cada 100 nanosegundos el nombre de una persona y esto no debería ser bloqueante, es decir si mientras imprimimos alguien cambia algo, no debería influir en nuestro proceso. Y si llega al final, cada vez que se inserte debería notificarnos.
Otra cosa muy buena, sería poder suscribir a un cambio (esto desplazaría a los triggers). Deberíamos poder suscribir al cambio de un registro o de todos los registros de una tabla o la estructura de una tabla o etc. Por ejemplo vamos a suscribir un proceso que se llame cuanto eliminen un registro :
Preparestatement ps = con.createPreparestatement(“select * from Persona p where p.id = 33”);
ps.subscribe(“delete”, rs => System.out.println(rs.getString(“name”); );
ponele, me estoy suscribiendo y cuando se borre esta fila, la base de datos debería, notificarnos.
Como se deben haber dado cuenta una base de datos reactiva no solo es un repositorio donde consulto datos, sino que es un sistema el cual conversa con nuestra aplicación y nos notifica de los cambios. Esto favorecería increíblemente las comunicaciones, supongamos que tenemos 2 sistemas que escriben en una base de datos, según lo que venimos razonando podríamos suscribirnos a la inserción de nuevos datos. Ect...
En fin, no conozco nada parecido, alguien conoce algo similar??
Dejo link:
