Interface RedoableWithPrepareClientMessage

All Superinterfaces:
ClientMessage, RedoableClientMessage
All Known Implementing Classes:
BulkExecutePacket, ExecutePacket, PrepareExecutePacket

public interface RedoableWithPrepareClientMessage extends RedoableClientMessage
Client message that can be replayed with parameter
  • Method Details

    • getCommand

      String getCommand()
      sql command value
      Returns:
      sql command
    • prep

      Server prepare statement caller
      Returns:
      caller
    • encode

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

      int encode(Writer writer, Context context, Prepare newPrepareResult) throws IOException, 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:
      IOException - if a socket exception occurs
      SQLException - for any other kind of error
    • reEncode

      default int reEncode(Writer writer, Context context, Prepare newPrepareResult) throws IOException, 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:
      IOException - if a socket exception occurs
      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 SQLException
      Force re-prepare command
      Parameters:
      client - client
      Throws:
      SQLException - if any error occurs