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
All Methods Instance Methods Abstract Methods 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 interfacejava.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()
-
-