Package org.mariadb.jdbc.internal.protocol

Class MasterProtocol

java.lang.Object

org.mariadb.jdbc.internal.protocol.AbstractConnectProtocol

org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol

org.mariadb.jdbc.internal.protocol.MasterProtocol

All Implemented Interfaces:

Closeable, AutoCloseable, Protocol

Direct Known Subclasses:

MastersSlavesProtocol

public class MasterProtocol
extends AbstractQueryProtocol
implements Closeable

Field Summary

Fields inherited from class org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol

readScheduler

Fields inherited from class org.mariadb.jdbc.internal.protocol.AbstractConnectProtocol

activeStreamingResult, autoIncrementIncrement, connected, database, eofDeprecated, explicitClosed, hasWarnings, lock, options, proxy, reader, readOnly, serverCapabilities, serverPrepareStatementCache, serverStatus, serverThreadId, socket, socketTimeout, urlParser, writer

Constructor Summary

Constructors

Constructor	Description
MasterProtocol(UrlParser urlParser, GlobalStateInfo globalInfo, ReentrantLock lock)	Get a protocol instance.

Method Summary

Modifier and Type	Method	Description
private static MasterProtocol	getNewProtocol(FailoverProxy proxy, GlobalStateInfo globalInfo, UrlParser urlParser)	Get new instance.
static void	loop(Listener listener, GlobalStateInfo globalInfo, List<HostAddress> addresses, SearchFilter searchFilter)	loop until found the failed connection.
private static void	resetHostList(Listener listener, Deque<HostAddress> loopAddresses)	Reinitialize loopAddresses with all hosts : all servers in randomize order without connected host.

Methods inherited from class org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol

addPrepareInCache, cancelCurrentQuery, closeExplicit, executeBatchClient, executeBatchServer, executeBatchStmt, executePreparedQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, forceReleasePrepareStatement, forceReleaseWaitingPrepareStatement, getAutocommit, getAutoIncrementIncrement, getCatalog, getMaxRows, getResult, getTimeout, getTransactionIsolationLevel, handleIoException, interrupt, inTransaction, isInterrupted, isValid, ping, prepare, prolog, prologProxy, releasePrepareStatement, reset, resetDatabase, resetStateAfterFailover, rollback, setActiveFutureTask, setCatalog, setLocalInfileInputStream, setMaxRows, setTimeout, setTransactionIsolation, stopIfInterrupted

Methods inherited from class org.mariadb.jdbc.internal.protocol.AbstractConnectProtocol

abort, changeSocketSoTimeout, changeSocketTcpNoDelay, checkIfMaster, close, connect, connectWithoutProxy, getActiveStreamingResult, getDatabase, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getOptions, getPinGlobalTxToPhysicalConnection, getPort, getProxy, getReader, getReadonly, getServerThreadId, getServerVersion, getSocket, getTimeZone, getTraces, getUrlParser, getUsername, getWriter, hasMoreResults, hasWarnings, isClosed, isConnected, isEofDeprecated, isExplicitClosed, isMasterConnection, isServerMariaDb, mustBeMasterConnection, noBackslashEscapes, prepareStatementCache, readEofPacket, readPipelineCheckMaster, removeActiveStreamingResult, removeHasMoreResults, sessionStateAware, setActiveStreamingResult, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setProxy, setReadonly, setServerStatus, shouldReconnectWithoutProxy, skip, skipEofPacket, versionGreaterOrEqual

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

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

abort, changeSocketSoTimeout, changeSocketTcpNoDelay, checkIfMaster, close, connect, connectWithoutProxy, getActiveStreamingResult, getDatabase, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getOptions, getPinGlobalTxToPhysicalConnection, getPort, getProxy, getReader, getReadonly, getServerThreadId, getServerVersion, getSocket, getTimeZone, getTraces, getUrlParser, getUsername, getWriter, hasMoreResults, hasWarnings, isClosed, isConnected, isEofDeprecated, isExplicitClosed, isMasterConnection, isServerMariaDb, mustBeMasterConnection, noBackslashEscapes, prepareStatementCache, readEofPacket, removeActiveStreamingResult, removeHasMoreResults, sessionStateAware, setActiveStreamingResult, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setProxy, setReadonly, setServerStatus, shouldReconnectWithoutProxy, skip, skipEofPacket, versionGreaterOrEqual

Constructor Details

MasterProtocol

public MasterProtocol(UrlParser urlParser,
 GlobalStateInfo globalInfo,
 ReentrantLock lock)

Get a protocol instance.

Parameters:

urlParser - connection URL infos

globalInfo - server global variables information

lock - the lock for thread synchronisation

Method Details

getNewProtocol

private static MasterProtocol getNewProtocol(FailoverProxy proxy,
 GlobalStateInfo globalInfo,
 UrlParser urlParser)

Get new instance.

Parameters:

proxy - proxy

urlParser - url connection object

Returns:

new instance

loop

public static void loop(Listener listener,
 GlobalStateInfo globalInfo,
 List<HostAddress> addresses,
 SearchFilter searchFilter)
                 throws SQLException

loop until found the failed connection.

Parameters:

listener - current failover

globalInfo - server global variables information

addresses - list of HostAddress to loop

searchFilter - search parameter

Throws:

SQLException - if not found

resetHostList

private static void resetHostList(Listener listener,
 Deque<HostAddress> loopAddresses)

Reinitialize loopAddresses with all hosts : all servers in randomize order without connected host.

Parameters:

listener - current listener

loopAddresses - the list to reinitialize