void |
ClickHouseTransaction.begin() |
Starts a new transaction.
|
void |
ClickHouseTransaction.begin(Map<String,Serializable> settings) |
Starts a new transaction with optional server settings.
|
void |
ClickHouseTransaction.commit() |
Commits the transaction.
|
void |
ClickHouseTransaction.commit(Map<String,Serializable> settings) |
Commits the transaction with optional server settings.
|
ClickHouseTransaction |
ClickHouseRequestManager.createImplicitTransaction(ClickHouseRequest<?> request) |
Creates an implicit transaction.
|
ClickHouseTransaction |
ClickHouseRequestManager.createTransaction(ClickHouseNode server,
int timeout) |
Creates a new transaction.
|
ClickHouseTransaction |
ClickHouseRequestManager.createTransaction(ClickHouseRequest<?> request) |
Creates a new transaction.
|
ClickHouseTransaction |
ClickHouseRequestManager.createTransaction(ClickHouseRequest<?> request,
int timeout) |
Creates a new transaction.
|
protected void |
ClickHouseTransaction.ensureTransactionId() |
Ensures client and server are using the exact same transaction ID.
|
default ClickHouseResponse |
ClickHouseClient.executeAndWait(ClickHouseRequest<?> request) |
|
ClickHouseResponse |
ClickHouseRequest.executeAndWait() |
|
ClickHouseResponse |
ClickHouseRequest.Mutation.executeAndWait() |
|
ClickHouseResponse |
ClickHouseRequest.executeWithinTransaction() |
Executes the request within an implicit transaction.
|
ClickHouseResponse |
ClickHouseRequest.executeWithinTransaction(boolean useImplicitTransaction) |
Deprecated.
|
ClickHouseTransaction |
ClickHouseRequestManager.getOrStartTransaction(ClickHouseRequest<?> request) |
Gets or starts a new transaction.
|
ClickHouseTransaction |
ClickHouseRequestManager.getOrStartTransaction(ClickHouseRequest<?> request,
int timeout) |
Gets or starts a new transaction.
|
protected ClickHouseRecord |
ClickHouseTransaction.issue(String command) |
Issues transaction related query.
|
protected ClickHouseRecord |
ClickHouseTransaction.issue(String command,
boolean sessionCheck,
Map<String,Serializable> settings) |
Issues transaction related query.
|
void |
ClickHouseTransaction.rollback() |
Rolls back the transaction.
|
void |
ClickHouseTransaction.rollback(Map<String,Serializable> settings) |
Rolls back the transaction with optional server settings.
|
protected abstract ClickHouseResponse |
AbstractClient.send(ClickHouseRequest<?> sealedRequest) |
Sends the request to server in a current thread.
|
ClickHouseResponse |
ClickHouseRequest.Mutation.sendAndWait() |
Deprecated.
|
protected ClickHouseResponse |
AbstractClient.sendAsync(ClickHouseRequest<?> sealedRequest,
Object... args) |
Sends the request to server in a separate thread.
|
void |
ClickHouseTransaction.snapshot(long snapshotVersion) |
Sets transaction snapshot with optional server settings.
|
void |
ClickHouseTransaction.snapshot(long snapshotVersion,
Map<String,Serializable> settings) |
|
SelfT |
ClickHouseRequest.transaction() |
Creates and starts a transaction.
|
SelfT |
ClickHouseRequest.transaction(int timeout) |
Creates and starts a transaction immediately.
|
SelfT |
ClickHouseRequest.transaction(ClickHouseTransaction transaction) |
Sets transaction.
|