com.oceanbase.jdbc.internal.io.input

类 Ob20PacketInputStream

java.lang.Object

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

com.oceanbase.jdbc.internal.io.input.StandardPacketInputStream

com.oceanbase.jdbc.internal.io.input.Ob20PacketInputStream

所有已实现的接口:

PacketInputStream

public class Ob20PacketInputStream
extends StandardPacketInputStream

字段概要

从类继承的字段 com.oceanbase.jdbc.internal.io.input.StandardPacketInputStream

lastPacketLength, mysqlHeader

从类继承的字段 com.oceanbase.jdbc.internal.io.input.AbstractPacketInputStream

enableNetworkStatistics, inputStream, MAX_PACKET_SIZE, maxQuerySizeToLog, mysqlSeqNo, REUSABLE_BUFFER_LENGTH, reusableArray, serverThreadLog, threadId, timestampAfterRead, timeTrace, traceCache

构造器概要

构造器

构造器和说明
Ob20PacketInputStream(InputStream in, long threadId, Options options, OceanBaseProtocolV20 ob20, TimeTrace timeTrace)

方法概要

限定符和类型	方法和说明
protected void	doTrace(int offset, int length, byte[] rawBytes)
Buffer	getPacket(boolean reUsable)
byte[]	getPacketArray(boolean reUsable) Get next packet.
protected void	readMysqlStream(byte[] rawBytes, int off, int remaining)

从类继承的方法 com.oceanbase.jdbc.internal.io.input.StandardPacketInputStream

create, create, getCompressLastPacketSeq, getInputStream, getLogger

从类继承的方法 com.oceanbase.jdbc.internal.io.input.AbstractPacketInputStream

clearNetworkStatistics, close, enableNetworkStatistics, endReceiveResponse, getLastPacketSeq, getTimestampAfterRead, setServerThreadId, setTraceCache, startReceiveResponse

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

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

构造器详细资料

Ob20PacketInputStream

public Ob20PacketInputStream(InputStream in,
                             long threadId,
                             Options options,
                             OceanBaseProtocolV20 ob20,
                             TimeTrace timeTrace)

方法详细资料

getPacket

public Buffer getPacket(boolean reUsable)
                 throws IOException

指定者:

getPacket 在接口中 PacketInputStream

覆盖:

getPacket 在类中 StandardPacketInputStream

抛出:

IOException

getPacketArray

public byte[] getPacketArray(boolean reUsable)
                      throws IOException

从类复制的说明: StandardPacketInputStream

Get next packet. If packet is more than 16M, read as many packet needed to finish packet. (first that has not length = 16Mb)

指定者:

getPacketArray 在接口中 PacketInputStream

覆盖:

getPacketArray 在类中 StandardPacketInputStream

参数:

reUsable - if can use existing reusable buffer to avoid creating array

返回:

array packet.

抛出:

IOException - if socket exception occur.

readMysqlStream

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

覆盖:

readMysqlStream 在类中 StandardPacketInputStream

抛出:

IOException

doTrace

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

覆盖:

doTrace 在类中 StandardPacketInputStream