public class StandardPacketInputStream extends java.lang.Object implements PacketInputStream
Modifier and Type | Field and Description |
---|---|
private byte[] |
header |
private java.io.InputStream |
inputStream |
private int |
lastPacketLength |
private static Logger |
logger |
private static int |
MAX_PACKET_SIZE |
private int |
maxQuerySizeToLog |
private int |
packetSeq |
private static int |
REUSABLE_BUFFER_LENGTH |
private byte[] |
reusableArray |
private java.lang.String |
serverThreadLog |
private LruTraceCache |
traceCache |
Constructor and Description |
---|
StandardPacketInputStream(java.io.InputStream in,
Options options)
Constructor of standard socket MySQL packet stream reader.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
static byte[] |
create(byte[] value)
Constructor for single Data (using text format).
|
static byte[] |
create(byte[][] rowDatas,
ColumnType[] columnTypes)
Create Buffer with Text protocol values.
|
int |
getCompressLastPacketSeq() |
java.io.InputStream |
getInputStream()
Get current input stream for creating compress input stream, to avoid losing already
read bytes in case of pipelining.
|
int |
getLastPacketSeq() |
Buffer |
getPacket(boolean reUsable) |
byte[] |
getPacketArray(boolean reUsable)
Get next packet.
|
void |
setServerThreadId(long serverThreadId,
java.lang.Boolean isMaster)
Set server thread id.
|
void |
setTraceCache(LruTraceCache traceCache) |
private static final int REUSABLE_BUFFER_LENGTH
private static final int MAX_PACKET_SIZE
private static final Logger logger
private final byte[] header
private final byte[] reusableArray
private final java.io.InputStream inputStream
private final int maxQuerySizeToLog
private int packetSeq
private int lastPacketLength
private java.lang.String serverThreadLog
private LruTraceCache traceCache
public StandardPacketInputStream(java.io.InputStream in, Options options)
in
- streamoptions
- connection optionspublic static byte[] create(byte[] value)
value
- valuepublic static byte[] create(byte[][] rowDatas, ColumnType[] columnTypes)
rowDatas
- datascolumnTypes
- column typespublic Buffer getPacket(boolean reUsable) throws java.io.IOException
getPacket
in interface PacketInputStream
java.io.IOException
public java.io.InputStream getInputStream()
public byte[] getPacketArray(boolean reUsable) throws java.io.IOException
getPacketArray
in interface PacketInputStream
reUsable
- if can use existing reusable buffer to avoid creating arrayjava.io.IOException
- if socket exception occur.public int getLastPacketSeq()
getLastPacketSeq
in interface PacketInputStream
public int getCompressLastPacketSeq()
getCompressLastPacketSeq
in interface PacketInputStream
public void close() throws java.io.IOException
close
in interface PacketInputStream
java.io.IOException
public void setServerThreadId(long serverThreadId, java.lang.Boolean isMaster)
setServerThreadId
in interface PacketInputStream
serverThreadId
- current server thread id.isMaster
- is server masterpublic void setTraceCache(LruTraceCache traceCache)
setTraceCache
in interface PacketInputStream