This is a native JDBC library for accessing ClickHouse in Java.
git clone [email protected]:housepower/ClickHouse-Native-JDBC.git
cd ClickHouse-Native-JDBC
mvn clean install
<dependency>
<groupId>com.github.housepower</groupId>
<artifactId>clickhouse-native-jdbc</artifactId>
<version>1.7-stable</version>
</dependency>
Differences from Yandex/Clickhouse-JDBC
- Data is organized and compressed by columns
- We implemented it using the TCP Protocol, with higher performance than HTTP
- Non-values format
- Complex values expression, Like
INSERT INTO test_table VALUES(toDate(123456))
- More compression method, like
ZSTD
- Array(T) only supports one-dimensional
Select query, see also SimpleQuery.java
Class.forName("com.github.housepower.jdbc.ClickHouseDriver");
Connection connection = DriverManager.getConnection("jdbc:clickhouse://127.0.0.1:9000");
Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery("SELECT (number % 3 + 1) as n, sum(number) FROM numbers(10000000) GROUP BY n");
while (rs.next()) {
System.out.println(rs.getInt(1) + "\t" + rs.getLong(2));
}
All DDL,DML queries, see also ExecuteQuery.java
Class.forName("com.github.housepower.jdbc.ClickHouseDriver");
Connection connection = DriverManager.getConnection("jdbc:clickhouse://127.0.0.1:9000");
Statement stmt = connection.createStatement();
// drop table
stmt.executeQuery("drop table if exists test_jdbc_example");
// create table
stmt.executeQuery("create table test_jdbc_example(day default toDate( toDateTime(timestamp) ), timestamp UInt32, name String, impressions UInt32) Engine=MergeTree(day, (timestamp, name), 8192)");
// add column `costs`
stmt.executeQuery("alter table test_jdbc_example add column costs Float32");
// drop the table
stmt.executeQuery("drop table test_jdbc_example");
Batch insert query, see also BatchQuery.java
Class.forName("com.github.housepower.jdbc.ClickHouseDriver");
Connection connection = DriverManager.getConnection("jdbc:clickhouse://127.0.0.1:9000");
Statement stmt = connection.createStatement();
stmt.executeQuery("drop table if exists test_jdbc_example");
stmt.executeQuery("create table test_jdbc_example(day Date, name String, age UInt8) Engine=Log");
PreparedStatement pstmt = connection.prepareStatement("INSERT INTO test_jdbc_example VALUES(?, ?, ?)");
for (int i = 0; i < 200; i++) {
pstmt.setDate(1, new Date(System.currentTimeMillis()));
pstmt.setString(2, "Zhang San" + i);
pstmt.setByte(3, (byte)i);
pstmt.addBatch();
}
pstmt.executeBatch();
stmt.executeQuery("drop table test_jdbc_example");