com.oceanbase.jdbc.internal.io.output

类 Ob20PacketOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

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

com.oceanbase.jdbc.internal.io.output.Ob20PacketOutputStream

所有已实现的接口:

PacketOutputStream, Closeable, Flushable, AutoCloseable

public class Ob20PacketOutputStream
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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	flushBuffer(boolean commandEnd)
OceanBaseProtocolV20	getOb20()
int	initialPacketPos()
void	setMaxAllowedPacket(int maxAllowedPacket)
void	startPacket(int compressSeqNo)
void	writeEmptyPacket()

从类继承的方法 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

构造器详细资料

Ob20PacketOutputStream

public Ob20PacketOutputStream(OutputStream out,
                              long threadId,
                              Options options,
                              OceanBaseProtocolV20 ob20,
                              TimeTrace timeTrace)

方法详细资料

initialPacketPos

public int initialPacketPos()

startPacket

public void startPacket(int compressSeqNo)

指定者:

startPacket 在接口中 PacketOutputStream

指定者:

startPacket 在类中 AbstractPacketOutputStream

flushBuffer

protected void flushBuffer(boolean commandEnd)
                    throws IOException

指定者:

flushBuffer 在类中 AbstractPacketOutputStream

抛出:

IOException

writeEmptyPacket

public void writeEmptyPacket()
                      throws IOException

指定者:

writeEmptyPacket 在接口中 PacketOutputStream

指定者:

writeEmptyPacket 在类中 AbstractPacketOutputStream

抛出:

IOException

setMaxAllowedPacket

public void setMaxAllowedPacket(int maxAllowedPacket)

指定者:

setMaxAllowedPacket 在接口中 PacketOutputStream

指定者:

setMaxAllowedPacket 在类中 AbstractPacketOutputStream

getOb20

public OceanBaseProtocolV20 getOb20()