io.vertx.pgclient.impl

Class PgSocketConnection

java.lang.Object

io.vertx.sqlclient.impl.SocketConnectionBase

io.vertx.pgclient.impl.PgSocketConnection

All Implemented Interfaces:

CommandScheduler, Connection

public class PgSocketConnection
extends SocketConnectionBase

Author:

Julien Viet

Nested Class Summary

Nested classes/interfaces inherited from class io.vertx.sqlclient.impl.SocketConnectionBase

SocketConnectionBase.Status

Nested classes/interfaces inherited from interface io.vertx.sqlclient.impl.Connection

Connection.Holder

Field Summary

Fields

Modifier and Type	Field and Description
PgDatabaseMetadata	dbMetaData
int	processId
int	secretKey

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

logger, psCache, socket, status

Constructor Summary

Constructors

Constructor and Description
PgSocketConnection(NetSocketInternal socket, boolean cachePreparedStatements, int preparedStatementCacheSize, Predicate<String> preparedStatementCacheSqlFilter, int pipeliningLimit, EventLoopContext context)

Method Summary

Modifier and Type	Method and Description
protected <R> void	doSchedule(CommandBase<R> cmd, Handler<AsyncResult<R>> handler)
DatabaseMetadata	getDatabaseMetaData()
int	getProcessId()
int	getSecretKey()
protected void	handleMessage(Object msg)
void	init()
boolean	isIndeterminatePreparedStatementError(Throwable error)

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

close, context, handleClose, handleEvent, init, isSsl, schedule, socket

Methods inherited from class java.lang.Object

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

Field Detail

processId

public int processId

secretKey

public int secretKey

dbMetaData

public PgDatabaseMetadata dbMetaData

Constructor Detail

PgSocketConnection

public PgSocketConnection(NetSocketInternal socket,
                          boolean cachePreparedStatements,
                          int preparedStatementCacheSize,
                          Predicate<String> preparedStatementCacheSqlFilter,
                          int pipeliningLimit,
                          EventLoopContext context)

Method Detail

init

public void init()

Overrides:

init in class SocketConnectionBase

handleMessage

protected void handleMessage(Object msg)

Overrides:

handleMessage in class SocketConnectionBase

getProcessId

public int getProcessId()

Specified by:

getProcessId in interface Connection

Overrides:

getProcessId in class SocketConnectionBase

getSecretKey

public int getSecretKey()

Specified by:

getSecretKey in interface Connection

Overrides:

getSecretKey in class SocketConnectionBase

getDatabaseMetaData

public DatabaseMetadata getDatabaseMetaData()

doSchedule

protected <R> void doSchedule(CommandBase<R> cmd,
                              Handler<AsyncResult<R>> handler)

Overrides:

doSchedule in class SocketConnectionBase

isIndeterminatePreparedStatementError

public boolean isIndeterminatePreparedStatementError(Throwable error)

Returns:

true when error is an indeterminate data type reported when preparing a statement