org.jooby.rx

Class RxJdbc

java.lang.Object

org.jooby.jdbc.Jdbc

org.jooby.rx.RxJdbc

All Implemented Interfaces:

org.jooby.Jooby.Module

public class RxJdbc
extends Jdbc

rxjdbc

rxjava-jdbc efficient execution, concise code, and functional composition of database calls using JDBC and RxJava Observable.

This module depends on Jdbc module, make sure you read the doc of the Jdbc module.

exports

• A Database object
• A Hikari DataSource object

usage

 import org.jooby.rx.RxJdbc;
 import org.jooby.rx.Rx;

 {
   use(new RxJdbc());

   get("/reactive", req ->
     req.require(Database.class)
       .select("select name from something where id = :id")
       .parameter("id", 1)
       .getAs(String.class)
   ).map(Rx.rx());
 }
 

The Rx.rx() mapper converts rx observables to Deferred instances. More at Rx.

multiple db connections

 import org.jooby.rx.RxJdbc;
 import org.jooby.rx.Rx;

 {
   use(new RxJdbc("db.main"));
   use(new RxJdbc("db.audit"));

   get("/", req ->
     Databse db = req.require("db.main", Database.class);
     Databse audit = req.require("db.audit", Database.class);
     // ...
   ).map(Rx.rx());
 }
 

For more details on how to configure the Hikari datasource, please check the jdbc module

Happy coding!!!

Since:

1.0.0.CR3

Author:

edgar

Field Summary

Fields inherited from class org.jooby.jdbc.Jdbc

dbName, dbtype, DEFAULT_DB

Constructor Summary

Constructors

Constructor and Description
RxJdbc() Creates a new RxJdbc module.
RxJdbc(String name) Creates a new RxJdbc module.

Method Summary

Modifier and Type	Method and Description
void	configure(org.jooby.Env env, com.typesafe.config.Config config, com.google.inject.Binder binder)

Methods inherited from class org.jooby.jdbc.Jdbc

config, dataSource, keys

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxJdbc

public RxJdbc(String name)

Creates a new RxJdbc module.

Parameters:

name - Database name.

RxJdbc

public RxJdbc()

Creates a new RxJdbc module.

Method Detail

configure

public void configure(org.jooby.Env env,
                      com.typesafe.config.Config config,
                      com.google.inject.Binder binder)

Specified by:

configure in interface org.jooby.Jooby.Module

Overrides:

configure in class Jdbc