com.oceanbase.jdbc.internal.io.input

类 AbstractPacketInputStream

java.lang.Object

com.oceanbase.jdbc.internal.io.input.AbstractPacketInputStream

所有已实现的接口:

PacketInputStream

直接已知子类:

DecompressPacketInputStream, StandardPacketInputStream

public abstract class AbstractPacketInputStream
extends Object
implements PacketInputStream

字段概要

字段

限定符和类型	字段和说明
protected boolean	enableNetworkStatistics
protected InputStream	inputStream
protected static int	MAX_PACKET_SIZE
protected int	maxQuerySizeToLog
protected int	mysqlSeqNo
protected static int	REUSABLE_BUFFER_LENGTH
protected byte[]	reusableArray
protected String	serverThreadLog
protected long	threadId
protected long	timestampAfterRead
protected TimeTrace	timeTrace
protected LruTraceCache	traceCache

构造器概要

构造器

构造器和说明
AbstractPacketInputStream()

方法概要

限定符和类型	方法和说明
void	clearNetworkStatistics()
void	close()
protected abstract void	doTrace(int offset, int length, byte[] rawBytes)
void	enableNetworkStatistics(boolean flag)
void	endReceiveResponse(String sql)
abstract int	getCompressLastPacketSeq()
int	getLastPacketSeq()
abstract Buffer	getPacket(boolean reUsable)
abstract byte[]	getPacketArray(boolean reUsable)
long	getTimestampAfterRead()
protected abstract void	readMysqlStream(byte[] rawBytes, int off, int remaining)
void	setServerThreadId(long serverThreadId, Boolean isMaster) Set server thread id.
void	setTraceCache(LruTraceCache traceCache)
void	startReceiveResponse()

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

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

从接口继承的方法 com.oceanbase.jdbc.internal.io.input.PacketInputStream

getLogger

字段详细资料

inputStream

protected InputStream inputStream

threadId

protected long threadId

mysqlSeqNo

protected int mysqlSeqNo

traceCache

protected LruTraceCache traceCache

serverThreadLog

protected String serverThreadLog

maxQuerySizeToLog

protected int maxQuerySizeToLog

enableNetworkStatistics

protected boolean enableNetworkStatistics

timestampAfterRead

protected long timestampAfterRead

REUSABLE_BUFFER_LENGTH

protected static final int REUSABLE_BUFFER_LENGTH

另请参阅:

常量字段值

MAX_PACKET_SIZE

protected static final int MAX_PACKET_SIZE

另请参阅:

常量字段值

reusableArray

protected final byte[] reusableArray

timeTrace

protected TimeTrace timeTrace

构造器详细资料

AbstractPacketInputStream

public AbstractPacketInputStream()

方法详细资料

getPacket

public abstract Buffer getPacket(boolean reUsable)
                          throws IOException

指定者:

getPacket 在接口中 PacketInputStream

抛出:

IOException

getPacketArray

public abstract byte[] getPacketArray(boolean reUsable)
                               throws IOException

指定者:

getPacketArray 在接口中 PacketInputStream

抛出:

IOException

readMysqlStream

protected abstract void readMysqlStream(byte[] rawBytes,
                                        int off,
                                        int remaining)
                                 throws IOException

抛出:

IOException

doTrace

protected abstract void doTrace(int offset,
                                int length,
                                byte[] rawBytes)

getLastPacketSeq

public int getLastPacketSeq()

指定者:

getLastPacketSeq 在接口中 PacketInputStream

getCompressLastPacketSeq

public abstract int getCompressLastPacketSeq()

指定者:

getCompressLastPacketSeq 在接口中 PacketInputStream

close

public void close()
           throws IOException

指定者:

close 在接口中 PacketInputStream

抛出:

IOException

setServerThreadId

public void setServerThreadId(long serverThreadId,
                              Boolean isMaster)

Set server thread id.

指定者:

setServerThreadId 在接口中 PacketInputStream

参数:

serverThreadId - current server thread id.

isMaster - is server master

setTraceCache

public void setTraceCache(LruTraceCache traceCache)

指定者:

setTraceCache 在接口中 PacketInputStream

enableNetworkStatistics

public void enableNetworkStatistics(boolean flag)

指定者:

enableNetworkStatistics 在接口中 PacketInputStream

getTimestampAfterRead

public long getTimestampAfterRead()

指定者:

getTimestampAfterRead 在接口中 PacketInputStream

clearNetworkStatistics

public void clearNetworkStatistics()

指定者:

clearNetworkStatistics 在接口中 PacketInputStream

startReceiveResponse

public void startReceiveResponse()

指定者:

startReceiveResponse 在接口中 PacketInputStream

endReceiveResponse

public void endReceiveResponse(String sql)

指定者:

endReceiveResponse 在接口中 PacketInputStream