public abstract class PgConnectionPool extends java.lang.Object implements ConnectionPool
| Constructor and Description |
|---|
PgConnectionPool(ConnectionPoolBuilder.PoolProperties properties) |
| Modifier and Type | Method and Description |
|---|---|
void |
begin(java.util.function.Consumer<Transaction> onTransaction,
java.util.function.Consumer<java.lang.Throwable> onError)
Begins a transaction.
|
void |
close()
Closes the pool.
|
protected DataConverter |
dataConverter() |
void |
getConnection(java.util.function.Consumer<Connection> onConnection,
java.util.function.Consumer<java.lang.Throwable> onError)
Executes a
Consumer callback when a connection is
available. |
protected abstract PgConnection |
newConnection(java.net.InetSocketAddress address)
Creates a new connection to the backend.
|
void |
query(java.lang.String sql,
java.util.function.Consumer<ResultSet> onResult,
java.util.function.Consumer<java.lang.Throwable> onError)
Executes a simple query.
|
void |
query(java.lang.String sql,
java.util.List params,
java.util.function.Consumer<ResultSet> onResult,
java.util.function.Consumer<java.lang.Throwable> onError)
Executes an anonymous prepared statement.
|
void |
release(Connection connection)
Releases a connection back to the pool.
|
public PgConnectionPool(ConnectionPoolBuilder.PoolProperties properties)
public void query(java.lang.String sql,
java.util.function.Consumer<ResultSet> onResult,
java.util.function.Consumer<java.lang.Throwable> onError)
QueryExecutorquery in interface QueryExecutorsql - SQL to execute.onResult - Called when query is completedonError - Called on exception thrownpublic void query(java.lang.String sql,
java.util.List params,
java.util.function.Consumer<ResultSet> onResult,
java.util.function.Consumer<java.lang.Throwable> onError)
QueryExecutorquery in interface QueryExecutorsql - SQL to executeparams - List of parametersonResult - Called when query is completedonError - Called on exception thrownpublic void begin(java.util.function.Consumer<Transaction> onTransaction, java.util.function.Consumer<java.lang.Throwable> onError)
TransactionExecutorbegin in interface TransactionExecutoronTransaction - Called when transaction is successfully started.onError - Called on exception thrownpublic void close()
ConnectionPoolclose in interface ConnectionPoolclose in interface java.lang.AutoCloseablepublic void getConnection(java.util.function.Consumer<Connection> onConnection, java.util.function.Consumer<java.lang.Throwable> onError)
ConnectionPoolConsumer callback when a connection is
available. Connection passed to callback must be freed with
ConnectionPool.release(Connection)getConnection in interface ConnectionPoolonConnection - Called when a connection is acquiredonError - Called on exception thrownpublic void release(Connection connection)
ConnectionPoolrelease in interface ConnectionPoolconnection - Connection fetched with getConnectionprotected DataConverter dataConverter()
protected abstract PgConnection newConnection(java.net.InetSocketAddress address)
address - Server addressCopyright © 2014. All Rights Reserved.