com.github.pgasync

Interface ConnectionPool

All Superinterfaces:

java.lang.AutoCloseable, Db, QueryExecutor, TransactionExecutor

All Known Implementing Classes:

NettyPgConnectionPool, PgConnectionPool

public interface ConnectionPool
extends Db

Pool of backend Connections. Pools implement Db so queries can be issued directly to the pool if using the same connection is not required.

Author:

Antti Laisi

Method Summary

Modifier and Type	Method and Description
void	close() Closes the pool.
void	getConnection(java.util.function.Consumer<Connection> handler, java.util.function.Consumer<java.lang.Throwable> onError) Executes a Consumer callback when a connection is available.
void	release(Connection connection) Releases a connection back to the pool.

Methods inherited from interface com.github.pgasync.QueryExecutor

query, query

Methods inherited from interface com.github.pgasync.TransactionExecutor

begin

Method Detail

getConnection

void getConnection(java.util.function.Consumer<Connection> handler,
                   java.util.function.Consumer<java.lang.Throwable> onError)

Executes a Consumer callback when a connection is available. Connection passed to callback must be freed with release(Connection)

Parameters:

handler - Called when a connection is acquired

onError - Called on exception thrown

release

void release(Connection connection)

Releases a connection back to the pool.

Parameters:

connection - Connection fetched with getConnection

close

void close()

Closes the pool.

Specified by:

close in interface java.lang.AutoCloseable