org.davidmoten.rx.jdbc

Class Database

java.lang.Object

org.davidmoten.rx.jdbc.Database

All Implemented Interfaces:

AutoCloseable

public final class Database
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
static Object	NULL_BLOB Sentinel object used to indicate in parameters of a query that rather than calling PreparedStatement.setObject(int, Object) with a null we call PreparedStatement.setNull(int, int) with Types.CLOB.
static Object	NULL_CLOB
static Object	NULL_NUMBER

Method Summary

Modifier and Type	Method and Description
static Object	blob(byte[] bytes)
static Object	clob(String s)
void	close()
io.reactivex.Single<Connection>	connections()
static Database	from(Pool<Connection> pool)
static Database	from(io.reactivex.Single<Connection> connections, io.reactivex.functions.Action onClose)
static Database	from(String url, int maxPoolSize)
<T> SelectAutomappedBuilder<T>	select(Class<T> cls)
SelectBuilder	select(String sql)
static Database	test() Returns a new testing apache derby in-memory database with a connection pool of size 3.
static Database	test(int maxPoolSize)
static Object	toSentinelIfNull(byte[] bytes)
static Object	toSentinelIfNull(String s)
TransactedBuilder	tx(Tx<?> tx)
UpdateBuilder	update(String sql)

Methods inherited from class java.lang.Object

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

Field Detail

NULL_CLOB

public static final Object NULL_CLOB

NULL_NUMBER

public static final Object NULL_NUMBER

NULL_BLOB

public static final Object NULL_BLOB

Sentinel object used to indicate in parameters of a query that rather than calling PreparedStatement.setObject(int, Object) with a null we call PreparedStatement.setNull(int, int) with Types.CLOB. This is required by many databases for setting CLOB and BLOB fields to null.

Method Detail

from

public static Database from(@Nonnull
                            io.reactivex.Single<Connection> connections,
                            @Nonnull
                            io.reactivex.functions.Action onClose)

from

public static Database from(@Nonnull
                            String url,
                            int maxPoolSize)

from

public static Database from(@Nonnull
                            Pool<Connection> pool)

test

public static Database test(int maxPoolSize)

test

public static Database test()

Returns a new testing apache derby in-memory database with a connection pool of size 3.

Returns:

new testing Database instance

connections

public io.reactivex.Single<Connection> connections()

close

public void close()

Specified by:

close in interface AutoCloseable

select

public <T> SelectAutomappedBuilder<T> select(@Nonnull
                                             Class<T> cls)

select

public SelectBuilder select(@Nonnull
                            String sql)

update

public UpdateBuilder update(@Nonnull
                            String sql)

tx

public TransactedBuilder tx(@Nonnull
                            Tx<?> tx)

toSentinelIfNull

public static Object toSentinelIfNull(@Nullable
                                      String s)

toSentinelIfNull

public static Object toSentinelIfNull(@Nullable
                                      byte[] bytes)

clob

public static Object clob(@Nullable
                          String s)

blob

public static Object blob(@Nullable
                          byte[] bytes)