Class Writer

java.lang.Object
org.mariadb.jdbc.client.socket.Writer
public class Writer extends Object
Packet writer

  • Field Details

    • SMALL_BUFFER_SIZE

      public static final int SMALL_BUFFER_SIZE
      initial buffer size
      See Also:

    • logger

      private static final Logger logger

    • QUOTE

      private static final byte QUOTE
      See Also:

    • DBL_QUOTE

      private static final byte DBL_QUOTE
      See Also:

    • ZERO_BYTE

      private static final byte ZERO_BYTE
      See Also:

    • BACKSLASH

      private static final byte BACKSLASH
      See Also:

    • MEDIUM_BUFFER_SIZE

      private static final int MEDIUM_BUFFER_SIZE
      See Also:

    • LARGE_BUFFER_SIZE

      private static final int LARGE_BUFFER_SIZE
      See Also:

    • MAX_PACKET_LENGTH

      private static final int MAX_PACKET_LENGTH
      See Also:

    • sequence

      protected final MutableByte sequence
      packet sequence

    • compressSequence

      protected final MutableByte compressSequence
      compressed packet sequence

    • maxQuerySizeToLog

      private final int maxQuerySizeToLog

    • out

      private final OutputStream out

    • maxPacketLength

      private final int maxPacketLength
      See Also:

    • maxAllowedPacket

      private Integer maxAllowedPacket

    • buf

      protected byte[] buf
      internal buffer

    • pos

      protected int pos
      buffer position

    • cmdLength

      private long cmdLength

    • permitTrace

      private boolean permitTrace

    • serverThreadLog

      private String serverThreadLog

    • mark

      private int mark

    • bufContainDataAfterMark

      private boolean bufContainDataAfterMark

  • Constructor Details

    • Writer

      public Writer(OutputStream out, int maxQuerySizeToLog, Integer maxAllowedPacket, MutableByte sequence, MutableByte compressSequence)
      Common feature to write data into socket, creating MariaDB Packet.
      Parameters:
      out - output stream
      maxQuerySizeToLog - maximum query size to log
      maxAllowedPacket - max allowed packet value if known
      sequence - packet sequence
      compressSequence - compressed packet sequence

  • Method Details

    • pos

      public int pos()
      get current position
      Returns:
      current position

    • pos

      public void pos(int pos) throws IOException
      position setter
      Parameters:
      pos - new position
      Throws:
      IOException - if buffer is not big enough to contains new position

    • getCmdLength

      public long getCmdLength()
      get current command length
      Returns:
      current command length

    • writeByte

      public void writeByte(int value) throws IOException
      Write byte into buf, flush buf to socket if needed.
      Parameters:
      value - byte to send
      Throws:
      IOException - if socket error occur.

    • writeShort

      public void writeShort(short value) throws IOException
      Write short value into buf. flush buf if too small.
      Parameters:
      value - short value
      Throws:
      IOException - if socket error occur

    • writeInt

      public void writeInt(int value) throws IOException
      Write int value into buf. flush buf if too small.
      Parameters:
      value - int value
      Throws:
      IOException - if socket error occur

    • writeLong

      public void writeLong(long value) throws IOException
      Write long value into buf. flush buf if too small.
      Parameters:
      value - long value
      Throws:
      IOException - if socket error occur

    • writeDouble

      public void writeDouble(double value) throws IOException
      Throws:
      IOException

    • writeFloat

      public void writeFloat(float value) throws IOException
      Throws:
      IOException

    • writeBytes

      public void writeBytes(byte[] arr) throws IOException
      Throws:
      IOException

    • writeBytesAtPos

      public void writeBytesAtPos(byte[] arr, int pos)

    • writeBytes

      public void writeBytes(byte[] arr, int off, int len) throws IOException
      Write byte array to buf. If buf is full, flush socket.
      Parameters:
      arr - byte array
      off - offset
      len - byte length to write
      Throws:
      IOException - if socket error occur

    • writeLength

      public void writeLength(long length) throws IOException
      Write field length into buf, flush socket if needed.
      Parameters:
      length - field length
      Throws:
      IOException - if socket error occur.

    • writeAscii

      public void writeAscii(String str) throws IOException
      Throws:
      IOException

    • writeString

      public void writeString(String str) throws IOException
      Throws:
      IOException

    • buf

      public byte[] buf()
      Current buffer
      Returns:
      current buffer

    • writeStringEscaped

      public void writeStringEscaped(String str, boolean noBackslashEscapes) throws IOException
      Write string to socket.
      Parameters:
      str - string
      noBackslashEscapes - escape method
      Throws:
      IOException - if socket error occur

    • writeBytesEscaped

      public void writeBytesEscaped(byte[] bytes, int len, boolean noBackslashEscapes) throws IOException
      Write escape bytes to socket.
      Parameters:
      bytes - bytes
      len - len to write
      noBackslashEscapes - escape method
      Throws:
      IOException - if socket error occur

    • growBuffer

      private void growBuffer(int len) throws IOException
      buf growing use 4 size only to avoid creating/copying that are expensive operations. possible size
      1. SMALL_buf_SIZE = 8k (default)
      2. MEDIUM_buf_SIZE = 128k
      3. LARGE_buf_SIZE = 1M
      4. getMaxPacketLength = 16M (+ 4 if using no compression)
      Parameters:
      len - length to add
      Throws:
      IOException

    • writeEmptyPacket

      public void writeEmptyPacket() throws IOException
      Send empty packet.
      Throws:
      IOException - if socket error occur.

    • flush

      public void flush() throws IOException
      Send packet to socket.
      Throws:
      IOException - if socket error occur.

    • flushPipeline

      public void flushPipeline() throws IOException
      Throws:
      IOException

    • checkMaxAllowedLength

      private void checkMaxAllowedLength(int length) throws MaxAllowedPacketException
      Count query size. If query size is greater than max_allowed_packet and nothing has been already send, throw an exception to avoid having the connection closed.
      Parameters:
      length - additional length to query size
      Throws:
      MaxAllowedPacketException - if query has not to be sent.

    • throwMaxAllowedLength

      public boolean throwMaxAllowedLength(int length)

    • throwMaxAllowedLengthOr16M

      public boolean throwMaxAllowedLengthOr16M(int length)

    • setMaxAllowedPacket

      public void setMaxAllowedPacket(Integer maxAllowedPacket)
      Set the maximum size (in bytes) of a packet the writer will send. Called once the handshake/authentication phase is over to raise the limit from the 16Mb connection-phase cap to the configured maxAllowedPacket.
      Parameters:
      maxAllowedPacket - maximum packet size to send, or null for no explicit limit

    • permitTrace

      public void permitTrace(boolean permitTrace)

    • setServerThreadId

      public void setServerThreadId(Long serverThreadId, HostAddress hostAddress)
      Set server thread id.
      Parameters:
      serverThreadId - current server thread id.
      hostAddress - host information

    • mark

      public void mark()

    • isMarked

      public boolean isMarked()

    • hasFlushed

      public boolean hasFlushed()

    • flushBufferStopAtMark

      public void flushBufferStopAtMark() throws IOException
      Flush to last mark.
      Throws:
      IOException - if flush fail.

    • bufIsDataAfterMark

      public boolean bufIsDataAfterMark()

    • resetMark

      public byte[] resetMark()
      Reset mark flag and send bytes after mark flag.
      Returns:
      bytes after mark flag

    • initPacket

      public void initPacket()

    • writeSocket

      protected void writeSocket(boolean commandEnd) throws IOException
      Flush the internal buf.
      Parameters:
      commandEnd - command end
      Throws:
      IOException - id connection error occur.

    • close

      public void close() throws IOException
      Throws:
      IOException

    • getSequence

      public byte getSequence()