io.vertx.pgclient.impl

Class PgPoolImpl

java.lang.Object

io.vertx.sqlclient.impl.SqlClientBase<P>

io.vertx.sqlclient.impl.PoolBase<PgPoolImpl>

io.vertx.pgclient.impl.PgPoolImpl

All Implemented Interfaces:

PgPool, CommandScheduler, Pool, SqlClient

public class PgPoolImpl
extends PoolBase<PgPoolImpl>
implements PgPool

Todo : - handle timeout when acquiring a connection - for per statement pooling, have several physical connection and use the less busy one to avoid head of line blocking effect

Author:

Julien Viet, Emad Alblueshi

Constructor Summary

Constructors

Constructor and Description
PgPoolImpl(Context context, boolean closeVertx, PgConnectOptions connectOptions, PoolOptions poolOptions)

Method Summary

Modifier and Type	Method and Description
void	connect(Handler<AsyncResult<Connection>> completionHandler)
protected void	doClose()
protected SqlConnectionImpl	wrap(Context context, Connection conn)

Methods inherited from class io.vertx.sqlclient.impl.PoolBase

begin, close, getConnection, schedule

Methods inherited from class io.vertx.sqlclient.impl.SqlClientBase

preparedQuery, query

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.pgclient.PgPool

pool, pool, pool, pool, pool, pool, pool, pool, pool

Methods inherited from interface io.vertx.sqlclient.Pool

begin, close, getConnection, pool, pool, pool, preparedQuery, query

Constructor Detail

PgPoolImpl

public PgPoolImpl(Context context,
                  boolean closeVertx,
                  PgConnectOptions connectOptions,
                  PoolOptions poolOptions)

Method Detail

connect

public void connect(Handler<AsyncResult<Connection>> completionHandler)

Specified by:

connect in class PoolBase<PgPoolImpl>

wrap

protected SqlConnectionImpl wrap(Context context,
                                 Connection conn)

Specified by:

wrap in class PoolBase<PgPoolImpl>

doClose

protected void doClose()

Overrides:

doClose in class PoolBase<PgPoolImpl>