com.mysql.cj

Class NativeSession

java.lang.Object

com.mysql.cj.CoreSession

com.mysql.cj.NativeSession

All Implemented Interfaces:

Session, java.io.Serializable

public class NativeSession
extends CoreSession
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.mysql.cj.Session

Session.SessionEventListener

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Timer	cancelTimer
private NativeMessageBuilder	commandBuilder
private java.lang.Throwable	forceClosedReason Why was this session implicitly closed, if known? (for diagnostics)
private boolean	isClosed Has this session been closed?
private long	lastQueryFinishedTime When did the last query finish?
private java.util.concurrent.CopyOnWriteArrayList<java.lang.ref.WeakReference<Session.SessionEventListener>>	listeners
private boolean	needsPing Does this connection need to be tested?
private static long	serialVersionUID
private static java.lang.String	SERVER_VERSION_STRING_VAR_NAME
private CacheAdapter<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	serverConfigCache

Fields inherited from class com.mysql.cj.CoreSession

autoReconnect, autoReconnectForPools, cacheServerConfiguration, characterEncoding, connectionCreationTimeMillis, disconnectOnExpiredPasswords, exceptionInterceptor, gatherPerfMetrics, hostInfo, log, maintainTimeStats, messageBuilder, NULL_LOGGER, propertySet, protocol, sessionMaxRows

Constructor Summary

Constructors

Constructor and Description
NativeSession(HostInfo hostInfo, PropertySet propSet)

Method Summary

Modifier and Type	Method and Description
void	addListener(Session.SessionEventListener l) Add listener for this session status changes.
void	checkClosed()
void	clearInputStream()
void	connect(HostInfo hi, java.lang.String user, java.lang.String password, java.lang.String database, int loginTimeout, TransactionEventHandler transactionManager)
private void	createConfigCacheIfNeeded(java.lang.Object syncMutex)
void	disableMultiQueries()
void	dumpPacketRingBuffer()
void	enableMultiQueries()
<T extends Resultset> T	execSQL(Query callingQuery, java.lang.String query, int maxRows, NativePacketPayload packet, boolean streamResults, ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory, ColumnDefinition cachedMetadata, boolean isBatch) Send a query to the server.
private java.lang.String	findProcessHost(long threadId)
void	forceClose() Clobbers the physical network connection and marks this session as closed.
java.util.Timer	getCancelTimer()
int	getCommandCount()
long	getConnectionCreationTimeMillis()
long	getCurrentTimeNanosOrMillis()
java.lang.Throwable	getForceClosedReason()
java.lang.String	getIdentifierQuoteString()
long	getIdleFor()
java.io.InputStream	getLocalInfileInputStream()
NetworkResources	getNetworkResources()
java.lang.String	getProcessHost()
NativeProtocol	getProtocol()
java.net.SocketAddress	getRemoteSocketAddress()
int	getSessionMaxRows()
NativePacketPayload	getSharedSendPacket() Returns the packet used for sending data (used by PreparedStatement) with position set to 0.
long	getSlowQueryThreshold()
int	getSocketTimeout()
boolean	hadWarnings()
void	invokeCleanupListeners(java.lang.Throwable whyCleanedUp)
protected void	invokeNormalCloseListeners()
<T extends Resultset> T	invokeQueryInterceptorsPost(java.util.function.Supplier<java.lang.String> sql, Query interceptedQuery, T originalResultSet, boolean forceExecute)
<T extends Resultset> T	invokeQueryInterceptorsPre(java.util.function.Supplier<java.lang.String> sql, Query interceptedQuery, boolean forceExecute)
protected void	invokeReconnectListeners()
boolean	isClosed()
boolean	isNeedsPing()
boolean	isServerLocal(Session sess)
boolean	isSetNeededForAutoCommitMode(boolean autoCommitFlag)
boolean	isSSLEstablished()
void	loadServerVariables(java.lang.Object syncMutex, java.lang.String version) Loads the result of 'SHOW VARIABLES' into the serverVariables field so that the driver can configure itself.
void	ping(boolean checkForClosedConnection, int timeoutMillis)
java.lang.String	queryServerVariable(java.lang.String varName) Get the variable value from server.
void	quit() Log-off of the MySQL server and close the socket.
void	removeListener(Session.SessionEventListener listener) Remove session listener.
void	setConnectionCreationTimeMillis(long connectionCreationTimeMillis)
void	setForceClosedReason(java.lang.Throwable forceClosedReason)
void	setLocalInfileInputStream(java.io.InputStream stream)
void	setNeedsPing(boolean needsPing)
void	setQueryInterceptors(java.util.List<QueryInterceptor> queryInterceptors)
void	setSessionMaxRows(int sessionMaxRows)
void	setSessionVariables()
void	setSocketTimeout(int milliseconds)
boolean	shouldIntercept()
void	shutdownServer() Used by MiniAdmin to shutdown a MySQL server

