Interface ColumnDecoder

    • Method Detail

      • decodeStd

        static ColumnDecoder decodeStd​(ReadableByteBuf buf)
        Decode Column from mysql packet
        Parameters:
        buf - packet
        Returns:
        column
      • create

        static ColumnDecoder create​(java.lang.String name,
                                    DataType type,
                                    int flags)
        Create fake MySQL column definition packet with indicated datatype
        Parameters:
        name - column name
        type - data type
        flags - column flags
        Returns:
        Column
      • defaultClassname

        java.lang.String defaultClassname​(Configuration conf)
        Returns default class name depending on server column datatype
        Parameters:
        conf - configuration
        Returns:
        default class name
      • getColumnType

        int getColumnType​(Configuration conf)
        Returns default java.sql.Types depending on server column datatype
        Parameters:
        conf - configuration
        Returns:
        default java.sql.Types
      • getColumnTypeName

        java.lang.String getColumnTypeName​(Configuration conf)
        Returns server column datatype
        Parameters:
        conf - configuration
        Returns:
        default server column datatype
      • getPrecision

        default int getPrecision()
        Return decimal precision.
        Returns:
        decimal precision
      • getDefaultText

        java.lang.Object getDefaultText​(ReadableByteBuf buf,
                                        MutableInt length,
                                        Context context)
                                 throws java.sql.SQLDataException
        Return default Object text encoded
        Parameters:
        buf - row buffer
        length - data length
        context - connection context
        Returns:
        default Object
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • getDefaultBinary

        java.lang.Object getDefaultBinary​(ReadableByteBuf buf,
                                          MutableInt length,
                                          Context context)
                                   throws java.sql.SQLDataException
        Return default Object binary encoded
        Parameters:
        buf - row buffer
        length - data length
        context - connection context
        Returns:
        default Object
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeStringText

        java.lang.String decodeStringText​(ReadableByteBuf buf,
                                          MutableInt length,
                                          java.util.Calendar cal,
                                          Context context)
                                   throws java.sql.SQLDataException
        Return String text encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection context
        Returns:
        String value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeStringBinary

        java.lang.String decodeStringBinary​(ReadableByteBuf buf,
                                            MutableInt length,
                                            java.util.Calendar cal,
                                            Context context)
                                     throws java.sql.SQLDataException
        Return String binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - current context
        Returns:
        String value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeByteText

        byte decodeByteText​(ReadableByteBuf buf,
                            MutableInt length)
                     throws java.sql.SQLDataException
        Return byte text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        byte value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeByteBinary

        byte decodeByteBinary​(ReadableByteBuf buf,
                              MutableInt length)
                       throws java.sql.SQLDataException
        Return byte binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        byte value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeDateText

        java.sql.Date decodeDateText​(ReadableByteBuf buf,
                                     MutableInt length,
                                     java.util.Calendar cal,
                                     Context context)
                              throws java.sql.SQLDataException
        Return date text encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection Context
        Returns:
        date value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeDateBinary

        java.sql.Date decodeDateBinary​(ReadableByteBuf buf,
                                       MutableInt length,
                                       java.util.Calendar cal,
                                       Context context)
                                throws java.sql.SQLDataException
        Return date binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection Context
        Returns:
        date value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeTimeText

        java.sql.Time decodeTimeText​(ReadableByteBuf buf,
                                     MutableInt length,
                                     java.util.Calendar cal,
                                     Context context)
                              throws java.sql.SQLDataException
        Return time text encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection context
        Returns:
        time value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeTimeBinary

        java.sql.Time decodeTimeBinary​(ReadableByteBuf buf,
                                       MutableInt length,
                                       java.util.Calendar cal,
                                       Context context)
                                throws java.sql.SQLDataException
        Return time binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection context
        Returns:
        time value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeTimestampText

        java.sql.Timestamp decodeTimestampText​(ReadableByteBuf buf,
                                               MutableInt length,
                                               java.util.Calendar cal,
                                               Context context)
                                        throws java.sql.SQLDataException
        Return timestamp text encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection context
        Returns:
        timestamp value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeTimestampBinary

        java.sql.Timestamp decodeTimestampBinary​(ReadableByteBuf buf,
                                                 MutableInt length,
                                                 java.util.Calendar cal,
                                                 Context context)
                                          throws java.sql.SQLDataException
        Return timestamp binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        cal - calendar
        context - connection context
        Returns:
        timestamp value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeBooleanText

        boolean decodeBooleanText​(ReadableByteBuf buf,
                                  MutableInt length)
                           throws java.sql.SQLDataException
        Return boolean text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        boolean value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeBooleanBinary

        boolean decodeBooleanBinary​(ReadableByteBuf buf,
                                    MutableInt length)
                             throws java.sql.SQLDataException
        Parse boolean binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        boolean value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeShortText

        short decodeShortText​(ReadableByteBuf buf,
                              MutableInt length)
                       throws java.sql.SQLDataException
        Parse short text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        short value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeShortBinary

        short decodeShortBinary​(ReadableByteBuf buf,
                                MutableInt length)
                         throws java.sql.SQLDataException
        Parse short binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        short value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeIntText

        int decodeIntText​(ReadableByteBuf buf,
                          MutableInt length)
                   throws java.sql.SQLDataException
        Parse int text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        int value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeIntBinary

        int decodeIntBinary​(ReadableByteBuf buf,
                            MutableInt length)
                     throws java.sql.SQLDataException
        Parse int binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        int value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeLongText

        long decodeLongText​(ReadableByteBuf buf,
                            MutableInt length)
                     throws java.sql.SQLDataException
        Parse long text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        long value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeLongBinary

        long decodeLongBinary​(ReadableByteBuf buf,
                              MutableInt length)
                       throws java.sql.SQLDataException
        Parse long binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        long value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeFloatText

        float decodeFloatText​(ReadableByteBuf buf,
                              MutableInt length)
                       throws java.sql.SQLDataException
        Parse float text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        float value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeFloatBinary

        float decodeFloatBinary​(ReadableByteBuf buf,
                                MutableInt length)
                         throws java.sql.SQLDataException
        Parse float binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        float value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeDoubleText

        double decodeDoubleText​(ReadableByteBuf buf,
                                MutableInt length)
                         throws java.sql.SQLDataException
        Parse double text encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        double value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs
      • decodeDoubleBinary

        double decodeDoubleBinary​(ReadableByteBuf buf,
                                  MutableInt length)
                           throws java.sql.SQLDataException
        Parse double binary encoded value
        Parameters:
        buf - row buffer
        length - data length
        Returns:
        double value
        Throws:
        java.sql.SQLDataException - if any decoding error occurs