static ClickHouseNode.Builder |
ClickHouseNode.builder(ClickHouseNode base) |
Gets builder for creating a new node based on the given one.
|
protected boolean |
AbstractClient.checkConnection(T connection,
ClickHouseNode requestServer,
ClickHouseNode currentServer,
ClickHouseRequest<?> request) |
Checks if the underlying connection can be reused.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.dump(ClickHouseNode server,
String tableOrQuery,
ClickHouseFormat format,
ClickHouseCompression compression,
OutputStream output) |
Dumps a table or query result from server into output stream.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.dump(ClickHouseNode server,
String tableOrQuery,
ClickHouseFormat format,
ClickHouseCompression compression,
String file) |
Dumps a table or query result from server into a file.
|
static ClickHouseException |
ClickHouseException.forCancellation(Exception e,
ClickHouseNode server) |
Creates an exception for cancellation.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.load(ClickHouseNode server,
String table,
ClickHouseFormat format,
ClickHouseCompression compression,
ClickHouseWriter writer) |
Loads data from a custom writer into a table using specified format and
compression algorithm.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.load(ClickHouseNode server,
String table,
ClickHouseFormat format,
ClickHouseCompression compression,
InputStream input) |
Loads data from input stream into a table using specified format and
compression algorithm.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.load(ClickHouseNode server,
String table,
ClickHouseFormat format,
ClickHouseCompression compression,
String file) |
Loads data from a file into table using specified format and compression
algorithm.
|
boolean |
ClickHouseNodeSelector.match(ClickHouseNode node) |
|
protected abstract T |
AbstractClient.newConnection(T connection,
ClickHouseNode server,
ClickHouseRequest<?> request) |
Creates a new connection and optionally close existing connection.
|
static ClickHouseException |
ClickHouseException.of(String message,
ClickHouseNode server) |
Creates an exception to encapsulate the given error message.
|
static ClickHouseException |
ClickHouseException.of(Throwable e,
ClickHouseNode server) |
Creates an exception to encapsulate cause of the given exception.
|
default boolean |
ClickHouseClient.ping(ClickHouseNode server,
int timeout) |
Tests if the given server is alive or not.
|
static CompletableFuture<List<ClickHouseResponseSummary>> |
ClickHouseClient.send(ClickHouseNode server,
String sql,
ClickHouseValue[] templates,
Object[]... params) |
Sends SQL query along with template objects and raw parameters to specified
server.
|
static CompletableFuture<List<ClickHouseResponseSummary>> |
ClickHouseClient.send(ClickHouseNode server,
String sql,
String... more) |
Sends one or more SQL queries to specified server, and execute them one by
one.
|
static CompletableFuture<List<ClickHouseResponseSummary>> |
ClickHouseClient.send(ClickHouseNode server,
String sql,
String[][] params) |
Sends SQL query along with stringified parameters to specified server.
|
static CompletableFuture<List<ClickHouseResponseSummary>> |
ClickHouseClient.send(ClickHouseNode server,
String sql,
List<ClickHouseColumn> columns,
Object[]... params) |
Sends SQL query along with raw parameters(e.g.
|
static CompletableFuture<ClickHouseResponseSummary> |
ClickHouseClient.send(ClickHouseNode server,
String sql,
Map<String,String> params) |
Sends SQL query along with stringified parameters to specified server.
|