com.github.pgasync.impl

Class PgConnectionPool

java.lang.Object

com.github.pgasync.impl.PgConnectionPool

All Implemented Interfaces:

ConnectionPool, Db, QueryExecutor, TransactionExecutor, java.lang.AutoCloseable

Direct Known Subclasses:

NettyPgConnectionPool

public abstract class PgConnectionPool
extends java.lang.Object
implements ConnectionPool

Pool for backend connections. Callbacks are queued and executed when pool has an available connection. TODO: Locking scheme is optimized for small thread pools and doesn't scale all that well for large ones.

Author:

Antti Laisi

Constructor Summary

Constructors

Constructor and Description
PgConnectionPool(ConnectionPoolBuilder.PoolProperties properties)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

PgConnectionPool

public PgConnectionPool(ConnectionPoolBuilder.PoolProperties properties)

Method Detail

query

public void query(java.lang.String sql,
                  java.util.function.Consumer<ResultSet> onResult,
                  java.util.function.Consumer<java.lang.Throwable> onError)

Description copied from interface: QueryExecutor

Executes a simple query.

Specified by:

query in interface QueryExecutor

Parameters:

sql - SQL to execute.

onResult - Called when query is completed

onError - Called on exception thrown

query

public void query(java.lang.String sql,
                  java.util.List params,
                  java.util.function.Consumer<ResultSet> onResult,
                  java.util.function.Consumer<java.lang.Throwable> onError)

Description copied from interface: QueryExecutor

Executes an anonymous prepared statement. Uses native PostgreSQL syntax with $arg instead of ? to mark parameters. Supported parameter types are String, Character, Number, Time, Date, Timestamp and byte[].

Specified by:

query in interface QueryExecutor

Parameters:

sql - SQL to execute

params - List of parameters

onResult - Called when query is completed

onError - Called on exception thrown

begin

public void begin(java.util.function.Consumer<Transaction> onTransaction,
                  java.util.function.Consumer<java.lang.Throwable> onError)

Description copied from interface: TransactionExecutor

Begins a transaction.

Specified by:

begin in interface TransactionExecutor

Parameters:

onTransaction - Called when transaction is successfully started.

onError - Called on exception thrown

close

public void close()

Description copied from interface: ConnectionPool

Closes the pool.

Specified by:

close in interface ConnectionPool

Specified by:

close in interface java.lang.AutoCloseable

getConnection

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

Description copied from interface: ConnectionPool

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

Specified by:

getConnection in interface ConnectionPool

Parameters:

onConnection - Called when a connection is acquired

onError - Called on exception thrown

release

public void release(Connection connection)

Description copied from interface: ConnectionPool

Releases a connection back to the pool.

Specified by:

release in interface ConnectionPool

Parameters:

connection - Connection fetched with getConnection

dataConverter

protected DataConverter dataConverter()

newConnection

protected abstract PgConnection newConnection(java.net.InetSocketAddress address)

Creates a new connection to the backend.

Parameters:

address - Server address

Returns:

Unconnected connection