Interface ClientMessage

    • Method Detail

      • validateLocalFileName

        static boolean validateLocalFileName​(java.lang.String sql,
                                             Parameters parameters,
                                             java.lang.String fileName,
                                             Context context)
        Check that file requested correspond to request.
        Parameters:
        sql - current command sql
        parameters - current command parameter
        fileName - file path request
        context - current connection context
        Returns:
        true if file name correspond to demand and query is a load local infile
      • encode

        int encode​(Writer writer,
                   Context context)
            throws java.io.IOException,
                   java.sql.SQLException
        Encode client message to socket.
        Parameters:
        writer - 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

        default int batchUpdateLength()
        Number of parameter rows, and so expected return length
        Returns:
        batch update length
      • description

        default java.lang.String description()
        Message description
        Returns:
        description
      • binaryProtocol

        default boolean binaryProtocol()
        Are return value encoded in binary protocol
        Returns:
        use binary protocol
      • canSkipMeta

        default boolean canSkipMeta()
        Can skip metadata
        Returns:
        can skip metadata
      • readPacket

        default Completion readPacket​(Statement stmt,
                                      int fetchSize,
                                      long maxRows,
                                      int resultSetConcurrency,
                                      int resultSetType,
                                      boolean closeOnCompletion,
                                      Reader reader,
                                      Writer writer,
                                      Context context,
                                      ExceptionFactory exceptionFactory,
                                      ClosableLock lock,
                                      boolean traceEnable,
                                      ClientMessage message,
                                      java.util.function.Consumer<java.lang.String> redirectFct)
                               throws java.io.IOException,
                                      java.sql.SQLException
        default packet resultset parser
        Parameters:
        stmt - caller
        fetchSize - fetch size
        maxRows - maximum number of rows
        resultSetConcurrency - resultset concurrency
        resultSetType - resultset type
        closeOnCompletion - must close caller on result parsing end
        reader - packet reader
        writer - packet writer
        context - connection context
        exceptionFactory - connection exception factory
        lock - thread safe locks
        traceEnable - is logging trace enable
        message - client message
        redirectFct - redirect consumer
        Returns:
        results
        Throws:
        java.io.IOException - if any socket error occurs
        java.sql.SQLException - for other kind of errors
      • getLocalInfileInputStream

        default java.io.InputStream getLocalInfileInputStream()
        Get current local infile input stream.
        Returns:
        default to null
      • mightBeBulkResult

        default boolean mightBeBulkResult()
        Indicating if result might be a COM_STMT_BULK result
        Returns:
        true if so.
      • validateLocalFileName

        default boolean validateLocalFileName​(java.lang.String fileName,
                                              Context context)
        Request for local file to be validated from current query.
        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