Methods inherited from class com.mysql.cj.CoreSession

changeUser, getDataStoreMetadata, getExceptionInterceptor, getHostInfo, getLog, getMessageBuilder, getProfilerEventHandler, getPropertySet, getQueryTimingUnits, getServerSession, getThreadId, setExceptionInterceptor, versionMeetsMinimum

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mysql.cj.Session

query, query, queryAsync

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

serverConfigCache

private CacheAdapter<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> serverConfigCache

lastQueryFinishedTime

private long lastQueryFinishedTime

When did the last query finish?

needsPing

private boolean needsPing

Does this connection need to be tested?

commandBuilder

private NativeMessageBuilder commandBuilder

isClosed

private boolean isClosed

Has this session been closed?

forceClosedReason

private java.lang.Throwable forceClosedReason

Why was this session implicitly closed, if known? (for diagnostics)

listeners

private java.util.concurrent.CopyOnWriteArrayList<java.lang.ref.WeakReference<Session.SessionEventListener>> listeners

cancelTimer

private transient java.util.Timer cancelTimer

SERVER_VERSION_STRING_VAR_NAME

private static final java.lang.String SERVER_VERSION_STRING_VAR_NAME

See Also:

Constant Field Values

Constructor Detail

NativeSession

public NativeSession(HostInfo hostInfo,
                     PropertySet propSet)

Method Detail

connect

public void connect(HostInfo hi,
                    java.lang.String user,
                    java.lang.String password,
                    java.lang.String database,
                    int loginTimeout,
                    TransactionEventHandler transactionManager)
             throws java.io.IOException

Throws:

java.io.IOException

getProtocol

public NativeProtocol getProtocol()

quit

public void quit()

Description copied from interface: Session

Log-off of the MySQL server and close the socket.

Specified by:

quit in interface Session

Overrides:

quit in class CoreSession

forceClose

public void forceClose()

Description copied from interface: Session

Clobbers the physical network connection and marks this session as closed.

Specified by:

forceClose in interface Session

Overrides:

forceClose in class CoreSession

enableMultiQueries

public void enableMultiQueries()

disableMultiQueries

public void disableMultiQueries()

isSetNeededForAutoCommitMode

public boolean isSetNeededForAutoCommitMode(boolean autoCommitFlag)

Specified by:

isSetNeededForAutoCommitMode in interface Session

Overrides:

isSetNeededForAutoCommitMode in class CoreSession

getSessionMaxRows

public int getSessionMaxRows()

setSessionMaxRows

public void setSessionMaxRows(int sessionMaxRows)

setQueryInterceptors

public void setQueryInterceptors(java.util.List<QueryInterceptor> queryInterceptors)

isServerLocal

public boolean isServerLocal(Session sess)

shutdownServer

public void shutdownServer()

Used by MiniAdmin to shutdown a MySQL server

setSocketTimeout

public void setSocketTimeout(int milliseconds)

getSocketTimeout

public int getSocketTimeout()

getSharedSendPacket

public NativePacketPayload getSharedSendPacket()

Returns the packet used for sending data (used by PreparedStatement) with position set to 0. Guarded by external synchronization on a mutex.

Returns:

A packet to send data with

dumpPacketRingBuffer

public void dumpPacketRingBuffer()

invokeQueryInterceptorsPre

public <T extends Resultset> T invokeQueryInterceptorsPre(java.util.function.Supplier<java.lang.String> sql,
                                                          Query interceptedQuery,
                                                          boolean forceExecute)

invokeQueryInterceptorsPost

public <T extends Resultset> T invokeQueryInterceptorsPost(java.util.function.Supplier<java.lang.String> sql,
                                                           Query interceptedQuery,
                                                           T originalResultSet,
                                                           boolean forceExecute)

