Package org.mariadb.jdbc.client
Class ClientReplayImpl
java.lang.Object
org.mariadb.jdbc.client.ClientImpl
org.mariadb.jdbc.client.ClientReplayImpl
- All Implemented Interfaces:
AutoCloseable
,Client
-
Field Summary
Fields inherited from class org.mariadb.jdbc.client.ClientImpl
context, exceptionFactory, writer
-
Constructor Summary
ConstructorsConstructorDescriptionClientReplayImpl
(Configuration conf, HostAddress hostAddress, ReentrantLock lock, boolean skipPostCommands) -
Method Summary
Modifier and TypeMethodDescriptionexecute
(ClientMessage message, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) executePipeline
(ClientMessage[] messages, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) int
sendQuery
(ClientMessage message) void
transactionReplay
(TransactionSaver transactionSaver) Methods inherited from class org.mariadb.jdbc.client.ClientImpl
abort, checkNotClosed, close, closePrepare, createSessionVariableQuery, destroySocket, execute, execute, getContext, getExceptionFactory, getHostAddress, getSocketTimeout, getWaitTimeout, isClosed, isPrimary, readPacket, readPacket, readResponse, readResponse, readStreamingResults, reset, setReadOnly, setSocketTimeout
-
Constructor Details
-
ClientReplayImpl
public ClientReplayImpl(Configuration conf, HostAddress hostAddress, ReentrantLock lock, boolean skipPostCommands) throws SQLException - Throws:
SQLException
-
-
Method Details
-
sendQuery
- Overrides:
sendQuery
in classClientImpl
- Throws:
SQLException
-
executePipeline
public List<Completion> executePipeline(ClientMessage[] messages, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) throws SQLException - Specified by:
executePipeline
in interfaceClient
- Overrides:
executePipeline
in classClientImpl
- Throws:
SQLException
-
execute
public List<Completion> execute(ClientMessage message, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) throws SQLException - Specified by:
execute
in interfaceClient
- Overrides:
execute
in classClientImpl
- Throws:
SQLException
-
transactionReplay
- Throws:
SQLException
-