Interface Reader

  • All Known Implementing Classes:
    PacketReader

    public interface Reader
    Packet Reader
    • 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