io.vertx.sqlclient.impl

Class SocketConnectionBase

java.lang.Object

io.vertx.sqlclient.impl.SocketConnectionBase

All Implemented Interfaces:

CommandScheduler, Connection

Direct Known Subclasses:

DB2SocketConnection, MySQLSocketConnection, PgSocketConnection

public abstract class SocketConnectionBase
extends Object
implements Connection

Author:

Julien Viet

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SocketConnectionBase.Status

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

Connection.Holder

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	logger
protected PreparedStatementCache	psCache
protected NetSocketInternal	socket
protected SocketConnectionBase.Status	status

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close(Connection.Holder holder, Promise<Void> promise)
Context	context()
protected <R> void	doSchedule(CommandBase<R> cmd, Handler<AsyncResult<R>> handler)
int	getProcessId()
int	getSecretKey()
protected void	handleClose(Throwable t)
protected void	handleEvent(Object event)
protected void	handleMessage(Object msg)
void	init()
void	init(Connection.Holder holder)
boolean	isSsl()
<R> void	schedule(CommandBase<R> cmd, Promise<R> promise)
NetSocketInternal	socket()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.sqlclient.impl.Connection

getDatabaseMetaData, isIndeterminatePreparedStatementError

Field Detail

logger

protected static final Logger logger

psCache

protected final PreparedStatementCache psCache

socket

protected final NetSocketInternal socket

status

protected SocketConnectionBase.Status status

Constructor Detail

SocketConnectionBase

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

Method Detail

context

public Context context()

init

public void init()

socket

public NetSocketInternal socket()

isSsl

public boolean isSsl()

Specified by:

isSsl in interface Connection

init

public void init(Connection.Holder holder)

Specified by:

init in interface Connection

getProcessId

public int getProcessId()

Specified by:

getProcessId in interface Connection

getSecretKey

public int getSecretKey()

Specified by:

getSecretKey in interface Connection

close

public void close(Connection.Holder holder,
                  Promise<Void> promise)

Specified by:

close in interface Connection

schedule

public <R> void schedule(CommandBase<R> cmd,
                         Promise<R> promise)

Specified by:

schedule in interface CommandScheduler

doSchedule

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

handleMessage

protected void handleMessage(Object msg)

handleEvent

protected void handleEvent(Object event)

handleClose

protected void handleClose(Throwable t)