Package | Description |
---|---|
org.davidmoten.rx.jdbc |
Modifier and Type | Method and Description |
---|---|
static Database |
Database.from(org.davidmoten.rx.pool.Pool<java.sql.Connection> pool) |
static Database |
Database.from(org.davidmoten.rx.pool.Pool<java.sql.Connection> pool,
io.reactivex.functions.Action closeAction) |
static Database |
Database.from(java.lang.String url,
int maxPoolSize) |
static Database |
Database.fromBlocking(ConnectionProvider cp) |
static Database |
Database.fromBlocking(javax.sql.DataSource dataSource) |
static Database |
Database.test()
Returns a new testing Apache Derby in-memory database with a connection pool
of size 3.
|
static Database |
Database.test(int maxPoolSize) |
Modifier and Type | Method and Description |
---|---|
static NonBlockingConnectionPool.Builder<Database> |
Database.nonBlocking() |
Modifier and Type | Method and Description |
---|---|
static <T> io.reactivex.Flowable<Tx<T>> |
Tx.toTx(io.reactivex.Notification<T> n,
java.sql.Connection con,
Database db) |
Constructor and Description |
---|
CallableBuilder(java.lang.String sql,
io.reactivex.Single<java.sql.Connection> connection,
Database db) |
Copyright © 2016–2020. All rights reserved.