Class StandardPacketOutputStream
java.lang.Object
java.io.OutputStream
java.io.FilterOutputStream
org.mariadb.jdbc.internal.io.output.AbstractPacketOutputStream
org.mariadb.jdbc.internal.io.output.StandardPacketOutputStream
- All Implemented Interfaces:
Closeable,Flushable,AutoCloseable,PacketOutputStream
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final Loggerprivate static final intprivate intFields inherited from class org.mariadb.jdbc.internal.io.output.AbstractPacketOutputStream
buf, cmdLength, maxAllowedPacket, maxQuerySizeToLog, permitTrace, pos, seqNo, serverThreadLog, traceCacheFields inherited from class java.io.FilterOutputStream
out -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidflushBuffer(boolean commandEnd) Flush the internal buffer.intintvoidsetMaxAllowedPacket(int maxAllowedPacket) voidstartPacket(int seqNo) voidWrite an empty com.Methods inherited from class org.mariadb.jdbc.internal.io.output.AbstractPacketOutputStream
bufferIsDataAfterMark, checkMaxAllowedLength, checkRemainingSize, exceedMaxLength, flush, flushBufferStopAtMark, getMaxAllowedPacket, getOutputStream, isMarked, mark, permitTrace, resetMark, setServerThreadId, setTraceCache, write, write, write, write, write, write, write, write, write, writeBytes, writeBytesEscaped, writeEmptyPacket, writeFieldLength, writeInt, writeLong, writeShortMethods inherited from class java.io.FilterOutputStream
closeMethods inherited from class java.io.OutputStream
nullOutputStreamMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.mariadb.jdbc.internal.io.output.PacketOutputStream
close
-
Field Details
-
logger
-
MAX_PACKET_LENGTH
private static final int MAX_PACKET_LENGTH- See Also:
-
maxPacketLength
private int maxPacketLength
-
-
Constructor Details
-
StandardPacketOutputStream
-
-
Method Details
-
getMaxPacketLength
public int getMaxPacketLength()- Specified by:
getMaxPacketLengthin classAbstractPacketOutputStream
-
startPacket
public void startPacket(int seqNo) - Specified by:
startPacketin interfacePacketOutputStream- Specified by:
startPacketin classAbstractPacketOutputStream
-
setMaxAllowedPacket
public void setMaxAllowedPacket(int maxAllowedPacket) - Specified by:
setMaxAllowedPacketin interfacePacketOutputStream- Specified by:
setMaxAllowedPacketin classAbstractPacketOutputStream
-
initialPacketPos
public int initialPacketPos() -
flushBuffer
Flush the internal buffer.- Specified by:
flushBufferin classAbstractPacketOutputStream- Parameters:
commandEnd- command end- Throws:
IOException- id connection error occur.
-
writeEmptyPacket
Write an empty com.- Specified by:
writeEmptyPacketin interfacePacketOutputStream- Specified by:
writeEmptyPacketin classAbstractPacketOutputStream- Throws:
IOException- if socket error occur.
-