Package org.mariadb.jdbc.client
Class ClientReplayImpl
- java.lang.Object
-
- org.mariadb.jdbc.client.ClientImpl
-
- org.mariadb.jdbc.client.ClientReplayImpl
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,Client
public class ClientReplayImpl extends ClientImpl
-
-
Field Summary
-
Fields inherited from class org.mariadb.jdbc.client.ClientImpl
context, exceptionFactory, writer
-
-
Constructor Summary
Constructors Constructor Description ClientReplayImpl(Configuration conf, HostAddress hostAddress, java.util.concurrent.locks.ReentrantLock lock, boolean skipPostCommands)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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)
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 Detail
-
ClientReplayImpl
public ClientReplayImpl(Configuration conf, HostAddress hostAddress, java.util.concurrent.locks.ReentrantLock lock, boolean skipPostCommands) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-
Method Detail
-
sendQuery
public int sendQuery(ClientMessage message) throws java.sql.SQLException
- Overrides:
sendQuery
in classClientImpl
- Throws:
java.sql.SQLException
-
executePipeline
public java.util.List<Completion> executePipeline(ClientMessage[] messages, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) throws java.sql.SQLException
- Specified by:
executePipeline
in interfaceClient
- Overrides:
executePipeline
in classClientImpl
- Throws:
java.sql.SQLException
-
execute
public java.util.List<Completion> execute(ClientMessage message, Statement stmt, int fetchSize, long maxRows, int resultSetConcurrency, int resultSetType, boolean closeOnCompletion) throws java.sql.SQLException
- Specified by:
execute
in interfaceClient
- Overrides:
execute
in classClientImpl
- Throws:
java.sql.SQLException
-
transactionReplay
public void transactionReplay(TransactionSaver transactionSaver) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-