Class PacketReader


  • public class PacketReader
    extends java.lang.Object
    • Field Detail

      • REUSABLE_BUFFER_LENGTH

        private static final int REUSABLE_BUFFER_LENGTH
        See Also:
        Constant Field Values
      • logger

        private static final Logger logger
      • header

        private final byte[] header
      • reusableArray

        private final byte[] reusableArray
      • inputStream

        private final java.io.InputStream inputStream
      • maxQuerySizeToLog

        private final int maxQuerySizeToLog
      • serverThreadLog

        private java.lang.String serverThreadLog
    • Constructor Detail

      • PacketReader

        public PacketReader​(java.io.InputStream in,
                            Configuration conf,
                            MutableInt sequence)
        Constructor of standard socket MySQL packet stream reader.
        Parameters:
        in - stream
        conf - connection options
        sequence - current increment sequence
    • Method Detail

      • readPacket

        public ReadableByteBuf readPacket​(boolean reUsable)
                                   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:
        reUsable - if packet can use existing reusable buf to avoid creating array
        Returns:
        array packet.
        Throws:
        java.io.IOException - if socket exception occur.
      • readPacket

        public ReadableByteBuf readPacket​(boolean reUsable,
                                          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:
        reUsable - if packet can use existing reusable buf to avoid creating array
        traceEnable - must trace packet.
        Returns:
        array packet.
        Throws:
        java.io.IOException - if socket exception occur.
      • close

        public void close()
                   throws java.io.IOException
        Throws:
        java.io.IOException
      • setServerThreadId

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