AbstractQueryProtocol (oceanbase-client 2.4.11 API)

java.lang.Object
- com.oceanbase.jdbc.internal.protocol.AbstractConnectProtocol
- - com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol

所有已实现的接口:: Protocol

直接已知子类:: MasterProtocol

public class AbstractQueryProtocol
extends AbstractConnectProtocol
implements Protocol

字段概要

字段
限定符和类型字段和说明

protected static Logger 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

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

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`ServerPrepareResult`	`addPrepareInCache(String key, ServerPrepareResult serverPrepareResult)`
`void`	`cancelCurrentQuery()` Cancels the current query - clones the current protocol and executes a query using the new connection.
`void`	`changeUser(String user, String pwd)`
`void`	`clearNetworkStatistics()`
`void`	`closeExplicit()`
`boolean`	`executeBatchClient(boolean mustExecuteOnMaster, Results results, ClientPrepareResult prepareResult, List<ParameterHolder[]> parametersList, boolean hasLongData)` Execute clientPrepareQuery batch.
`ServerPrepareResult`	`executeBatchServer(ServerPrepareResult serverPrepareResult, Results results, String sql, List<ParameterHolder[]> parametersList, boolean hasLongData)` Execute Prepare if needed, and execute COM_STMT_EXECUTE queries in batch.
`void`	`executeBatchStmt(boolean mustExecuteOnMaster, Results results, List<String> queries)` Execute batch from Statement.executeBatch().
`void`	`executePreparedQuery(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, ParameterHolder[] parameters)` Execute a query that is already prepared.
`ServerPrepareResult`	`executePreparedQuery(int parameterCount, ParameterHolder[] parameters, ServerPrepareResult serverPrepareResult, Results results)` Execute a query that is to be prepared on server in Oracle mode
`void`	`executePreparedQueryArrayBinding(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, List<ParameterHolder[]> queryParameters, int queryParameterSize)` Protocol processing mechanism when prepareExecute is not used
`ServerPrepareResult`	`executePreparedQueryArrayBinding(int parameterCount, boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, List<ParameterHolder[]> queryParameters, int queryParamtersSize)` Protocol processing mechanism when prepareExecute is used.
`void`	`executeQuery(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters)` Execute a unique clientPrepareQuery.
`void`	`executeQuery(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters, int queryTimeout)` Execute a unique clientPrepareQuery.
`void`	`executeQuery(boolean mustExecuteOnMaster, Results results, String sql)` Execute query directly to outputStream.
`void`	`executeQuery(boolean mustExecuteOnMaster, Results results, String sql, Charset charset)`
`void`	`executeQuery(String sql)` Execute internal query.
`ColumnDefinition[]`	`fetchRowViaCursor(int cursorId, int fetchSize, Results results)`
`ColumnDefinition[]`	`fetchRowViaCursorForOracle(int cursorId, int numRows, byte offsetType, int offset, Results results)`
`boolean`	`forceReleasePrepareStatement(int statementId)` Force release of prepare statement that are not used.
`boolean`	`getAutocommit()` Get current autocommit status.
`int`	`getAutoIncrementIncrement()` Get current auto increment increment. * no lock needed **
`String`	`getCatalog()`
`long`	`getChecksum()`
`int`	`getExecuteMode()`
`int`	`getIterationCount()`
`long`	`getLastPacketCostTime()`
`long`	`getLastPacketResponseTimestamp()`
`long`	`getLastPacketSendTimestamp()`
`long`	`getMaxRows()`
`boolean`	`getNetworkStatisticsFlag()`
`void`	`getResult(Results results)`
`ColumnDefinition[]`	`getResultWithoutValue(Results results)`
`int`	`getTimeout()` Returns the connection timeout in milliseconds.
`int`	`getTransactionIsolationLevel()`
`SQLException`	`handleIoException(Exception initialException)` Handle IoException (reconnect if Exception is due to having send too much data, making server close the connection.
`void`	`interrupt()`
`boolean`	`inTransaction()`
`boolean`	`isInterrupted()`
`boolean`	`isValid(int timeout)` Check that connection is valid. !!
`boolean`	`ping()`
`ServerPrepareResult`	`prepare(String sql, boolean executeOnMaster)` Prepare query on server side.
`void`	`prolog(long maxRows, boolean hasProxy, OceanBaseConnection connection, OceanBaseStatement statement)` Preparation before command.
`void`	`prologProxy(ServerPrepareResult serverPrepareResult, long maxRows, boolean hasProxy, OceanBaseConnection connection, OceanBaseStatement statement)`
`SQLException`	`readErrorPacket(Buffer buffer, Results results)` Read ERR_Packet.
`void`	`readOkPacket(Buffer buffer, Results results)` Read OK_Packet.
`void`	`readResultSet(ColumnDefinition[] ci, Results results)` Read ResultSet Packet.
`void`	`releasePrepareStatement(ServerPrepareResult serverPrepareResult)` Deallocate prepare statement if not used anymore.
`void`	`reset()` Reset connection state.
`void`	`resetChecksum()`
`void`	`resetDatabase()`
`void`	`resetStateAfterFailover(long maxRows, int transactionIsolationLevel, String database, boolean autocommit)` Set current state after a failover.
`void`	`rollback()` Rollback transaction.
`void`	`setActiveFutureTask(FutureTask activeFutureTask)`
`void`	`setAutoCommit(boolean autoCommit)`
`void`	`setCatalog(String database)`
`void`	`setChecksum(long checksum)`
`void`	`setComStmtPrepareExecuteField(int iterationCount, int executeMode, long checksum)`
`void`	`setExecuteMode(int executeMode)`
`void`	`setIterationCount(int iterationCount)`
`void`	`setLocalInfileInputStream(InputStream inputStream)`
`void`	`setMaxRows(long max)`
`void`	`setNetworkStatisticsFlag(boolean flag)`
`void`	`setReadonly(boolean readOnly)` Puts this connection in read-only / read-write mode
`void`	`setTimeout(int timeout)` Sets the connection timeout.
`void`	`setTransactionIsolation(int level)` Set transaction isolation.
`void`	`setUsername(String username)`
`void`	`stopIfInterrupted()` Throw TimeoutException if timeout has been reached.

从类继承的方法 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, mustBeMasterConnection, 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

从接口继承的方法 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, mustBeMasterConnection, 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
```
- 方法详细资料
  - reset
```
public void reset()
           throws SQLException
```
    Reset connection state.
    1. Transaction will be rollback
    2. transaction isolation will be reset
    3. user variables will be removed
    4. sessions variables will be reset to global values
    指定者:
    
    reset 在接口中 Protocol
    
    抛出:
    
    SQLException - if command failed
  - prepare
```
public ServerPrepareResult prepare(String sql,
                                   boolean executeOnMaster)
                            throws SQLException
```
    Prepare query on server side. Will permit to know the parameter number of the query, and permit to send only the data on next results.
    For failover, two additional information are in the result-set object : - current connection : Since server maintain a state of this prepare statement, all query will be executed on this particular connection. - executeOnMaster : state of current connection when creating this prepareStatement (if was on master, will only be executed on master. If was on a slave, can be execute temporary on master, but we keep this flag, so when a slave is connected back to relaunch this query on slave)
    
    指定者:
    
    prepare 在接口中 Protocol
    
    参数:
    
    sql - the query
    
    executeOnMaster - state of current connection when creating this prepareStatement
    
    返回:
    
    a ServerPrepareResult object that contain prepare result information.
    
    抛出:
    
    SQLException - if any error occur on connection.
  - executeQuery
```
public void executeQuery(String sql)
                  throws SQLException
```
    Execute internal query.
    !! will not support multi values queries !!
    
    指定者:
    
    executeQuery 在接口中 Protocol
    
    指定者:
    
    executeQuery 在类中 AbstractConnectProtocol
    
    参数:
    
    sql - sql
    
    抛出:
    
    SQLException - in any exception occur
  - executeQuery
```
public void executeQuery(boolean mustExecuteOnMaster,
                         Results results,
                         String sql)
                  throws SQLException
```
    Execute query directly to outputStream.
    
    指定者:
    
    executeQuery 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - was intended to be launched on master connection
    
    results - result
    
    sql - the query to executeInternal
    
    抛出:
    
    SQLException - exception
  - executeQuery
```
public void executeQuery(boolean mustExecuteOnMaster,
                         Results results,
                         String sql,
                         Charset charset)
                  throws SQLException
```
    指定者:
    
    executeQuery 在接口中 Protocol
    
    抛出:
    
    SQLException
  - executeQuery
```
public void executeQuery(boolean mustExecuteOnMaster,
                         Results results,
                         ClientPrepareResult clientPrepareResult,
                         ParameterHolder[] parameters)
                  throws SQLException
```
    Execute a unique clientPrepareQuery.
    
    指定者:
    
    executeQuery 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - was intended to be launched on master connection
    
    results - results
    
    clientPrepareResult - clientPrepareResult
    
    parameters - parameters
    
    抛出:
    
    SQLException - exception
  - executeQuery
```
public void executeQuery(boolean mustExecuteOnMaster,
                         Results results,
                         ClientPrepareResult clientPrepareResult,
                         ParameterHolder[] parameters,
                         int queryTimeout)
                  throws SQLException
```
    Execute a unique clientPrepareQuery.
    
    指定者:
    
    executeQuery 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - was intended to be launched on master connection
    
    results - results
    
    clientPrepareResult - clientPrepareResult
    
    parameters - parameters
    
    queryTimeout - if timeout is set and must use max_statement_time
    
    抛出:
    
    SQLException - exception
  - executePreparedQuery
```
public void executePreparedQuery(boolean mustExecuteOnMaster,
                                 ServerPrepareResult serverPrepareResult,
                                 Results results,
                                 ParameterHolder[] parameters)
                          throws SQLException
```
    Execute a query that is already prepared.
    
    指定者:
    
    executePreparedQuery 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - must execute on master
    
    serverPrepareResult - prepare result
    
    results - execution result
    
    parameters - parameters
    
    抛出:
    
    SQLException - exception
  - executePreparedQuery
```
public ServerPrepareResult executePreparedQuery(int parameterCount,
                                                ParameterHolder[] parameters,
                                                ServerPrepareResult serverPrepareResult,
                                                Results results)
                                         throws SQLException
```
    Execute a query that is to be prepared on server in Oracle mode
    
    指定者:
    
    executePreparedQuery 在接口中 Protocol
    
    抛出:
    
    SQLException - exception
  - executeBatchClient
```
public boolean executeBatchClient(boolean mustExecuteOnMaster,
                                  Results results,
                                  ClientPrepareResult prepareResult,
                                  List<ParameterHolder[]> parametersList,
                                  boolean hasLongData)
                           throws SQLException
```
    Execute clientPrepareQuery batch.
    
    指定者:
    
    executeBatchClient 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - was intended to be launched on master connection
    
    results - results
    
    prepareResult - ClientPrepareResult
    
    parametersList - List of parameters
    
    hasLongData - has parameter with long data (stream)
    
    抛出:
    
    SQLException - exception
  - executeBatchStmt
```
public void executeBatchStmt(boolean mustExecuteOnMaster,
                             Results results,
                             List<String> queries)
                      throws SQLException
```
    Execute batch from Statement.executeBatch().
    
    指定者:
    
    executeBatchStmt 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster - was intended to be launched on master connection
    
    results - results
    
    queries - queries
    
    抛出:
    
    SQLException - if any exception occur
  - executeBatchServer
```
public ServerPrepareResult executeBatchServer(ServerPrepareResult serverPrepareResult,
                                              Results results,
                                              String sql,
                                              List<ParameterHolder[]> parametersList,
                                              boolean hasLongData)
                                       throws SQLException
```
    Execute Prepare if needed, and execute COM_STMT_EXECUTE queries in batch.
    
    指定者:
    
    executeBatchServer 在接口中 Protocol
    
    参数:
    
    serverPrepareResult - prepare result. can be null if not prepared.
    
    results - execution results
    
    sql - sql query if needed to be prepared
    
    parametersList - parameter list
    
    hasLongData - has long data (stream)
    
    返回:
    
    executed
    
    抛出:
    
    SQLException - if parameter error or connection error occur.
  - fetchRowViaCursor
```
public ColumnDefinition[] fetchRowViaCursor(int cursorId,
                                            int fetchSize,
                                            Results results)
                                     throws SQLException
```
    指定者:
    
    fetchRowViaCursor 在接口中 Protocol
    
    抛出:
    
    SQLException
  - fetchRowViaCursorForOracle
```
public ColumnDefinition[] fetchRowViaCursorForOracle(int cursorId,
                                                     int numRows,
                                                     byte offsetType,
                                                     int offset,
                                                     Results results)
                                              throws SQLException
```
    指定者:
    
    fetchRowViaCursorForOracle 在接口中 Protocol
    
    抛出:
    
    SQLException
  - executePreparedQueryArrayBinding
```
public void executePreparedQueryArrayBinding(boolean mustExecuteOnMaster,
                                             ServerPrepareResult serverPrepareResult,
                                             Results results,
                                             List<ParameterHolder[]> queryParameters,
                                             int queryParameterSize)
                                      throws SQLException
```
    Protocol processing mechanism when prepareExecute is not used
    
    指定者:
    
    executePreparedQueryArrayBinding 在接口中 Protocol
    
    参数:
    
    mustExecuteOnMaster -
    
    serverPrepareResult -
    
    results -
    
    queryParameters -
    
    queryParameterSize -
    
    抛出:
    
    SQLException
  - executePreparedQueryArrayBinding
```
public ServerPrepareResult executePreparedQueryArrayBinding(int parameterCount,
                                                            boolean mustExecuteOnMaster,
                                                            ServerPrepareResult serverPrepareResult,
                                                            Results results,
                                                            List<ParameterHolder[]> queryParameters,
                                                            int queryParamtersSize)
                                                     throws SQLException
```
    Protocol processing mechanism when prepareExecute is used.
    
    指定者:
    
    executePreparedQueryArrayBinding 在接口中 Protocol
    
    参数:
    
    parameterCount - is count of parameters.
    
    mustExecuteOnMaster -
    
    serverPrepareResult -
    
    results -
    
    queryParameters - is sublist of parameters list.
    
    queryParamtersSize -
    
    返回:
    
    抛出:
    
    SQLException
  - getLastPacketCostTime
```
public long getLastPacketCostTime()
                           throws SQLException
```
    指定者:
    
    getLastPacketCostTime 在接口中 Protocol
    
    抛出:
    
    SQLException
  - getNetworkStatisticsFlag
```
public boolean getNetworkStatisticsFlag()
```
    指定者:
    
    getNetworkStatisticsFlag 在接口中 Protocol
  - setNetworkStatisticsFlag
```
public void setNetworkStatisticsFlag(boolean flag)
```
    指定者:
    
    setNetworkStatisticsFlag 在接口中 Protocol
  - getLastPacketResponseTimestamp
```
public long getLastPacketResponseTimestamp()
```
    指定者:
    
    getLastPacketResponseTimestamp 在接口中 Protocol
  - getLastPacketSendTimestamp
```
public long getLastPacketSendTimestamp()
```
    指定者:
    
    getLastPacketSendTimestamp 在接口中 Protocol
  - clearNetworkStatistics
```
public void clearNetworkStatistics()
```
    指定者:
    
    clearNetworkStatistics 在接口中 Protocol
  - changeUser
```
public void changeUser(String user,
                       String pwd)
                throws SQLException
```
    指定者:
    
    changeUser 在接口中 Protocol
    
    抛出:
    
    SQLException
  - rollback
```
public void rollback()
              throws SQLException
```
    Rollback transaction.
    
    指定者:
    
    rollback 在接口中 Protocol
    
    抛出:
    
    SQLException
  - setUsername
```
public void setUsername(String username)
```
    指定者:
    
    setUsername 在接口中 Protocol
  - forceReleasePrepareStatement
```
public boolean forceReleasePrepareStatement(int statementId)
                                     throws SQLException
```
    Force release of prepare statement that are not used. This method will be call when adding a new prepare statement in cache, so the packet can be send to server without problem.
    
    指定者:
    
    forceReleasePrepareStatement 在接口中 Protocol
    
    参数:
    
    statementId - prepared statement Id to remove.
    
    返回:
    
    true if successfully released
    
    抛出:
    
    SQLException - if connection exception.
  - ping
```
public boolean ping()
             throws SQLException
```
    指定者:
    
    ping 在接口中 Protocol
    
    抛出:
    
    SQLException
  - isValid
```
public boolean isValid(int timeout)
                throws SQLException
```
    Check that connection is valid. !! careful, timeout is in milliseconds, connection.isValid(timeout) is in seconds !!
    
    指定者:
    
    isValid 在接口中 Protocol
    
    参数:
    
    timeout - timeout in milliseconds
    
    返回:
    
    true is valid
    
    抛出:
    
    SQLException - if any error occur
  - getCatalog
```
public String getCatalog()
                  throws SQLException
```
    指定者:
    
    getCatalog 在接口中 Protocol
    
    抛出:
    
    SQLException
  - setCatalog
```
public void setCatalog(String database)
                throws SQLException
```
    指定者:
    
    setCatalog 在接口中 Protocol
    
    抛出:
    
    SQLException
  - resetDatabase
```
public void resetDatabase()
                   throws SQLException
```
    指定者:
    
    resetDatabase 在接口中 Protocol
    
    抛出:
    
    SQLException
  - cancelCurrentQuery
```
public void cancelCurrentQuery()
                        throws SQLException
```
    Cancels the current query - clones the current protocol and executes a query using the new connection.
    
    指定者:
    
    cancelCurrentQuery 在接口中 Protocol
    
    抛出:
    
    SQLException - never thrown
  - getAutocommit
```
public boolean getAutocommit()
```
    Get current autocommit status.
    
    指定者:
    
    getAutocommit 在接口中 Protocol
    
    返回:
    
    autocommit status
  - setAutoCommit
```
public void setAutoCommit(boolean autoCommit)
                   throws SQLException
```
    指定者:
    
    setAutoCommit 在接口中 Protocol
    
    抛出:
    
    SQLException
  - inTransaction
```
public boolean inTransaction()
```
    指定者:
    
    inTransaction 在接口中 Protocol
  - closeExplicit
```
public void closeExplicit()
```
    指定者:
    
    closeExplicit 在接口中 Protocol
  - releasePrepareStatement
```
public void releasePrepareStatement(ServerPrepareResult serverPrepareResult)
                             throws SQLException
```
    Deallocate prepare statement if not used anymore.
    
    指定者:
    
    releasePrepareStatement 在接口中 Protocol
    
    参数:
    
    serverPrepareResult - allocation result
    
    抛出:
    
    SQLException - if de-allocation failed.
  - getMaxRows
```
public long getMaxRows()
```
    指定者:
    
    getMaxRows 在接口中 Protocol
  - setMaxRows
```
public void setMaxRows(long max)
                throws SQLException
```
    指定者:
    
    setMaxRows 在接口中 Protocol
    
    抛出:
    
    SQLException
  - setLocalInfileInputStream
```
public void setLocalInfileInputStream(InputStream inputStream)
```
    指定者:
    
    setLocalInfileInputStream 在接口中 Protocol
  - getTimeout
```
public int getTimeout()
```
    Returns the connection timeout in milliseconds.
    
    指定者:
    
    getTimeout 在接口中 Protocol
    
    返回:
    
    the connection timeout in milliseconds.
  - setTimeout
```
public void setTimeout(int timeout)
                throws SocketException
```
    Sets the connection timeout.
    
    指定者:
    
    setTimeout 在接口中 Protocol
    
    参数:
    
    timeout - the timeout, in milliseconds
    
    抛出:
    
    SocketException - if there is an error in the underlying protocol, such as a TCP error.
  - setReadonly
```
public void setReadonly(boolean readOnly)
                 throws SQLException
```
    Puts this connection in read-only / read-write mode
    
    指定者:
    
    setReadonly 在接口中 Protocol
    
    参数:
    
    readOnly - true enables read-only mode; false disables it
    
    抛出:
    
    SQLException - If socket error.
  - setTransactionIsolation
```
public void setTransactionIsolation(int level)
                             throws SQLException
```
    Set transaction isolation.
    
    指定者:
    
    setTransactionIsolation 在接口中 Protocol
    
    参数:
    
    level - transaction level.
    
    抛出:
    
    SQLException - if transaction level is unknown
  - getTransactionIsolationLevel
```
public int getTransactionIsolationLevel()
```
    指定者:
    
    getTransactionIsolationLevel 在接口中 Protocol
  - getResult
```
public void getResult(Results results)
               throws SQLException
```
    指定者:
    
    getResult 在接口中 Protocol
    
    抛出:
    
    SQLException
  - getResultWithoutValue
```
public ColumnDefinition[] getResultWithoutValue(Results results)
                                         throws SQLException
```
    抛出:
    
    SQLException
  - getAutoIncrementIncrement
```
public int getAutoIncrementIncrement()
                              throws SQLException
```
    Get current auto increment increment. *** no lock needed ****
    
    指定者:
    
    getAutoIncrementIncrement 在接口中 Protocol
    
    返回:
    
    auto increment increment.
    
    抛出:
    
    SQLException - if cannot retrieve auto increment value
  - readOkPacket
```
public void readOkPacket(Buffer buffer,
                         Results results)
```
    Read OK_Packet.
    
    指定者:
    
    readOkPacket 在接口中 Protocol
    
    参数:
    
    buffer - current buffer
    
    results - result object
    
    另请参阅:
    
    OK_Packet
  - readErrorPacket
```
public SQLException readErrorPacket(Buffer buffer,
                                    Results results)
```
    Read ERR_Packet.
    
    指定者:
    
    readErrorPacket 在接口中 Protocol
    
    参数:
    
    buffer - current buffer
    
    results - result object
    
    返回:
    
    SQLException if sub-result connection fail
    
    另请参阅:
    
    ERR_Packet
  - readResultSet
```
public void readResultSet(ColumnDefinition[] ci,
                          Results results)
                   throws SQLException
```
    Read ResultSet Packet.
    
    指定者:
    
    readResultSet 在接口中 Protocol
    
    参数:
    
    results - result object
    
    抛出:
    
    SQLException - if sub-result connection fail
    
    另请参阅:
    
    resultSet packets
  - prologProxy
```
public void prologProxy(ServerPrepareResult serverPrepareResult,
                        long maxRows,
                        boolean hasProxy,
                        OceanBaseConnection connection,
                        OceanBaseStatement statement)
                 throws SQLException
```
    指定者:
    
    prologProxy 在接口中 Protocol
    
    抛出:
    
    SQLException
  - prolog
```
public void prolog(long maxRows,
                   boolean hasProxy,
                   OceanBaseConnection connection,
                   OceanBaseStatement statement)
            throws SQLException
```
    Preparation before command.
    
    指定者:
    
    prolog 在接口中 Protocol
    
    参数:
    
    maxRows - query max rows
    
    hasProxy - has proxy
    
    connection - current connection
    
    statement - current statement
    
    抛出:
    
    SQLException - if any error occur.
  - addPrepareInCache
```
public ServerPrepareResult addPrepareInCache(String key,
                                             ServerPrepareResult serverPrepareResult)
```
    指定者:
    
    addPrepareInCache 在接口中 Protocol
  - resetStateAfterFailover
```
public void resetStateAfterFailover(long maxRows,
                                    int transactionIsolationLevel,
                                    String database,
                                    boolean autocommit)
                             throws SQLException
```
    Set current state after a failover.
    
    指定者:
    
    resetStateAfterFailover 在接口中 Protocol
    
    参数:
    
    maxRows - current Max rows
    
    transactionIsolationLevel - current transactionIsolationLevel
    
    database - current database
    
    autocommit - current autocommit state
    
    抛出:
    
    SQLException - if any error occur.
  - handleIoException
```
public SQLException handleIoException(Exception initialException)
```
    Handle IoException (reconnect if Exception is due to having send too much data, making server close the connection.
    There is 3 kind of IOException :
    1. MaxAllowedPacketException : without need of reconnect : thrown when driver don't send packet that would have been too big then error is not a CONNECTION_EXCEPTION
    2. packets size is greater than max_allowed_packet (can be checked with writer.isAllowedCmdLength()). Need to reconnect
    3. unknown IO error throw a CONNECTION_EXCEPTION
    指定者:
    
    handleIoException 在接口中 Protocol
    
    参数:
    
    initialException - initial Io error
    
    返回:
    
    the resulting error to return to client.
  - setActiveFutureTask
```
public void setActiveFutureTask(FutureTask activeFutureTask)
```
    指定者:
    
    setActiveFutureTask 在接口中 Protocol
  - interrupt
```
public void interrupt()
```
    指定者:
    
    interrupt 在接口中 Protocol
  - isInterrupted
```
public boolean isInterrupted()
```
    指定者:
    
    isInterrupted 在接口中 Protocol
  - stopIfInterrupted
```
public void stopIfInterrupted()
                       throws SQLTimeoutException
```
    Throw TimeoutException if timeout has been reached.
    
    指定者:
    
    stopIfInterrupted 在接口中 Protocol
    
    抛出:
    
    SQLTimeoutException - to indicate timeout exception.
  - getChecksum
```
public long getChecksum()
```
    指定者:
    
    getChecksum 在接口中 Protocol
  - setChecksum
```
public void setChecksum(long checksum)
```
    指定者:
    
    setChecksum 在接口中 Protocol
  - resetChecksum
```
public void resetChecksum()
```
    指定者:
    
    resetChecksum 在接口中 Protocol
  - getIterationCount
```
public int getIterationCount()
```
    指定者:
    
    getIterationCount 在接口中 Protocol
  - setIterationCount
```
public void setIterationCount(int iterationCount)
```
    指定者:
    
    setIterationCount 在接口中 Protocol
  - getExecuteMode
```
public int getExecuteMode()
```
    指定者:
    
    getExecuteMode 在接口中 Protocol
  - setExecuteMode
```
public void setExecuteMode(int executeMode)
```
    指定者:
    
    setExecuteMode 在接口中 Protocol
  - setComStmtPrepareExecuteField
```
public void setComStmtPrepareExecuteField(int iterationCount,
                                          int executeMode,
                                          long checksum)
```
    指定者:
    
    setComStmtPrepareExecuteField 在接口中 Protocol

类 AbstractQueryProtocol

字段概要

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

方法概要

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

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

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

字段详细资料

lockLogger

方法详细资料

reset

prepare

executeQuery

executeQuery

executeQuery

executeQuery

executeQuery

executePreparedQuery

executePreparedQuery

executeBatchClient

executeBatchStmt

executeBatchServer

fetchRowViaCursor

fetchRowViaCursorForOracle

executePreparedQueryArrayBinding

executePreparedQueryArrayBinding

getLastPacketCostTime

getNetworkStatisticsFlag

setNetworkStatisticsFlag

getLastPacketResponseTimestamp

getLastPacketSendTimestamp

clearNetworkStatistics

changeUser

rollback

setUsername

forceReleasePrepareStatement

ping

isValid

getCatalog

setCatalog

resetDatabase

cancelCurrentQuery

getAutocommit

setAutoCommit

inTransaction

closeExplicit

releasePrepareStatement

getMaxRows

setMaxRows

setLocalInfileInputStream

getTimeout

setTimeout

setReadonly

setTransactionIsolation

getTransactionIsolationLevel

getResult

getResultWithoutValue

getAutoIncrementIncrement

readOkPacket

readErrorPacket

readResultSet

prologProxy

prolog

addPrepareInCache

resetStateAfterFailover

handleIoException

setActiveFutureTask

interrupt

isInterrupted

stopIfInterrupted

getChecksum

setChecksum

resetChecksum

getIterationCount

setIterationCount

getExecuteMode

setExecuteMode

setComStmtPrepareExecuteField