ClickHouse JDBC driver
This is a basic and restricted implementation of jdbc driver for ClickHouse. It has support of a minimal subset of features to be usable.
Usage
<dependency>
<groupId>ru.yandex.clickhousegroupId>
<artifactId>clickhouse-jdbcartifactId>
<version>0.3.1version>
dependency>
URL syntax: jdbc:clickhouse://, e.g. jdbc:clickhouse://localhost:8123/test
JDBC Driver Class: ru.yandex.clickhouse.ClickHouseDriver
For example:
String url = "jdbc:clickhouse://localhost:8123/test";
ClickHouseProperties properties = new ClickHouseProperties();
// set connection options - see more defined in ClickHouseConnectionSettings
properties.setClientName("Agent #1");
...
// set default request options - more in ClickHouseQueryParam
properties.setSessionId("default-session-id");
...
ClickHouseDataSource dataSource = new ClickHouseDataSource(url, properties)
String sql = "select * from mytable";
Map<ClickHouseQueryParam, String> additionalDBParams = new HashMap<>();
// set request options, which will override the default ones in ClickHouseProperties
additionalDBParams.put(ClickHouseQueryParam.SESSION_ID, "new-session-id");
...
try (ClickHouseConnection conn = dataSource.getConnection();
ClickHouseStatement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql, additionalDBParams)) {
...
}
Additionally, if you have a few instances, you can use BalancedClickhouseDataSource.
Extended API
In order to provide non-JDBC complaint data manipulation functionality, proprietary API exists. Entry point for API is ClickHouseStatement#write() method.
Importing file into table
import ru.yandex.clickhouse.ClickHouseStatement;
ClickHouseStatement sth = connection.createStatement();
sth
.write() // Write API entrypoint
.table("default.my_table") // where to write data
.option("format_csv_delimiter", ";") // specific param
.data(new File("/path/to/file.csv.gz"), ClickHouseFormat.CSV, ClickHouseCompression.gzip) // specify input
.send();
Configurable send
import ru.yandex.clickhouse.ClickHouseStatement;
ClickHouseStatement sth = connection.createStatement();
sth
.write()
.sql("INSERT INTO default.my_table (a,b,c)")
.data(new MyCustomInputStream(), ClickHouseFormat.JSONEachRow)
.dataCompression(ClickHouseCompression.brotli)
.addDbParam(ClickHouseQueryParam.MAX_PARALLEL_REPLICAS, 2)
.send();
Send data in binary formatted with custom user callback
import ru.yandex.clickhouse.ClickHouseStatement;
ClickHouseStatement sth = connection.createStatement();
sth.write().send("INSERT INTO test.writer", new ClickHouseStreamCallback() {
@Override
public void writeTo(ClickHouseRowBinaryStream stream) throws IOException {
for (int i = 0; i < 10; i++) {
stream.writeInt32(i);
stream.writeString("Name " + i);
}
}
},
ClickHouseFormat.RowBinary); // RowBinary or Native are supported
Compiling with maven
The driver is built with maven. mvn package -DskipTests=true
To build a jar with dependencies use
mvn package assembly:single -DskipTests=true
Build requirements
In order to build the jdbc client one need to have jdk 1.7 or higher.
It looks like problem in lines 171-173 of 
Looks like problems with declared precision in 
![[HELP] 0.3.2 pre-release for public testing](https://avatars.githubusercontent.com/u/4270380?v=4)
Note: 
Note: on client side, the new driver consumes less memory and CPU than others, BUT higher CPU on server side(due to overhead of http protocol?).
Note: gRPC does not support LZ4 compression so we use GZIP in the test.
66 Nov 10, 2022
3 Nov 30, 2022
159 Dec 13, 2022
1.5k Dec 31, 2022
17.7k Jan 1, 2023
94 Apr 20, 2022
213 Dec 29, 2022
5 Apr 7, 2022
547 Dec 25, 2022
1 Jan 27, 2022
6 Oct 26, 2022
6 Oct 14, 2022
19 Nov 7, 2022
990 Dec 27, 2022
21 Dec 9, 2022
69 Nov 27, 2022
2.2k Dec 30, 2022