java.lang.Object
- org.mariadb.jdbc.internal.protocol.AbstractConnectProtocol

All Implemented Interfaces:: Protocol

Direct Known Subclasses:: AbstractQueryProtocol

public abstract class AbstractConnectProtocol
extends java.lang.Object
implements Protocol

Field Summary

Fields
Modifier and Type	Field	Description
`Results`	`activeStreamingResult`
`protected int`	`autoIncrementIncrement`
`protected boolean`	`connected`
`private HostAddress`	`currentHost`
`protected java.lang.String`	`database`
`protected boolean`	`eofDeprecated`
`protected boolean`	`explicitClosed`
`private GlobalStateInfo`	`globalInfo`
`boolean`	`hasWarnings`
`private boolean`	`hostFailed`
`private static byte[]`	`IS_MASTER_QUERY`
`protected java.util.concurrent.locks.ReentrantLock`	`lock`
`private static Logger`	`logger`
`private int`	`majorVersion`
`private int`	`minorVersion`
`protected Options`	`options`
`private java.lang.String`	`password`
`private int`	`patchVersion`
`protected FailoverProxy`	`proxy`
`protected PacketInputStream`	`reader`
`protected boolean`	`readOnly`
`protected long`	`serverCapabilities`
`private boolean`	`serverMariaDb`
`protected ServerPrepareStatementCache`	`serverPrepareStatementCache`
`short`	`serverStatus`
`protected long`	`serverThreadId`
`private java.lang.String`	`serverVersion`
`private static byte[]`	`SESSION_QUERY`
`protected java.net.Socket`	`socket`
`protected int`	`socketTimeout`
`private java.util.TimeZone`	`timeZone`
`private LruTraceCache`	`traceCache`
`protected UrlParser`	`urlParser`
`private java.lang.String`	`username`
`protected PacketOutputStream`	`writer`

Constructor Summary

