public class Buffer
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
(package private) static int |
MAX_BYTES_TO_DUMP |
(package private) static int |
NO_LENGTH_LIMIT |
(package private) static long |
NULL_LENGTH |
protected boolean |
wasMultiPacket |
Modifier and Type | Method and Description |
---|---|
(package private) void |
clear() |
(package private) void |
dump() |
(package private) java.lang.String |
dump(int numBytes) |
(package private) java.lang.String |
dumpClampedBytes(int numBytes) |
(package private) void |
dumpHeader() |
(package private) void |
dumpNBytes(int start,
int nBytes) |
(package private) void |
ensureCapacity(int additionalData) |
void |
fastSkipLenByteArray() |
int |
fastSkipLenString()
Skip over a length-encoded string
|
protected byte[] |
getBufferSource() |
int |
getBufLength() |
byte[] |
getByteBuffer()
Returns the array of bytes this Buffer is using to read from.
|
(package private) byte[] |
getBytes(int len) |
(package private) byte[] |
getBytes(int offset,
int len) |
(package private) int |
getCapacity() |
java.nio.ByteBuffer |
getNioBuffer() |
int |
getPosition()
Returns the current position to write to/ read from
|
(package private) boolean |
isAuthMethodSwitchRequestPacket() |
(package private) boolean |
isLastDataPacket() |
(package private) boolean |
isOKPacket() |
(package private) boolean |
isRawPacket() |
(package private) long |
newReadLength() |
(package private) byte |
readByte() |
(package private) byte |
readByte(int readAt) |
(package private) long |
readFieldLength() |
(package private) int |
readInt() |
(package private) int |
readIntAsLong() |
(package private) byte[] |
readLenByteArray(int offset) |
(package private) long |
readLength() |
(package private) long |
readLong() |
(package private) int |
readLongInt() |
(package private) long |
readLongLong() |
(package private) int |
readnBytes() |
java.lang.String |
readString() |
(package private) java.lang.String |
readString(java.lang.String encoding,
ExceptionInterceptor exceptionInterceptor)
Read string[NUL]
|
(package private) java.lang.String |
readString(java.lang.String encoding,
ExceptionInterceptor exceptionInterceptor,
int expectedLength)
Read string[$len]
|
void |
setBufLength(int bufLengthToSet) |
void |
setByteBuffer(byte[] byteBufferToSet)
Sets the array of bytes to use as a buffer to read from.
|
void |
setPosition(int positionToSet)
Set the current position to write to/ read from
|
void |
setWasMultiPacket(boolean flag)
Sets whether this packet was part of a multipacket
|
java.lang.String |
toString() |
java.lang.String |
toSuperString() |
boolean |
wasMultiPacket()
Was this packet part of a multipacket?
|
void |
writeByte(byte b) |
void |
writeBytesNoNull(byte[] bytes) |
(package private) void |
writeBytesNoNull(byte[] bytes,
int offset,
int length) |
(package private) void |
writeDouble(double d) |
(package private) void |
writeFieldLength(long length) |
(package private) void |
writeFloat(float f) |
(package private) void |
writeInt(int i) |
(package private) void |
writeLenBytes(byte[] b) |
(package private) void |
writeLenString(java.lang.String s,
java.lang.String encoding,
java.lang.String serverEncoding,
SingleByteCharsetConverter converter,
boolean parserKnowsUnicode,
MySQLConnection conn) |
(package private) void |
writeLong(long i) |
(package private) void |
writeLongInt(int i) |
(package private) void |
writeLongLong(long i) |
(package private) void |
writeString(java.lang.String s) |
(package private) void |
writeString(java.lang.String s,
java.lang.String encoding,
MySQLConnection conn) |
(package private) void |
writeStringNoNull(java.lang.String s) |
(package private) void |
writeStringNoNull(java.lang.String s,
java.lang.String encoding,
java.lang.String serverEncoding,
boolean parserKnowsUnicode,
MySQLConnection conn) |
static final int MAX_BYTES_TO_DUMP
static final int NO_LENGTH_LIMIT
static final long NULL_LENGTH
protected boolean wasMultiPacket
final void clear()
final void dump()
final java.lang.String dump(int numBytes)
final java.lang.String dumpClampedBytes(int numBytes)
final void dumpHeader()
final void dumpNBytes(int start, int nBytes)
final void ensureCapacity(int additionalData) throws java.sql.SQLException
java.sql.SQLException
public int fastSkipLenString()
public void fastSkipLenByteArray()
protected final byte[] getBufferSource()
public int getBufLength()
public byte[] getByteBuffer()
final byte[] getBytes(int len)
byte[] getBytes(int offset, int len)
int getCapacity()
public java.nio.ByteBuffer getNioBuffer()
public int getPosition()
final boolean isLastDataPacket()
final boolean isAuthMethodSwitchRequestPacket()
final boolean isOKPacket()
final boolean isRawPacket()
final long newReadLength()
final byte readByte()
final byte readByte(int readAt)
final long readFieldLength()
final int readInt()
final int readIntAsLong()
final byte[] readLenByteArray(int offset)
final long readLength()
final long readLong()
final int readLongInt()
final long readLongLong()
final int readnBytes()
public final java.lang.String readString()
final java.lang.String readString(java.lang.String encoding, ExceptionInterceptor exceptionInterceptor) throws java.sql.SQLException
encoding
- exceptionInterceptor
- java.sql.SQLException
final java.lang.String readString(java.lang.String encoding, ExceptionInterceptor exceptionInterceptor, int expectedLength) throws java.sql.SQLException
java.sql.SQLException
public void setBufLength(int bufLengthToSet)
public void setByteBuffer(byte[] byteBufferToSet)
byteBuffer
- the array of bytes to use as a bufferpublic void setPosition(int positionToSet)
position
- the position (0-based index)public void setWasMultiPacket(boolean flag)
flag
- was this packet part of a multipacket?public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toSuperString()
public boolean wasMultiPacket()
public final void writeByte(byte b) throws java.sql.SQLException
java.sql.SQLException
public final void writeBytesNoNull(byte[] bytes) throws java.sql.SQLException
java.sql.SQLException
final void writeBytesNoNull(byte[] bytes, int offset, int length) throws java.sql.SQLException
java.sql.SQLException
final void writeDouble(double d) throws java.sql.SQLException
java.sql.SQLException
final void writeFieldLength(long length) throws java.sql.SQLException
java.sql.SQLException
final void writeFloat(float f) throws java.sql.SQLException
java.sql.SQLException
final void writeInt(int i) throws java.sql.SQLException
java.sql.SQLException
final void writeLenBytes(byte[] b) throws java.sql.SQLException
java.sql.SQLException
final void writeLenString(java.lang.String s, java.lang.String encoding, java.lang.String serverEncoding, SingleByteCharsetConverter converter, boolean parserKnowsUnicode, MySQLConnection conn) throws java.io.UnsupportedEncodingException, java.sql.SQLException
java.io.UnsupportedEncodingException
java.sql.SQLException
final void writeLong(long i) throws java.sql.SQLException
java.sql.SQLException
final void writeLongInt(int i) throws java.sql.SQLException
java.sql.SQLException
final void writeLongLong(long i) throws java.sql.SQLException
java.sql.SQLException
final void writeString(java.lang.String s) throws java.sql.SQLException
java.sql.SQLException
final void writeString(java.lang.String s, java.lang.String encoding, MySQLConnection conn) throws java.sql.SQLException
java.sql.SQLException
final void writeStringNoNull(java.lang.String s) throws java.sql.SQLException
java.sql.SQLException
final void writeStringNoNull(java.lang.String s, java.lang.String encoding, java.lang.String serverEncoding, boolean parserKnowsUnicode, MySQLConnection conn) throws java.io.UnsupportedEncodingException, java.sql.SQLException
java.io.UnsupportedEncodingException
java.sql.SQLException