Interface RedoableWithPrepareClientMessage

    • Method Detail

      • getCommand

        java.lang.String getCommand()
        sql command value
        Returns:
        sql command
      • encode

        default int encode​(Writer writer,
                           Context context)
                    throws java.io.IOException,
                           java.sql.SQLException
        Default encoder caller
        Specified by:
        encode in interface ClientMessage
        Parameters:
        writer - socket writer
        context - connection context
        Returns:
        number of command sent
        Throws:
        java.io.IOException - if a socket exception occurs
        java.sql.SQLException - for any other kind of error
      • encode

        int encode​(Writer writer,
                   Context context,
                   Prepare newPrepareResult)
            throws java.io.IOException,
                   java.sql.SQLException
        encoder method in case of failover, passing new prepared object
        Specified by:
        encode in interface RedoableClientMessage
        Parameters:
        writer - socket writer
        context - connection context
        newPrepareResult - new prepare result
        Returns:
        number of command sent
        Throws:
        java.io.IOException - if a socket exception occurs
        java.sql.SQLException - for any other kind of error
      • reEncode

        default int reEncode​(Writer writer,
                             Context context,
                             Prepare newPrepareResult)
                      throws java.io.IOException,
                             java.sql.SQLException
        re-encoder method in case of failover, passing new prepared object
        Specified by:
        reEncode in interface RedoableClientMessage
        Parameters:
        writer - socket writer
        context - connection context
        newPrepareResult - new prepare result
        Returns:
        number of command sent
        Throws:
        java.io.IOException - if a socket exception occurs
        java.sql.SQLException - for any other kind of error
      • setPrepareResult

        void setPrepareResult​(PrepareResultPacket prepareResult)
        Set prepare result, if pipelining prepare
        Parameters:
        prepareResult - prepare results
      • rePrepare

        default void rePrepare​(Client client)
                        throws java.sql.SQLException
        Force re-prepare command
        Parameters:
        client - client
        Throws:
        java.sql.SQLException - if any error occurs