Class QueryWithParametersPacket

  • All Implemented Interfaces:
    RedoableClientMessage, ClientMessage

    public final class QueryWithParametersPacket
    extends java.lang.Object
    implements RedoableClientMessage
    Query client packet COM_QUERY see https://mariadb.com/kb/en/com_query/ same than QueryPacket, but with parameters that will be escaped
    • Field Detail

      • preSqlCmd

        private final java.lang.String preSqlCmd
      • localInfileInputStream

        private final java.io.InputStream localInfileInputStream
    • Constructor Detail

      • QueryWithParametersPacket

        public QueryWithParametersPacket​(java.lang.String preSqlCmd,
                                         ClientParser parser,
                                         Parameters parameters,
                                         java.io.InputStream localInfileInputStream)
        Constructor
        Parameters:
        preSqlCmd - additional pre command
        parser - command parser result
        parameters - parameters
        localInfileInputStream - local infile input stream
    • Method Detail

      • ensureReplayable

        public void ensureReplayable​(Context context)
                              throws java.io.IOException,
                                     java.sql.SQLException
        Description copied from interface: RedoableClientMessage
        Ensure that command can be replayed
        Specified by:
        ensureReplayable in interface RedoableClientMessage
        Parameters:
        context - connection context
        Throws:
        java.io.IOException - If socket error occurs
        java.sql.SQLException - for other type of issue
      • encode

        public int encode​(Writer encoder,
                          Context context)
                   throws java.io.IOException,
                          java.sql.SQLException
        Description copied from interface: ClientMessage
        Encode client message to socket.
        Specified by:
        encode in interface ClientMessage
        Parameters:
        encoder - socket writer
        context - connection context
        Returns:
        number of client message written
        Throws:
        java.io.IOException - if socket error occur
        java.sql.SQLException - if any issue occurs
      • batchUpdateLength

        public int batchUpdateLength()
        Description copied from interface: ClientMessage
        Number of parameter rows, and so expected return length
        Specified by:
        batchUpdateLength in interface ClientMessage
        Returns:
        batch update length
      • validateLocalFileName

        public boolean validateLocalFileName​(java.lang.String fileName,
                                             Context context)
        Description copied from interface: ClientMessage
        Request for local file to be validated from current query.
        Specified by:
        validateLocalFileName in interface ClientMessage
        Parameters:
        fileName - server file request path
        context - current connection context
        Returns:
        true if file name correspond to demand and query is a load local infile
      • getLocalInfileInputStream

        public java.io.InputStream getLocalInfileInputStream()
        Description copied from interface: ClientMessage
        Get current local infile input stream.
        Specified by:
        getLocalInfileInputStream in interface ClientMessage
        Returns:
        default to null
      • description

        public java.lang.String description()
        Description copied from interface: ClientMessage
        Message description
        Specified by:
        description in interface ClientMessage
        Returns:
        description