com.oceanbase.jdbc.internal.protocol

类 MastersSlavesProtocol

java.lang.Object

com.oceanbase.jdbc.internal.protocol.AbstractConnectProtocol

com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol

com.oceanbase.jdbc.internal.protocol.MasterProtocol

com.oceanbase.jdbc.internal.protocol.MastersSlavesProtocol

所有已实现的接口:

Protocol, Closeable, AutoCloseable

直接已知子类:

AuroraProtocol

public class MastersSlavesProtocol
extends MasterProtocol

字段概要

字段

限定符和类型	字段和说明
protected boolean	masterConnection

从类继承的字段 com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol

lockLogger

从类继承的字段 com.oceanbase.jdbc.internal.protocol.AbstractConnectProtocol

activeStreamingResult, autoCommit, autoIncrementIncrement, CHECK_GALERA_STATE_QUERY, connected, database, enableFullLinkTrace, eofDeprecated, exceptionFactory, explicitClosed, galeraAllowedStates, hasWarnings, lock, options, proxy, reader, readOnly, seed, serverCapabilities, serverPrepareStatementCache, serverStatus, serverThreadId, serverVersion, socket, socketTimeout, traceCache, transactionIsolationLevel, urlParser, useNewExtraInfo, useOceanBaseProtocolV20, username, writer

构造器概要

构造器

构造器和说明
MastersSlavesProtocol(UrlParser url, GlobalStateInfo globalInfo, ReentrantLock lock, LruTraceCache traceCache)

方法概要

限定符和类型	方法和说明
protected static boolean	foundMaster(MastersSlavesListener listener, MastersSlavesProtocol protocol, SearchFilter searchFilter)
protected static boolean	foundSecondary(MastersSlavesListener listener, MastersSlavesProtocol protocol, SearchFilter searchFilter)
static void	loop(MastersSlavesListener listener, GlobalStateInfo globalInfo, List<HostAddress> addresses, SearchFilter searchFilter) loop until found the failed connection.
boolean	mustBeMasterConnection()
void	setMustBeMasterConnection(boolean mustBeMasterConnection)

从类继承的方法 com.oceanbase.jdbc.internal.protocol.MasterProtocol

loop, loop

从类继承的方法 com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol

addPrepareInCache, cancelCurrentQuery, changeUser, clearNetworkStatistics, closeExplicit, executeBatchClient, executeBatchServer, executeBatchStmt, executePreparedQuery, executePreparedQuery, executePreparedQueryArrayBinding, executePreparedQueryArrayBinding, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, fetchRowViaCursor, fetchRowViaCursorForOracle, forceReleasePrepareStatement, getAutocommit, getAutoIncrementIncrement, getCatalog, getChecksum, getExecuteMode, getIterationCount, getLastPacketCostTime, getLastPacketResponseTimestamp, getLastPacketSendTimestamp, getMaxRows, getNetworkStatisticsFlag, getResult, getResultWithoutValue, getTimeout, getTransactionIsolationLevel, handleIoException, interrupt, inTransaction, isInterrupted, isValid, ping, prepare, prolog, prologProxy, readErrorPacket, readOkPacket, readResultSet, releasePrepareStatement, reset, resetChecksum, resetDatabase, resetStateAfterFailover, rollback, setActiveFutureTask, setAutoCommit, setCatalog, setChecksum, setComStmtPrepareExecuteField, setExecuteMode, setIterationCount, setLocalInfileInputStream, setMaxRows, setNetworkStatisticsFlag, setReadonly, setTimeout, setTransactionIsolation, setUsername, stopIfInterrupted

从类继承的方法 com.oceanbase.jdbc.internal.protocol.AbstractConnectProtocol

