Package org.mariadb.jdbc.internal.protocol

Interface Protocol

    • Method Detail

      • prepare

        ServerPrepareResult prepare​(java.lang.String sql,
                            boolean executeOnMaster)
                     throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getAutocommit

        boolean getAutocommit()
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • noBackslashEscapes

        boolean noBackslashEscapes()

      • connect

        void connect()
      throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • inTransaction

        boolean inTransaction()

      • hasMoreResults

        boolean hasMoreResults()

      • close

        void close()

      • abort

        void abort()

      • reset

        void reset()
    throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • closeExplicit

        void closeExplicit()

      • isClosed

        boolean isClosed()

      • resetDatabase

        void resetDatabase()
            throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getCatalog

        java.lang.String getCatalog()
                     throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • setCatalog

        void setCatalog​(java.lang.String database)
         throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getServerVersion

        java.lang.String getServerVersion()

      • isConnected

        boolean isConnected()

      • getReadonly

        boolean getReadonly()
             throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • setReadonly

        void setReadonly​(boolean readOnly)
          throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • isMasterConnection

        boolean isMasterConnection()

      • mustBeMasterConnection

        boolean mustBeMasterConnection()

      • setHostAddress

        void setHostAddress​(HostAddress hostAddress)

      • getHost

        java.lang.String getHost()

      • getPort

        int getPort()

      • rollback

        void rollback()
       throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getDatabase

        java.lang.String getDatabase()

      • getUsername

        java.lang.String getUsername()

      • ping

        boolean ping()
      throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • isValid

        boolean isValid​(int timeout)
         throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeQuery

        void executeQuery​(java.lang.String sql)
           throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeQuery

        void executeQuery​(boolean mustExecuteOnMaster,
                  Results results,
                  java.lang.String sql)
           throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeQuery

        void executeQuery​(boolean mustExecuteOnMaster,
                  Results results,
                  java.lang.String sql,
                  java.nio.charset.Charset charset)
           throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeQuery

        void executeQuery​(boolean mustExecuteOnMaster,
                  Results results,
                  ClientPrepareResult clientPrepareResult,
                  ParameterHolder[] parameters)
           throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeQuery

        void executeQuery​(boolean mustExecuteOnMaster,
                  Results results,
                  ClientPrepareResult clientPrepareResult,
                  ParameterHolder[] parameters,
                  int timeout)
           throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeBatchClient

        boolean executeBatchClient​(boolean mustExecuteOnMaster,
                           Results results,
                           ClientPrepareResult prepareResult,
                           java.util.List<ParameterHolder[]> parametersList)
                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeBatchStmt

        void executeBatchStmt​(boolean mustExecuteOnMaster,
                      Results results,
                      java.util.List<java.lang.String> queries)
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executePreparedQuery

        void executePreparedQuery​(boolean mustExecuteOnMaster,
                          ServerPrepareResult serverPrepareResult,
                          Results results,
                          ParameterHolder[] parameters)
                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • executeBatchServer

        boolean executeBatchServer​(boolean mustExecuteOnMaster,
                           ServerPrepareResult serverPrepareResult,
                           Results results,
                           java.lang.String sql,
                           java.util.List<ParameterHolder[]> parameterList)
                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getResult

        void getResult​(Results results)
        throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • cancelCurrentQuery

        void cancelCurrentQuery()
                 throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • interrupt

        void interrupt()

      • skip

        void skip()
   throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • checkIfMaster

        boolean checkIfMaster()
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • hasWarnings

        boolean hasWarnings()

      • getMaxRows

        long getMaxRows()

      • setMaxRows

        void setMaxRows​(long max)
         throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getMajorServerVersion

        int getMajorServerVersion()

      • getMinorServerVersion

        int getMinorServerVersion()

      • versionGreaterOrEqual

        boolean versionGreaterOrEqual​(int major,
                              int minor,
                              int patch)

      • setLocalInfileInputStream

        void setLocalInfileInputStream​(java.io.InputStream inputStream)

      • getTimeout

        int getTimeout()

      • setTimeout

        void setTimeout​(int timeout)
         throws java.net.SocketException
        Throws:
        java.net.SocketException

      • getPinGlobalTxToPhysicalConnection

        boolean getPinGlobalTxToPhysicalConnection()

      • getServerThreadId

        long getServerThreadId()

      • getSocket

        java.net.Socket getSocket()

      • setTransactionIsolation

        void setTransactionIsolation​(int level)
                      throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getTransactionIsolationLevel

        int getTransactionIsolationLevel()

      • isExplicitClosed

        boolean isExplicitClosed()

      • connectWithoutProxy

        void connectWithoutProxy()
                  throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • shouldReconnectWithoutProxy

        boolean shouldReconnectWithoutProxy()

      • setHostFailedWithoutProxy

        void setHostFailedWithoutProxy()

      • releasePrepareStatement

        void releasePrepareStatement​(ServerPrepareResult serverPrepareResult)
                      throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • forceReleasePrepareStatement

        boolean forceReleasePrepareStatement​(int statementId)
                              throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • forceReleaseWaitingPrepareStatement

        void forceReleaseWaitingPrepareStatement()
                                  throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getTimeZone

        java.util.TimeZone getTimeZone()

      • prolog

        void prolog​(long maxRows,
            boolean hasProxy,
            MariaDbConnection connection,
            MariaDbStatement statement)
     throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getActiveStreamingResult

        Results getActiveStreamingResult()

      • setActiveStreamingResult

        void setActiveStreamingResult​(Results mariaSelectResultSet)

      • getLock

        java.util.concurrent.locks.ReentrantLock getLock()

      • setServerStatus

        void setServerStatus​(short serverStatus)

      • removeHasMoreResults

        void removeHasMoreResults()

      • setHasWarnings

        void setHasWarnings​(boolean hasWarnings)

      • readEofPacket

        void readEofPacket()
            throws java.sql.SQLException,
                   java.io.IOException
        Throws:
        java.sql.SQLException
        java.io.IOException

      • skipEofPacket

        void skipEofPacket()
            throws java.sql.SQLException,
                   java.io.IOException
        Throws:
        java.sql.SQLException
        java.io.IOException

      • changeSocketTcpNoDelay

        void changeSocketTcpNoDelay​(boolean setTcpNoDelay)

      • changeSocketSoTimeout

        void changeSocketSoTimeout​(int setSoTimeout)
                    throws java.net.SocketException
        Throws:
        java.net.SocketException

      • removeActiveStreamingResult

        void removeActiveStreamingResult()

      • resetStateAfterFailover

        void resetStateAfterFailover​(long maxRows,
                             int transactionIsolationLevel,
                             java.lang.String database,
                             boolean autocommit)
                      throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • setActiveFutureTask

        void setActiveFutureTask​(java.util.concurrent.FutureTask activeFutureTask)

      • isServerMariaDb

        boolean isServerMariaDb()

      • handleIoException

        java.sql.SQLException handleIoException​(java.lang.Exception initialException)

      • isEofDeprecated

        boolean isEofDeprecated()

      • getAutoIncrementIncrement

        int getAutoIncrementIncrement()
                       throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • sessionStateAware

        boolean sessionStateAware()

      • getTraces

        java.lang.String getTraces()

      • isInterrupted

        boolean isInterrupted()

      • stopIfInterrupted

        void stopIfInterrupted()
                throws java.sql.SQLTimeoutException
        Throws:
        java.sql.SQLTimeoutException