com.oceanbase.jdbc.internal.io.output

类 CompressPacketOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

com.oceanbase.jdbc.internal.io.output.AbstractPacketOutputStream

com.oceanbase.jdbc.internal.io.output.CompressPacketOutputStream

所有已实现的接口:

PacketOutputStream, Closeable, Flushable, AutoCloseable

public class CompressPacketOutputStream
extends AbstractPacketOutputStream

字段概要

从类继承的字段 com.oceanbase.jdbc.internal.io.output.AbstractPacketOutputStream

buf, charset, cmdLength, enableNetworkStatistics, maxAllowedPacket, maxPacketLength, maxQuerySizeToLog, mysqlSeqNo, permitTrace, pos, serverThreadLog, threadId, timestampBeforeFlush, traceCache

从类继承的字段 java.io.FilterOutputStream

out

构造器概要

构造器

构造器和说明
CompressPacketOutputStream(OutputStream out, long threadId, Options options, TimeTrace timeTrace)

方法概要

限定符和类型	方法和说明
protected void	flushBuffer(boolean commandEnd) Flush the internal buffer.
int	initialPacketPos()
void	setMaxAllowedPacket(int maxAllowedPacket)
void	startPacket(int compressSeqNo)
void	writeEmptyPacket() Write an empty packet.

从类继承的方法 com.oceanbase.jdbc.internal.io.output.AbstractPacketOutputStream

bufferIsDataAfterMark, checkMaxAllowedLength, checkRemainingSize, clearNetworkStatistics, doFlush, enableNetworkStatistics, endSendRequest, exceedMaxLength, flush, flushBufferStopAtMark, flushLoadDataLocalFile, getCharset, getMaxAllowedPacket, getMaxPacketLength, getOutputStream, getPosition, getTimestampBeforeFlush, getTimeZone, isEncloseParamInParentheses, isMarked, isOracleMode, mark, permitTrace, resetMark, setOracleMode, setPosition, setServerThreadId, setTimeZone, setTraceCache, startSendRequest, write, write, write, write, write, write, write, write, write, writeBytes, writeBytesEscaped, writeBytesEscapedQuote, writeEmptyPacket, writeEscapeQuote, writeEscapeQuote, writeFieldLength, writeFloatV1, writeHex, writeHex, writeInt, writeIntV1, writeLong, writeLongV1, writeShort

从类继承的方法 java.io.FilterOutputStream

close

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

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

从接口继承的方法 com.oceanbase.jdbc.internal.io.output.PacketOutputStream

close

构造器详细资料

CompressPacketOutputStream

public CompressPacketOutputStream(OutputStream out,
                                  long threadId,
                                  Options options,
                                  TimeTrace timeTrace)

方法详细资料

setMaxAllowedPacket

public void setMaxAllowedPacket(int maxAllowedPacket)

指定者:

setMaxAllowedPacket 在接口中 PacketOutputStream

指定者:

setMaxAllowedPacket 在类中 AbstractPacketOutputStream

startPacket

public void startPacket(int compressSeqNo)

指定者:

startPacket 在接口中 PacketOutputStream

指定者:

startPacket 在类中 AbstractPacketOutputStream

initialPacketPos

public int initialPacketPos()

flushBuffer

protected void flushBuffer(boolean commandEnd)
                    throws IOException

Flush the internal buffer.

Compression add a 7 header :

1. 3 byte compression length
2. 1 byte compress sequence number
3. 3 bytes uncompress length

in case packet isn't compressed (last 3 bytes == 0):

1. 3 byte uncompress length
2. 1 byte compress sequence number
3. 3 bytes with 0 value

Content correspond to standard content.

1. 3 byte length
2. 1 byte sequence number (!= than compress sequence number)
3. sub-content

Problem is when standard content is bigger than 16mb : content will not send 4byte standard header + 16mb content, since packet are limited to 16mb then 4 bytes standard header + 16mb - 4 bytes content. the ending 4 bytes are waiting to be send. next packet will then send the waiting data before next packet, putting more waiting data is needed. if ending data is exactly MAX_PACKET_LENGTH length, then an empty packet must be send.

指定者:

flushBuffer 在类中 AbstractPacketOutputStream

参数:

commandEnd - command end

抛出:

IOException - id connection error occur.

writeEmptyPacket

public void writeEmptyPacket()
                      throws IOException

Write an empty packet.

指定者:

writeEmptyPacket 在接口中 PacketOutputStream

指定者:

writeEmptyPacket 在类中 AbstractPacketOutputStream

抛出:

IOException - if socket error occur.