abort, changeSocketSoTimeout, changeSocketTcpNoDelay, checkIfMaster, cleanMemory, close, connect, connectWithoutProxy, destroySocket, endCallInterface, getActiveStreamingResult, getCurrentHost, getDatabase, getEncoding, getFullLinkTraceAction, getFullLinkTraceClientInfo, getFullLinkTraceIdentifier, getFullLinkTraceLevel, getFullLinkTraceModule, getFullLinkTracePrintSamplePercentage, getFullLinkTraceRecordPolicy, getFullLinkTraceSamplePercentage, getFullLinkTraceSlowQueryThreshold, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getObServerVersion, getOptions, getPinGlobalTxToPhysicalConnection, getPort, getProxy, getReader, getReadonly, getServerStatus, getServerThreadId, getServerTimeZone, getServerVersion, getSocket, getTimeTrace, getTimeZone, getTraces, getUrlParser, getUsername, getWriter, hasMoreResults, hasWarnings, haveInformationSchemaParameters, isClosed, isConnected, isEofDeprecated, isExplicitClosed, isMasterConnection, isOracleMode, isServerMariaDb, isTZTablesImported, noBackslashEscapes, parseVersion, postConnectionQueries, prepareStatementCache, readEofPacket, readPipelineCheckMaster, removeActiveStreamingResult, removeHasMoreResults, sessionStateAware, setActiveStreamingResult, setFullLinkTraceAction, setFullLinkTraceClientInfo, setFullLinkTraceIdentifier, setFullLinkTraceModule, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setObServerVersion, setOracleMode, setProxy, setServerStatus, shouldReconnectWithoutProxy, skip, skipEofPacket, startCallInterface, supportFetchWithOffset, supportStmtPrepareExecute, versionGreaterOrEqual, whyConnectedIsFalse

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.io.Closeable

close

从接口继承的方法 com.oceanbase.jdbc.internal.protocol.Protocol

abort, changeSocketSoTimeout, changeSocketTcpNoDelay, checkIfMaster, close, connect, connectWithoutProxy, endCallInterface, getActiveStreamingResult, getCurrentHost, getDatabase, getEncoding, getFullLinkTraceAction, getFullLinkTraceClientInfo, getFullLinkTraceIdentifier, getFullLinkTraceLevel, getFullLinkTraceModule, getFullLinkTracePrintSamplePercentage, getFullLinkTraceRecordPolicy, getFullLinkTraceSamplePercentage, getFullLinkTraceSlowQueryThreshold, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getObServerVersion, getOptions, getPinGlobalTxToPhysicalConnection, getPort, getProxy, getReader, getReadonly, getServerStatus, getServerThreadId, getServerVersion, getSocket, getTimeTrace, getTimeZone, getTraces, getUrlParser, getUsername, getWriter, hasMoreResults, hasWarnings, haveInformationSchemaParameters, isClosed, isConnected, isEofDeprecated, isExplicitClosed, isMasterConnection, isOracleMode, isServerMariaDb, isTZTablesImported, noBackslashEscapes, parseVersion, prepareStatementCache, readEofPacket, removeActiveStreamingResult, removeHasMoreResults, sessionStateAware, setActiveStreamingResult, setFullLinkTraceAction, setFullLinkTraceClientInfo, setFullLinkTraceIdentifier, setFullLinkTraceModule, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setObServerVersion, setProxy, setServerStatus, shouldReconnectWithoutProxy, skip, skipEofPacket, startCallInterface, supportFetchWithOffset, supportStmtPrepareExecute, versionGreaterOrEqual

字段详细资料

masterConnection

protected boolean masterConnection

构造器详细资料

MastersSlavesProtocol

public MastersSlavesProtocol(UrlParser url,
                             GlobalStateInfo globalInfo,
                             ReentrantLock lock,
                             LruTraceCache traceCache)

方法详细资料

loop

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

loop until found the failed connection.

参数:

listener - current failover

globalInfo - server global variables information

addresses - list of HostAddress to loop

searchFilter - search parameter

抛出:

SQLException - if not found

foundMaster

protected static boolean foundMaster(MastersSlavesListener listener,
                                     MastersSlavesProtocol protocol,
                                     SearchFilter searchFilter)

foundSecondary

protected static boolean foundSecondary(MastersSlavesListener listener,
                                        MastersSlavesProtocol protocol,
                                        SearchFilter searchFilter)
                                 throws SQLException

抛出:

SQLException

mustBeMasterConnection

public boolean mustBeMasterConnection()

指定者:

mustBeMasterConnection 在接口中 Protocol

覆盖:

mustBeMasterConnection 在类中 AbstractConnectProtocol

setMustBeMasterConnection

public void setMustBeMasterConnection(boolean mustBeMasterConnection)