shouldIntercept

public boolean shouldIntercept()

getCurrentTimeNanosOrMillis

public long getCurrentTimeNanosOrMillis()

getSlowQueryThreshold

public long getSlowQueryThreshold()

hadWarnings

public boolean hadWarnings()

clearInputStream

public void clearInputStream()

getNetworkResources

public NetworkResources getNetworkResources()

isSSLEstablished

public boolean isSSLEstablished()

Specified by:

isSSLEstablished in interface Session

Overrides:

isSSLEstablished in class CoreSession

getCommandCount

public int getCommandCount()

getRemoteSocketAddress

public java.net.SocketAddress getRemoteSocketAddress()

Specified by:

getRemoteSocketAddress in interface Session

Overrides:

getRemoteSocketAddress in class CoreSession

getLocalInfileInputStream

public java.io.InputStream getLocalInfileInputStream()

setLocalInfileInputStream

public void setLocalInfileInputStream(java.io.InputStream stream)

createConfigCacheIfNeeded

private void createConfigCacheIfNeeded(java.lang.Object syncMutex)

loadServerVariables

public void loadServerVariables(java.lang.Object syncMutex,
                                java.lang.String version)

Loads the result of 'SHOW VARIABLES' into the serverVariables field so that the driver can configure itself.

Parameters:

syncMutex - synchronization mutex

version - driver version string

setSessionVariables

public void setSessionVariables()

getProcessHost

public java.lang.String getProcessHost()

Specified by:

getProcessHost in interface Session

findProcessHost

private java.lang.String findProcessHost(long threadId)

queryServerVariable

public java.lang.String queryServerVariable(java.lang.String varName)

Get the variable value from server.

Parameters:

varName - server variable name

Returns:

server variable value

execSQL

public <T extends Resultset> T execSQL(Query callingQuery,
                                       java.lang.String query,
                                       int maxRows,
                                       NativePacketPayload packet,
                                       boolean streamResults,
                                       ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
                                       ColumnDefinition cachedMetadata,
                                       boolean isBatch)

Send a query to the server. Returns one of the ResultSet objects. To ensure that Statement's queries are serialized, calls to this method should be enclosed in a connection mutex synchronized block.

Type Parameters:

T - extends Resultset

Parameters:

callingQuery - Query object

query - the SQL statement to be executed

maxRows - rows limit

packet - NativePacketPayload

streamResults - whether a stream result should be created

resultSetFactory - ProtocolEntityFactory

cachedMetadata - use this metadata instead of the one provided on wire

isBatch - is it a batch query

Returns:

a ResultSet holding the results

getIdleFor

public long getIdleFor()

isNeedsPing

public boolean isNeedsPing()

setNeedsPing

public void setNeedsPing(boolean needsPing)

ping

public void ping(boolean checkForClosedConnection,
                 int timeoutMillis)

getConnectionCreationTimeMillis

public long getConnectionCreationTimeMillis()

setConnectionCreationTimeMillis

public void setConnectionCreationTimeMillis(long connectionCreationTimeMillis)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Session

checkClosed

public void checkClosed()

getForceClosedReason

public java.lang.Throwable getForceClosedReason()

setForceClosedReason

public void setForceClosedReason(java.lang.Throwable forceClosedReason)

addListener

public void addListener(Session.SessionEventListener l)

Description copied from interface: Session

Add listener for this session status changes.

Specified by:

addListener in interface Session

Overrides:

addListener in class CoreSession

Parameters:

l - Session.SessionEventListener instance.

removeListener

public void removeListener(Session.SessionEventListener listener)

Description copied from interface: Session

Remove session listener.

Specified by:

removeListener in interface Session

Overrides:

removeListener in class CoreSession

Parameters:

listener - Session.SessionEventListener instance.

invokeNormalCloseListeners

protected void invokeNormalCloseListeners()

invokeReconnectListeners

protected void invokeReconnectListeners()

invokeCleanupListeners

public void invokeCleanupListeners(java.lang.Throwable whyCleanedUp)

getIdentifierQuoteString

public java.lang.String getIdentifierQuoteString()

Specified by:

getIdentifierQuoteString in interface Session

Overrides:

getIdentifierQuoteString in class CoreSession

getCancelTimer

public java.util.Timer getCancelTimer()