Interface Client

    • Method Detail

      • execute

        java.util.List<Completion> execute​(ClientMessage message)
                                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • execute

        java.util.List<Completion> execute​(ClientMessage message,
                                           Statement stmt,
                                           int fetchSize,
                                           long maxRows,
                                           int resultSetConcurrency,
                                           int resultSetType,
                                           boolean closeOnCompletion)
                                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • executePipeline

        java.util.List<Completion> executePipeline​(ClientMessage[] messages,
                                                   Statement stmt,
                                                   int fetchSize,
                                                   long maxRows,
                                                   int resultSetConcurrency,
                                                   int resultSetType,
                                                   boolean closeOnCompletion)
                                            throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • readStreamingResults

        void readStreamingResults​(java.util.List<Completion> completions,
                                  int fetchSize,
                                  long maxRows,
                                  int resultSetConcurrency,
                                  int resultSetType,
                                  boolean closeOnCompletion)
                           throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • closePrepare

        void closePrepare​(PrepareResultPacket prepare)
                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • abort

        void abort​(java.util.concurrent.Executor executor)
            throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • close

        void close()
            throws java.sql.SQLException
        Specified by:
        close in interface java.lang.AutoCloseable
        Throws:
        java.sql.SQLException
      • setReadOnly

        void setReadOnly​(boolean readOnly)
                  throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • getWaitTimeout

        int getWaitTimeout()
      • getSocketTimeout

        int getSocketTimeout()
      • setSocketTimeout

        void setSocketTimeout​(int milliseconds)
                       throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • isClosed

        boolean isClosed()
      • reset

        void reset()
      • isPrimary

        boolean isPrimary()