com.oceanbase.jdbc.internal.io.input

类 StandardPacketInputStream

java.lang.Object

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

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

所有已实现的接口:

PacketInputStream

直接已知子类:

Ob20PacketInputStream

public class StandardPacketInputStream
extends AbstractPacketInputStream

字段概要

字段

限定符和类型	字段和说明
protected int	lastPacketLength
protected byte[]	mysqlHeader

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

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

构造器概要

构造器

构造器和说明
StandardPacketInputStream(InputStream in, long threadId, Options options, TimeTrace timeTrace) Constructor of standard socket MySQL packet stream reader.
StandardPacketInputStream(long threadId, Options options, TimeTrace timeTrace)

方法概要

限定符和类型	方法和说明
static byte[]	create(byte[] value) Constructor for single Data (using text format).
static byte[]	create(byte[][] row, ColumnType[] columnTypes) Create Buffer with Text protocol values.
protected void	doTrace(int offset, int length, byte[] rawBytes)
int	getCompressLastPacketSeq()
InputStream	getInputStream() Get current input stream for creating compress input stream, to avoid losing already read bytes in case of pipelining.
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

字段详细资料

mysqlHeader

protected byte[] mysqlHeader

lastPacketLength

protected int lastPacketLength

构造器详细资料

StandardPacketInputStream

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

Constructor of standard socket MySQL packet stream reader.

参数:

in - stream

options - connection options

threadId - thread id

StandardPacketInputStream

public StandardPacketInputStream(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. If packet is more than 16M, read as many packet needed to finish packet. (first that has not length = 16Mb)

指定者:

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

create

public static byte[] create(byte[] value)

Constructor for single Data (using text format).

参数:

value - value

返回:

Buffer

create

public static byte[] create(byte[][] row,
                            ColumnType[] columnTypes)

Create Buffer with Text protocol values.

参数:

row - row data

columnTypes - column types

返回:

Buffer

getInputStream

public InputStream getInputStream()

Get current input stream for creating compress input stream, to avoid losing already read bytes in case of pipelining.

返回:

input stream.

getLogger

public Logger getLogger()