com.oceanbase.jdbc.internal.protocol

类 AuroraProtocol

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

com.oceanbase.jdbc.internal.protocol.AuroraProtocol

所有已实现的接口:

Protocol, Closeable, AutoCloseable

public class AuroraProtocol
extends MastersSlavesProtocol

字段概要

字段

限定符和类型	字段和说明
protected static Logger	lockLogger

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

masterConnection

从类继承的字段 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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
boolean	checkIfMaster() Aurora best way to check if a node is a master : is not in read-only mode.
static AuroraProtocol	getNewProtocol(FailoverProxy proxy, GlobalStateInfo globalInfo, UrlParser urlParser) Initialize new protocol instance.
boolean	isMasterConnection() Indicate if current protocol is a master protocol.
boolean	isValid(int timeout) Check that connection is valid. !!
static void	loop(AuroraListener listener, GlobalStateInfo globalInfo, List<HostAddress> addresses, SearchFilter initialSearchFilter) loop until found the failed connection.
void	readPipelineCheckMaster()

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

foundMaster, foundSecondary, loop, mustBeMasterConnection, setMustBeMasterConnection

从类继承的方法 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, 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, 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, isOracleMode, isServerMariaDb, isTZTablesImported, noBackslashEscapes, parseVersion, postConnectionQueries, prepareStatementCache, readEofPacket, 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, 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, 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

字段详细资料

lockLogger

protected static final Logger lockLogger

构造器详细资料

AuroraProtocol

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

方法详细资料

loop

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

loop until found the failed connection.

参数:

listener - current failover

globalInfo - server global variables information

addresses - list of HostAddress to loop

initialSearchFilter - search parameter

抛出:

SQLException - if not found

getNewProtocol

public static AuroraProtocol getNewProtocol(FailoverProxy proxy,
                                            GlobalStateInfo globalInfo,
                                            UrlParser urlParser)

Initialize new protocol instance.

参数:

proxy - proxy

globalInfo - server global variables information

urlParser - connection string data's

返回:

new AuroraProtocol

isMasterConnection

public boolean isMasterConnection()

从类复制的说明: AbstractConnectProtocol

Indicate if current protocol is a master protocol.

指定者:

isMasterConnection 在接口中 Protocol

覆盖:

isMasterConnection 在类中 AbstractConnectProtocol

返回:

is master flag

readPipelineCheckMaster

public void readPipelineCheckMaster()
                             throws SQLException

覆盖:

readPipelineCheckMaster 在类中 AbstractConnectProtocol

抛出:

SQLException

isValid

public boolean isValid(int timeout)
                throws SQLException

从类复制的说明: AbstractQueryProtocol

Check that connection is valid. !! careful, timeout is in milliseconds, connection.isValid(timeout) is in seconds !!

指定者:

isValid 在接口中 Protocol

覆盖:

isValid 在类中 AbstractQueryProtocol

参数:

timeout - timeout in milliseconds

返回:

true is valid

抛出:

SQLException - if any error occur

checkIfMaster

public boolean checkIfMaster()
                      throws SQLException

Aurora best way to check if a node is a master : is not in read-only mode.

指定者:

checkIfMaster 在接口中 Protocol

覆盖:

checkIfMaster 在类中 AbstractConnectProtocol

返回:

indicate if master has been found

抛出:

SQLException - if requesting infos for server fail.