com.github.davidmoten.rx.jdbc

Class Database.Builder

java.lang.Object

com.github.davidmoten.rx.jdbc.Database.Builder

Enclosing class:

Database

public static final class Database.Builder
extends Object

Builds a Database.

Method Summary

Modifier and Type	Method and Description
Database	build() Returns a Database.
Database.Builder	configure(rx.functions.Action1<com.zaxxer.hikari.HikariDataSource> configureDataSource)
Database.Builder	connectionProvider(ConnectionProvider cp) Sets the connection provider.
Database.Builder	nonTransactionalScheduler(rx.functions.Func0<rx.Scheduler> factory) Sets the non transactional scheduler.
Database.Builder	nonTransactionalSchedulerOnCurrentThread() Requests that the non transactional queries are run using Schedulers.trampoline().
Database.Builder	password(String password)
Database.Builder	pool(int minPoolSize, int maxPoolSize) Sets the ConnectionProvider to use a connection pool with the given jdbc url and pool size.
Database.Builder	pool(int minPoolSize, int maxPoolSize, long connectionTimeoutMs) Sets the ConnectionProvider to use a connection pool with the given jdbc url and pool size.
Database.Builder	pool(String url) Sets the ConnectionProvider to use a connection pool with the given jdbc url and min pool size of 0, max pool size of 10.
Database.Builder	resultSetTransform(rx.functions.Func1<ResultSet,? extends ResultSet> transform) When a ResultSet is obtained by Database.select() Observable then before being used it is transformed by the transform function.
Database.Builder	url(String url) Sets the jdbc url.
Database.Builder	username(String username)

Methods inherited from class java.lang.Object

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

Method Detail

connectionProvider

public Database.Builder connectionProvider(ConnectionProvider cp)

Sets the connection provider.

Parameters:

cp -

Returns:

url

public Database.Builder url(String url)

Sets the jdbc url.

Parameters:

url -

Returns:

username

public Database.Builder username(String username)

password

public Database.Builder password(String password)

pool

public Database.Builder pool(int minPoolSize,
                             int maxPoolSize)

Sets the ConnectionProvider to use a connection pool with the given jdbc url and pool size.

Parameters:

url -

minPoolSize -

maxPoolSize -

Returns:

pool

public Database.Builder pool(int minPoolSize,
                             int maxPoolSize,
                             long connectionTimeoutMs)

Sets the ConnectionProvider to use a connection pool with the given jdbc url and pool size.

Parameters:

url -

minPoolSize -

maxPoolSize -

Returns:

configure

public Database.Builder configure(rx.functions.Action1<com.zaxxer.hikari.HikariDataSource> configureDataSource)

pool

public Database.Builder pool(String url)

Sets the ConnectionProvider to use a connection pool with the given jdbc url and min pool size of 0, max pool size of 10.

Parameters:

url -

Returns:

nonTransactionalScheduler

public Database.Builder nonTransactionalScheduler(rx.functions.Func0<rx.Scheduler> factory)

Sets the non transactional scheduler.

Parameters:

factory -

Returns:

nonTransactionalSchedulerOnCurrentThread

public Database.Builder nonTransactionalSchedulerOnCurrentThread()

Requests that the non transactional queries are run using Schedulers.trampoline().

Returns:

this

resultSetTransform

public Database.Builder resultSetTransform(rx.functions.Func1<ResultSet,? extends ResultSet> transform)

When a ResultSet is obtained by Database.select() Observable then before being used it is transformed by the transform function.

Parameters:

transform - function that transforms the ResultSet into another ResultSet

Returns:

this

build

public Database build()

Returns a Database.

Returns:

the constructed Database