Constructors
Constructor	Description
`AbstractConnectProtocol(UrlParser urlParser, GlobalStateInfo globalInfo, java.util.concurrent.locks.ReentrantLock lock)`	Get a protocol instance.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`abort()`	Force closes socket and stream readers/writers.
`private void`	`abortActiveStream()`
`private void`	`additionalData(java.util.Map<java.lang.String,java.lang.String> serverData)`
`private void`	`authentication(byte exchangeCharset, long clientCapabilities, byte packetSeq, ReadInitialHandShakePacket greetingPacket)`
`void`	`changeSocketSoTimeout(int setSoTimeout)`
`void`	`changeSocketTcpNoDelay(boolean setTcpNoDelay)`	Change Socket TcpNoDelay option.
`boolean`	`checkIfMaster()`	Check that current connection is a master connection (not read-only).
`private void`	`cleanMemory()`
`void`	`close()`	Closes socket and stream readers/writers Attempts graceful shutdown.
`private static void`	`closeSocket(PacketInputStream packetInputStream, PacketOutputStream packetOutputStream, java.net.Socket socket)`
`void`	`connect()`	Connect to currentHost.
`private void`	`connect(java.lang.String host, int port)`	Connect the client and perform handshake.
`void`	`connectWithoutProxy()`	Connect without proxy.
`private byte`	`decideLanguage(int serverLanguage)`	Default collation used for string exchanges with server.
`private void`	`enabledSslCipherSuites(javax.net.ssl.SSLSocket sslSocket)`	Set ssl socket cipher according to options.
`private void`	`enabledSslProtocolSuites(javax.net.ssl.SSLSocket sslSocket)`	Return possible protocols : values of option enabledSslProtocolSuites is set, or default to "TLSv1,TLSv1.1".
`private void`	`ensureClosingSocketOnException()`
`abstract void`	`executeQuery(java.lang.String sql)`
`private void`	`forceAbort()`
`Results`	`getActiveStreamingResult()`
`java.lang.String`	`getDatabase()`
`java.lang.String`	`getHost()`
`HostAddress`	`getHostAddress()`
`java.util.concurrent.locks.ReentrantLock`	`getLock()`
`int`	`getMajorServerVersion()`
`int`	`getMinorServerVersion()`
`Options`	`getOptions()`
`boolean`	`getPinGlobalTxToPhysicalConnection()`
`int`	`getPort()`
`FailoverProxy`	`getProxy()`
`PacketInputStream`	`getReader()`
`boolean`	`getReadonly()`
`long`	`getServerThreadId()`
`java.lang.String`	`getServerVersion()`
`java.net.Socket`	`getSocket()`
`java.util.TimeZone`	`getTimeZone()`
`java.lang.String`	`getTraces()`	Get a String containing readable information about last 10 send/received packets.
`UrlParser`	`getUrlParser()`
`java.lang.String`	`getUsername()`
`PacketOutputStream`	`getWriter()`
`private void`	`handleConnectionPhases(java.lang.String host)`
`boolean`	`hasMoreResults()`
`boolean`	`hasWarnings()`	Has warnings.
`private long`	`initializeClientCapabilities(long serverCapabilities)`
`private void`	`initializeSocketOption()`	InitializeSocketOption.
`boolean`	`isClosed()`	Is the connection closed.
`boolean`	`isConnected()`	Is connected.
`boolean`	`isEofDeprecated()`
`boolean`	`isExplicitClosed()`
`boolean`	`isMasterConnection()`	Indicate if current protocol is a master protocol.
`boolean`	`isServerMariaDb()`
`private void`	`loadCalendar(java.lang.String srvTimeZone, java.lang.String srvSystemTimeZone)`
`boolean`	`mustBeMasterConnection()`
`boolean`	`noBackslashEscapes()`
`private void`	`parseVersion()`
`ServerPrepareStatementCache`	`prepareStatementCache()`
`void`	`readEofPacket()`	Check that next read packet is a End-of-file packet.
`private void`	`readPipelineAdditionalData(java.util.Map<java.lang.String,java.lang.String> serverData)`
`void`	`readPipelineCheckMaster()`
`private void`	`readRequestSessionVariables(java.util.Map<java.lang.String,java.lang.String> serverData)`
`void`	`removeActiveStreamingResult()`	Remove exception result and since totally fetched, set fetch size to 0.
`void`	`removeHasMoreResults()`	Remove flag has more results.
`private void`	`requestSessionDataWithShow(java.util.Map<java.lang.String,java.lang.String> serverData)`
`private void`	`sendCreateDatabaseIfNotExist(java.lang.String quotedDb)`
`private void`	`sendPipelineAdditionalData()`	Send all additional needed values.
`private void`	`sendPipelineCheckMaster()`	Send query to identify if server is master.
`private void`	`sendRequestSessionVariables()`
`private void`	`sendSessionInfos()`
`private void`	`sendUseDatabaseIfNotExist(java.lang.String quotedDb)`
`boolean`	`sessionStateAware()`
`void`	`setActiveStreamingResult(Results activeStreamingResult)`
`void`	`setHasWarnings(boolean hasWarnings)`
`void`	`setHostAddress(HostAddress host)`
`void`	`setHostFailedWithoutProxy()`
`void`	`setProxy(FailoverProxy proxy)`
`void`	`setReadonly(boolean readOnly)`
`void`	`setServerStatus(short serverStatus)`
`boolean`	`shouldReconnectWithoutProxy()`
`void`	`skip()`	Skip packets not read that are not needed.
`void`	`skipEofPacket()`	Check that next read packet is a End-of-file packet.
`boolean`	`versionGreaterOrEqual(int major, int minor, int patch)`	Utility method to check if database version is greater than parameters.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - SESSION_QUERY
```
private static final byte[] SESSION_QUERY
```
  - IS_MASTER_QUERY
```
private static final byte[] IS_MASTER_QUERY
```
  - logger
```
private static final Logger logger
```
  - lock
```
protected final java.util.concurrent.locks.ReentrantLock lock
```
  - urlParser
```
protected final UrlParser urlParser
```
  - options
```
protected final Options options
```
  - username
```
private final java.lang.String username
```
  - password
```
private final java.lang.String password
```
  - traceCache
```
private final LruTraceCache traceCache
```
  - globalInfo
```
private final GlobalStateInfo globalInfo
```
  - hasWarnings
```
public boolean hasWarnings
```
  - activeStreamingResult
```
public Results activeStreamingResult
```
  - serverStatus
```
public short serverStatus
```
  - autoIncrementIncrement
```
protected int autoIncrementIncrement
```
  - socket
```
protected java.net.Socket socket
```
  - writer
```
protected PacketOutputStream writer
```
  - readOnly
```
protected boolean readOnly
```
  - reader
