Package org.mariadb.jdbc.client

Interface Client

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

ClientImpl, ClientReplayImpl, MultiPrimaryClient, MultiPrimaryReplicaClient

public interface Client
extends java.lang.AutoCloseable

Method Summary

Modifier and Type	Method	Description
void	abort(java.util.concurrent.Executor executor)
void	close()
void	closePrepare(PrepareResultPacket prepare)
java.util.List<Completion>	execute(ClientMessage message)
java.util.List<Completion>	execute(ClientMessage message, Statement stmt)
java.util.List<Completion>	execute(ClientMessage message, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion)
java.util.List<Completion>	executePipeline(ClientMessage[] messages, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion)
Context	getContext()
ExceptionFactory	getExceptionFactory()
HostAddress	getHostAddress()
int	getSocketTimeout()
int	getWaitTimeout()
boolean	isClosed()
boolean	isPrimary()
void	readStreamingResults(java.util.List<Completion> completions, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion)
void	reset()
void	setReadOnly(boolean readOnly)
void	setSocketTimeout(int milliseconds)

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)
                            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()

getContext

Context getContext()

getExceptionFactory

ExceptionFactory getExceptionFactory()

getHostAddress

HostAddress getHostAddress()