Package org.mariadb.jdbc.client.socket
Interface Reader
-
- All Known Implementing Classes:
PacketReader
public interface Reader
Packet Reader
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
Close streamMutableByte
getSequence()
Get current sequence objectReadableByteBuf
readableBufFromArray(byte[] buf)
Get a readable byte array from byte array.byte[]
readPacket(boolean traceEnable)
Get next MySQL packet.ReadableByteBuf
readReusablePacket()
Get next MySQL packet.ReadableByteBuf
readReusablePacket(boolean traceEnable)
Get next MySQL packet.void
setServerThreadId(java.lang.Long serverThreadId, HostAddress hostAddress)
Set server thread id.void
skipPacket()
Skip next MySQL packet.
-
-
-
Method Detail
-
readReusablePacket
ReadableByteBuf readReusablePacket(boolean traceEnable) throws java.io.IOException
Get next MySQL packet. Packet is expected to have size < 16M and will use if possible an internal cached buffer. This packet bytes are expect to be read immediately- Parameters:
traceEnable
- must trace pacjet- Returns:
- Readable byte array packet.
- Throws:
java.io.IOException
- if socket exception occur.
-
readReusablePacket
ReadableByteBuf readReusablePacket() throws java.io.IOException
Get next MySQL packet. Packet is expected to have size < 16M and will use if possible an internal cached buffer. This packet bytes are expect to be read immediately- Returns:
- Readable byte array packet.
- Throws:
java.io.IOException
- if socket exception occur.
-
readPacket
byte[] readPacket(boolean traceEnable) throws java.io.IOException
Get next MySQL packet. If packet is more than 16M, read as many packet needed to finish reading MySQL packet. (first that has not length = 16Mb)- Parameters:
traceEnable
- must trace packet.- Returns:
- array packet.
- Throws:
java.io.IOException
- if socket exception occur.
-
readableBufFromArray
ReadableByteBuf readableBufFromArray(byte[] buf)
Get a readable byte array from byte array. This packet is expected to be read immediately, since no lock is set on this packet.- Parameters:
buf
- byte array to be parsed- Returns:
- array packet.
-
skipPacket
void skipPacket() throws java.io.IOException
Skip next MySQL packet. Packet is expected to have size < 16M- Throws:
java.io.IOException
- if socket exception occur.
-
getSequence
MutableByte getSequence()
Get current sequence object- Returns:
- current sequence
-
close
void close() throws java.io.IOException
Close stream- Throws:
java.io.IOException
- if any error occurs
-
setServerThreadId
void setServerThreadId(java.lang.Long serverThreadId, HostAddress hostAddress)
Set server thread id.- Parameters:
serverThreadId
- current server thread id.hostAddress
- host information
-
-