```
protected PacketInputStream reader
```
  - proxy
```
protected FailoverProxy proxy
```
  - connected
```
protected volatile boolean connected
```
  - explicitClosed
```
protected boolean explicitClosed
```
  - database
```
protected java.lang.String database
```
  - serverThreadId
```
protected long serverThreadId
```
  - serverPrepareStatementCache
```
protected ServerPrepareStatementCache serverPrepareStatementCache
```
  - eofDeprecated
```
protected boolean eofDeprecated
```
  - serverCapabilities
```
protected long serverCapabilities
```
  - currentHost
```
private HostAddress currentHost
```
  - hostFailed
```
private boolean hostFailed
```
  - serverVersion
```
private java.lang.String serverVersion
```
  - serverMariaDb
```
private boolean serverMariaDb
```
  - majorVersion
```
private int majorVersion
```
  - minorVersion
```
private int minorVersion
```
  - patchVersion
```
private int patchVersion
```
  - timeZone
```
private java.util.TimeZone timeZone
```
  - socketTimeout
```
protected int socketTimeout
```
- Constructor Detail
  - AbstractConnectProtocol
```
public AbstractConnectProtocol(UrlParser urlParser,
                               GlobalStateInfo globalInfo,
                               java.util.concurrent.locks.ReentrantLock lock)
```
    Get a protocol instance.
    
    Parameters:
    
    urlParser - connection URL information
    
    globalInfo - server global variables information
    
    lock - the lock for thread synchronisation
- Method Detail
  - closeSocket
```
private static void closeSocket(PacketInputStream packetInputStream,
                                PacketOutputStream packetOutputStream,
                                java.net.Socket socket)
```
  - close
```
public void close()
```
    Closes socket and stream readers/writers Attempts graceful shutdown.
    
    Specified by:
    
    close in interface Protocol
  - abort
```
public void abort()
```
    Force closes socket and stream readers/writers.
    
    Specified by:
    
    abort in interface Protocol
  - forceAbort
```
private void forceAbort()
```
  - abortActiveStream
```
private void abortActiveStream()
```
  - skip
```
public void skip()
          throws java.sql.SQLException
```
    Skip packets not read that are not needed. Packets are read according to needs. If some data have not been read before next execution, skip it. Lock must be set before using this method
    
    Specified by:
    
    skip in interface Protocol
    
    Throws:
    
    java.sql.SQLException - exception
  - cleanMemory
```
private void cleanMemory()
```
  - setServerStatus
```
public void setServerStatus(short serverStatus)
```
    Specified by:
    
    setServerStatus in interface Protocol
  - removeHasMoreResults
```
public void removeHasMoreResults()
```
    Remove flag has more results.
    
    Specified by:
    
    removeHasMoreResults in interface Protocol
  - initializeSocketOption
```
private void initializeSocketOption()
```
    InitializeSocketOption.
  - connect
```
public void connect()
             throws java.sql.SQLException
```
    Connect to currentHost.
    
    Specified by:
    
    connect in interface Protocol
    
    Throws:
    
    java.sql.SQLException - exception
  - connect
```
private void connect(java.lang.String host,
                     int port)
              throws java.sql.SQLException,
                     java.io.IOException
```
    Connect the client and perform handshake.
    
    Parameters:
    
    host - host
    
    port - port
    
    Throws:
    
    java.sql.SQLException - handshake error, e.g wrong user or password
    
    java.io.IOException - connection error (host/port not available)
  - sendPipelineAdditionalData
```
private void sendPipelineAdditionalData()
                                 throws java.io.IOException
```
    Send all additional needed values. Command are send one after the other, assuming that command are less than 65k (minimum hosts TCP/IP buffer size)
    
    Throws:
    
    java.io.IOException - if socket exception occur
  - sendSessionInfos
```
private void sendSessionInfos()
                       throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - sendRequestSessionVariables
```
private void sendRequestSessionVariables()
                                  throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - readRequestSessionVariables
```
private void readRequestSessionVariables(java.util.Map<java.lang.String,java.lang.String> serverData)
                                  throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - sendCreateDatabaseIfNotExist
```
private void sendCreateDatabaseIfNotExist(java.lang.String quotedDb)
                                   throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - sendUseDatabaseIfNotExist
