com.oceanbase.jdbc.internal.io.input

类 DecompressPacketInputStream

java.lang.Object

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

com.oceanbase.jdbc.internal.io.input.DecompressPacketInputStream

所有已实现的接口:

PacketInputStream

public class DecompressPacketInputStream
extends AbstractPacketInputStream

字段概要

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

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	doTrace(int offset, int length, byte[] rawBytes)
int	getCompressLastPacketSeq()
Logger	getLogger()
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.AbstractPacketInputStream

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

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

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

构造器详细资料

DecompressPacketInputStream

public DecompressPacketInputStream(InputStream in,
                                   long threadId,
                                   Options options,
                                   TimeTrace timeTrace)

方法详细资料

getPacket

public Buffer getPacket(boolean reUsable)
                 throws IOException

指定者:

getPacket 在接口中 PacketInputStream

指定者:

getPacket 在类中 AbstractPacketInputStream

抛出:

IOException

getPacketArray

public byte[] getPacketArray(boolean reUsable)
                      throws IOException

Get next packet. Packet can be compressed, and if so, can contain many standard packet.

指定者:

getPacketArray 在接口中 PacketInputStream

指定者:

getPacketArray 在类中 AbstractPacketInputStream

参数:

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 在类中 AbstractPacketInputStream

抛出:

IOException

doTrace

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

指定者:

doTrace 在类中 AbstractPacketInputStream

getCompressLastPacketSeq

public int getCompressLastPacketSeq()

指定者:

getCompressLastPacketSeq 在接口中 PacketInputStream

指定者:

getCompressLastPacketSeq 在类中 AbstractPacketInputStream

getLogger

public Logger getLogger()