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:

Closeable, PgPool, CommandScheduler, SqlClientInternal, 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

Field Summary

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

metrics, tracer

Method Summary

Modifier and Type	Method and Description
int	appendQueryPlaceholder(StringBuilder queryBuilder, int index, int current) Append a parameter placeholder in the query.
static PgPoolImpl	create(ContextInternal context, boolean closeVertx, PgConnectOptions connectOptions, PoolOptions poolOptions)
protected SqlConnectionImpl	wrap(ContextInternal context, Connection conn)

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

close, close, close, closeFuture, getConnection, getConnection, promise, promise, 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

close, getConnection, getConnection, pool, pool, pool, preparedQuery, query, withConnection, withConnection, withTransaction, withTransaction

Methods inherited from interface io.vertx.sqlclient.SqlClient

close

Method Detail

create

public static PgPoolImpl create(ContextInternal context,
                                boolean closeVertx,
                                PgConnectOptions connectOptions,
                                PoolOptions poolOptions)

appendQueryPlaceholder

public int appendQueryPlaceholder(StringBuilder queryBuilder,
                                  int index,
                                  int current)

Description copied from interface: SqlClientInternal

Append a parameter placeholder in the query.

The index starts at 0.

• When index == current indicates it is a new parameter and therefore the same * value should be returned.
• When index < current indicates the builder wants to reuse a parameter. The implementation can either return the same value to indicate the parameter can be reused or return the next index to use (which is shall be the current value

Specified by:

appendQueryPlaceholder in interface SqlClientInternal

Overrides:

appendQueryPlaceholder in class SqlClientBase<PgPoolImpl>

Parameters:

queryBuilder - the builder to append to

index - the parameter placeholder index

Returns:

the index at which the parameter placeholder could be added

wrap

protected SqlConnectionImpl wrap(ContextInternal context,
                                 Connection conn)

Specified by:

wrap in class PoolBase<PgPoolImpl>