```
private void sendUseDatabaseIfNotExist(java.lang.String quotedDb)
                                throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - readPipelineAdditionalData
```
private void readPipelineAdditionalData(java.util.Map<java.lang.String,java.lang.String> serverData)
                                 throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - requestSessionDataWithShow
```
private void requestSessionDataWithShow(java.util.Map<java.lang.String,java.lang.String> serverData)
                                 throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - additionalData
```
private void additionalData(java.util.Map<java.lang.String,java.lang.String> serverData)
                     throws java.io.IOException,
                            java.sql.SQLException
```
    Throws:
    
    java.io.IOException
    
    java.sql.SQLException
  - ensureClosingSocketOnException
```
private void ensureClosingSocketOnException()
```
  - isClosed
```
public boolean isClosed()
```
    Is the connection closed.
    
    Specified by:
    
    isClosed in interface Protocol
    
    Returns:
    
    true if the connection is closed
  - handleConnectionPhases
```
private void handleConnectionPhases(java.lang.String host)
                             throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - authentication
```
private void authentication(byte exchangeCharset,
                            long clientCapabilities,
                            byte packetSeq,
                            ReadInitialHandShakePacket greetingPacket)
                     throws java.sql.SQLException,
                            java.io.IOException
```
    Throws:
    
    java.sql.SQLException
    
    java.io.IOException
  - initializeClientCapabilities
```
private long initializeClientCapabilities(long serverCapabilities)
```
  - loadCalendar
```
private void loadCalendar(java.lang.String srvTimeZone,
                          java.lang.String srvSystemTimeZone)
                   throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - checkIfMaster
```
public boolean checkIfMaster()
                      throws java.sql.SQLException
```
    Check that current connection is a master connection (not read-only).
    
    Specified by:
    
    checkIfMaster in interface Protocol
    
    Returns:
    
    true if master
    
    Throws:
    
    java.sql.SQLException - if requesting infos for server fail.
  - decideLanguage
```
private byte decideLanguage(int serverLanguage)
```
    Default collation used for string exchanges with server.
    
    Parameters:
    
    serverLanguage - server default collation
    
    Returns:
    
    collation byte
  - readEofPacket
```
public void readEofPacket()
                   throws java.sql.SQLException,
                          java.io.IOException
```
    Check that next read packet is a End-of-file packet.
    
    Specified by:
    
    readEofPacket in interface Protocol
    
    Throws:
    
    java.sql.SQLException - if not a End-of-file packet
    
    java.io.IOException - if connection error occur
  - skipEofPacket
```
public void skipEofPacket()
                   throws java.sql.SQLException,
                          java.io.IOException
```
    Check that next read packet is a End-of-file packet.
    
    Specified by:
    
    skipEofPacket in interface Protocol
    
    Throws:
    
    java.sql.SQLException - if not a End-of-file packet
    
    java.io.IOException - if connection error occur
  - setHostFailedWithoutProxy
```
public void setHostFailedWithoutProxy()
```
    Specified by:
    
    setHostFailedWithoutProxy in interface Protocol
  - getUrlParser
```
public UrlParser getUrlParser()
```
    Specified by:
    
    getUrlParser in interface Protocol
  - isMasterConnection
```
public boolean isMasterConnection()
```
    Indicate if current protocol is a master protocol.
    
    Specified by:
    
    isMasterConnection in interface Protocol
    
    Returns:
    
    is master flag
  - sendPipelineCheckMaster
```
private void sendPipelineCheckMaster()
                              throws java.io.IOException
```
    Send query to identify if server is master.
    
    Throws:
    
    java.io.IOException - in case of socket error.
  - readPipelineCheckMaster
```
public void readPipelineCheckMaster()
                             throws java.sql.SQLException
```
    Throws:
    
    java.sql.SQLException
  - mustBeMasterConnection
```
public boolean mustBeMasterConnection()
```
    Specified by:
    
    mustBeMasterConnection in interface Protocol
  - noBackslashEscapes
```
public boolean noBackslashEscapes()
```
    Specified by:
    
    noBackslashEscapes in interface Protocol
  - connectWithoutProxy
```
public void connectWithoutProxy()
                         throws java.sql.SQLException
```
    Connect without proxy. (use basic failover implementation)
    
    Specified by:
    
    connectWithoutProxy in interface Protocol
    
    Throws:
    
    java.sql.SQLException - exception
  - shouldReconnectWithoutProxy
```
public boolean shouldReconnectWithoutProxy()
```
    Specified by:
    
    shouldReconnectWithoutProxy in interface Protocol
  - getServerVersion
```
public java.lang.String getServerVersion()
```
    Specified by:
    
    getServerVersion in interface Protocol
  - getReadonly
```
public boolean getReadonly()
```
    Specified by:
    
    getReadonly in interface Protocol
  - setReadonly
```
public void setReadonly(boolean readOnly)
```
    Specified by:
    
    setReadonly in interface Protocol
  - getHostAddress
```
public HostAddress getHostAddress()
```
    Specified by:
    
    getHostAddress in interface Protocol
  - setHostAddress
```
public void setHostAddress(HostAddress host)
```
    Specified by:
    
    setHostAddress in interface Protocol
  - getHost
```
public java.lang.String getHost()
```
    Specified by:
    
    getHost in interface Protocol
  - getProxy
```
public FailoverProxy getProxy()
```
    Specified by:
    
    getProxy in interface Protocol
  - setProxy
```
public void setProxy(FailoverProxy proxy)
```
    Specified by:
    
    setProxy in interface Protocol
  - getPort
```
public int getPort()
```
    Specified by:
    
    getPort in interface Protocol
  - getDatabase
```
public java.lang.String getDatabase()
```
    Specified by:
    
    getDatabase in interface Protocol
  - getUsername
```
public java.lang.String getUsername()
```
    Specified by:
    
    getUsername in interface Protocol
  - parseVersion
```
private void parseVersion()
```
  - getMajorServerVersion
```
public int getMajorServerVersion()
```
    Specified by:
    
    getMajorServerVersion in interface Protocol
  - getMinorServerVersion
```
public int getMinorServerVersion()
```
    Specified by:
    
    getMinorServerVersion in interface Protocol
  - enabledSslProtocolSuites
```
private void enabledSslProtocolSuites(javax.net.ssl.SSLSocket sslSocket)
                               throws java.sql.SQLException
```
    Return possible protocols : values of option enabledSslProtocolSuites is set, or default to "TLSv1,TLSv1.1". MariaDB versions ≥ 10.0.15 and ≥ 5.5.41 supports TLSv1.2 if compiled with openSSL (default). MySQL community versions ≥ 5.7.10 is compile with yaSSL, so max TLS is TLSv1.1.
    
    Parameters:
    
    sslSocket - current sslSocket
    
    Throws:
    
    java.sql.SQLException - if protocol isn't a supported protocol
  - enabledSslCipherSuites
```
private void enabledSslCipherSuites(javax.net.ssl.SSLSocket sslSocket)
                             throws java.sql.SQLException
```
    Set ssl socket cipher according to options.
    
    Parameters:
    
    sslSocket - current ssl socket
    
    Throws:
    
    java.sql.SQLException - if a cipher isn't known
  - versionGreaterOrEqual
```
public boolean versionGreaterOrEqual(int major,
                                     int minor,
                                     int patch)
```
    Utility method to check if database version is greater than parameters.
    
    Specified by:
    
    versionGreaterOrEqual in interface Protocol
    
    Parameters:
    
    major - major version
    
    minor - minor version
    
    patch - patch version
    
    Returns:
    
    true if version is greater than parameters
  - getPinGlobalTxToPhysicalConnection
```
public boolean getPinGlobalTxToPhysicalConnection()
```
    Specified by:
    
    getPinGlobalTxToPhysicalConnection in interface Protocol
  - hasWarnings
```
public boolean hasWarnings()
```
    Has warnings.
    
    Specified by:
    
    hasWarnings in interface Protocol
    
    Returns:
    
    true if as warnings.
  - isConnected
```
public boolean isConnected()
```
    Is connected.
    
    Specified by:
    
    isConnected in interface Protocol
    
    Returns:
    
    true if connected
  - getServerThreadId
```
public long getServerThreadId()
```
    Specified by:
    
    getServerThreadId in interface Protocol
  - getSocket
```
public java.net.Socket getSocket()
```
    Specified by:
    
    getSocket in interface Protocol
  - isExplicitClosed
```
public boolean isExplicitClosed()
```
    Specified by:
    
    isExplicitClosed in interface Protocol
  - getTimeZone
```
public java.util.TimeZone getTimeZone()
```
    Specified by:
    
    getTimeZone in interface Protocol
  - getOptions
```
public Options getOptions()
```
    Specified by:
    
    getOptions in interface Protocol
  - setHasWarnings
```
public void setHasWarnings(boolean hasWarnings)
```
    Specified by:
    
    setHasWarnings in interface Protocol
  - getActiveStreamingResult
```
public Results getActiveStreamingResult()
```
    Specified by:
    
    getActiveStreamingResult in interface Protocol
  - setActiveStreamingResult
```
public void setActiveStreamingResult(Results activeStreamingResult)
```
    Specified by:
    
    setActiveStreamingResult in interface Protocol
  - removeActiveStreamingResult
```
public void removeActiveStreamingResult()
```
    Remove exception result and since totally fetched, set fetch size to 0.
    
    Specified by:
    
    removeActiveStreamingResult in interface Protocol
  - getLock
```
public java.util.concurrent.locks.ReentrantLock getLock()
```
    Specified by:
    
    getLock in interface Protocol
  - hasMoreResults
```
public boolean hasMoreResults()
```
    Specified by:
    
    hasMoreResults in interface Protocol
  - prepareStatementCache
```
public ServerPrepareStatementCache prepareStatementCache()
```
    Specified by:
    
    prepareStatementCache in interface Protocol
  - executeQuery
```
public abstract void executeQuery(java.lang.String sql)
                           throws java.sql.SQLException
```
    Specified by:
    
    executeQuery in interface Protocol
    
    Throws:
    
    java.sql.SQLException
  - changeSocketTcpNoDelay
```
public void changeSocketTcpNoDelay(boolean setTcpNoDelay)
```
    Change Socket TcpNoDelay option.
    
    Specified by:
    
    changeSocketTcpNoDelay in interface Protocol
    
    Parameters:
    
    setTcpNoDelay - value to set.
  - changeSocketSoTimeout
```
public void changeSocketSoTimeout(int setSoTimeout)
                           throws java.net.SocketException
```
    Specified by:
    
    changeSocketSoTimeout in interface Protocol
    
    Throws:
    
    java.net.SocketException
  - isServerMariaDb
```
public boolean isServerMariaDb()
```
    Specified by:
    
    isServerMariaDb in interface Protocol
  - getReader
```
public PacketInputStream getReader()
```
    Specified by:
    
    getReader in interface Protocol
  - getWriter
```
public PacketOutputStream getWriter()
```
    Specified by:
    
    getWriter in interface Protocol
  - isEofDeprecated
```
public boolean isEofDeprecated()
```
    Specified by:
    
    isEofDeprecated in interface Protocol
  - sessionStateAware
```
public boolean sessionStateAware()
```
    Specified by:
    
    sessionStateAware in interface Protocol
  - getTraces
```
public java.lang.String getTraces()
```
    Get a String containing readable information about last 10 send/received packets.
    
    Specified by:
    
    getTraces in interface Protocol
    
    Returns:
    
    String value

Class AbstractConnectProtocol

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.mariadb.jdbc.internal.protocol.Protocol

Field Detail

SESSION_QUERY

IS_MASTER_QUERY

logger

lock

urlParser

options

username

password

traceCache

globalInfo

hasWarnings

activeStreamingResult

serverStatus

autoIncrementIncrement

socket

writer

readOnly

reader

proxy

connected

explicitClosed

database

serverThreadId

serverPrepareStatementCache

eofDeprecated

serverCapabilities

currentHost

hostFailed

serverVersion

serverMariaDb

majorVersion

minorVersion

patchVersion

timeZone

socketTimeout

Constructor Detail

AbstractConnectProtocol

Method Detail

closeSocket

close

abort

forceAbort

abortActiveStream

skip

cleanMemory

setServerStatus

removeHasMoreResults

initializeSocketOption

connect

connect

sendPipelineAdditionalData

sendSessionInfos

sendRequestSessionVariables

readRequestSessionVariables

sendCreateDatabaseIfNotExist

sendUseDatabaseIfNotExist

readPipelineAdditionalData

requestSessionDataWithShow

additionalData

ensureClosingSocketOnException

isClosed

handleConnectionPhases

authentication

initializeClientCapabilities

loadCalendar

checkIfMaster

decideLanguage

readEofPacket

skipEofPacket

setHostFailedWithoutProxy

getUrlParser

isMasterConnection

sendPipelineCheckMaster