New JDBC driver

README.md

@@ -40,7 +40,7 @@ try (ClickHouseClient client = ClickHouseClient.newInstance(ClickHouseProtocol.G
     ClickHouseResponse resp = client.connect(server)
         .format(ClickHouseFormat.RowBinaryWithNamesAndTypes).set("send_logs_level", "trace")
         .query("select id, name from some_table where id in :ids and name like :name").params(Arrays.asList(1,2,3), "%key%").execute().get()) {
-    // you can also use resp.recordStream() as well
+    // you can also use resp.stream() as well
     for (ClickHouseRecord record : resp.records()) {
         int id = record.getValue(0).asInteger();
         String name = record.getValue(1).asString();

clickhouse-benchmark/pom.xml

@@ -17,10 +17,7 @@
 
     <properties>
         <clickhouse4j-driver.version>1.4.4</clickhouse4j-driver.version>
-        <mariadb-driver.version>2.7.3</mariadb-driver.version>
-        <mysql-driver.version>8.0.26</mysql-driver.version>
-        <native-driver.version>2.5.6</native-driver.version>
-        <postgresql-driver.version>42.2.23</postgresql-driver.version>
+        <native-driver.version>2.6.0</native-driver.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <jmh.version>1.33</jmh.version>
         <shade.name>benchmarks</shade.name>
@@ -67,10 +64,10 @@
 
         <!-- JDBC drivers -->
         <dependency>
-            <groupId>ru.yandex.clickhouse</groupId>
+            <groupId>com.clickhouse</groupId>
             <artifactId>clickhouse-jdbc</artifactId>
             <version>${revision}</version>
-            <classifier>shaded</classifier>
+            <classifier>all</classifier>
             <exclusions>
                 <exclusion>
                     <groupId>*</groupId>
@@ -79,9 +76,9 @@
             </exclusions>
         </dependency>
         <dependency>
-            <groupId>cc.blynk.clickhouse</groupId>
-            <artifactId>clickhouse4j</artifactId>
-            <version>${clickhouse4j-driver.version}</version>
+            <groupId>com.github.housepower</groupId>
+            <artifactId>clickhouse-native-jdbc-shaded</artifactId>
+            <version>${native-driver.version}</version>
             <exclusions>
                 <exclusion>
                     <groupId>*</groupId>
@@ -90,9 +87,9 @@
             </exclusions>
         </dependency>
         <dependency>
-            <groupId>org.mariadb.jdbc</groupId>
-            <artifactId>mariadb-java-client</artifactId>
-            <version>${mariadb-driver.version}</version>
+            <groupId>cc.blynk.clickhouse</groupId>
+            <artifactId>clickhouse4j</artifactId>
+            <version>${clickhouse4j-driver.version}</version>
             <exclusions>
                 <exclusion>
                     <groupId>*</groupId>
@@ -103,35 +100,14 @@
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
-            <version>${mysql-driver.version}</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>*</groupId>
-                    <artifactId>*</artifactId>
-                </exclusion>
-            </exclusions>
         </dependency>
         <dependency>
-            <groupId>com.github.housepower</groupId>
-            <artifactId>clickhouse-native-jdbc-shaded</artifactId>
-            <version>${native-driver.version}</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>*</groupId>
-                    <artifactId>*</artifactId>
-                </exclusion>
-            </exclusions>
+            <groupId>org.mariadb.jdbc</groupId>
+            <artifactId>mariadb-java-client</artifactId>
         </dependency>
         <dependency>
             <groupId>org.postgresql</groupId>
             <artifactId>postgresql</artifactId>
-            <version>${postgresql-driver.version}</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>*</groupId>
-                    <artifactId>*</artifactId>
-                </exclusion>
-            </exclusions>
         </dependency>
         <dependency>
             <groupId>org.testcontainers</groupId>

clickhouse-benchmark/src/main/java/com/clickhouse/benchmark/client/ClientState.java

@@ -24,7 +24,7 @@
 import com.clickhouse.client.ClickHouseResponse;
 import com.clickhouse.client.ClickHouseValue;
 import com.clickhouse.client.config.ClickHouseClientOption;
-import com.clickhouse.client.grpc.config.ClickHouseGrpcClientOption;
+import com.clickhouse.client.grpc.config.ClickHouseGrpcOption;
 
 @State(Scope.Thread)
 public class ClientState extends BaseState {
@@ -57,24 +57,25 @@ private ClickHouseClient createClient() {
 
         ClickHouseClientBuilder builder = ClickHouseClient.builder();
         if (bufferSize != null && !bufferSize.isEmpty()) {
-            builder.addOption(ClickHouseClientOption.MAX_BUFFER_SIZE, Integer.parseInt(bufferSize));
+            builder.option(ClickHouseClientOption.MAX_BUFFER_SIZE, Integer.parseInt(bufferSize));
         }
         if (compression != null && !compression.isEmpty()) {
-            builder.addOption(ClickHouseClientOption.COMPRESSION, compression.toUpperCase());
+            // builder.option(ClickHouseClientOption.COMPRESSION,
+            // compression.toUpperCase());
             if (ClickHouseCompression.NONE.name().equalsIgnoreCase(compression)) {
-                builder.addOption(ClickHouseGrpcClientOption.USE_FULL_STREAM_DECOMPRESSION, true);
+                builder.option(ClickHouseGrpcOption.USE_FULL_STREAM_DECOMPRESSION, true);
             }
         }
         if (threads != null && !threads.isEmpty()) {
-            builder.addOption(ClickHouseClientOption.MAX_THREADS_PER_CLIENT, Integer.parseInt(threads));
+            builder.option(ClickHouseClientOption.MAX_THREADS_PER_CLIENT, Integer.parseInt(threads));
         }
 
         if (window != null && !window.isEmpty()) {
-            builder.addOption(ClickHouseGrpcClientOption.FLOW_CONTROL_WINDOW, Integer.parseInt(window));
+            builder.option(ClickHouseGrpcOption.FLOW_CONTROL_WINDOW, Integer.parseInt(window));
         }
 
-        return builder.addOption(ClickHouseClientOption.ASYNC, "async".equals(mode))
-                .addOption(ClickHouseGrpcClientOption.USE_OKHTTP, "okhttp".equals(transport)).build();
+        return builder.option(ClickHouseClientOption.ASYNC, "async".equals(mode))
+                .option(ClickHouseGrpcOption.USE_OKHTTP, "okhttp".equals(transport)).build();
     }
 
     @Setup(Level.Trial)

clickhouse-benchmark/src/main/java/com/clickhouse/benchmark/jdbc/DriverState.java

@@ -17,8 +17,8 @@
 
 @State(Scope.Thread)
 public class DriverState extends BaseState {
-    @Param(value = { "clickhouse4j", "clickhouse-jdbc", "clickhouse-native-jdbc-shaded", "mariadb-java-client",
-            "mysql-connector-java", "postgresql-jdbc" })
+    @Param(value = { "clickhouse4j", "clickhouse-http-jdbc", "clickhouse-grpc-jdbc", "clickhouse-jdbc",
+            "clickhouse-native-jdbc-shaded", "mariadb-java-client", "mysql-connector-java", "postgresql-jdbc" })
     private String client;
 
     @Param(value = { Constants.REUSE_CONNECTION, Constants.NEW_CONNECTION })
@@ -38,11 +38,13 @@ public class DriverState extends BaseState {
     public void doSetup(ServerState serverState) throws Exception {
         JdbcDriver jdbcDriver = JdbcDriver.from(client);
 
+        String compression = String.valueOf(Boolean.parseBoolean(System.getProperty("compression", "true")));
+
         try {
             driver = (java.sql.Driver) Class.forName(jdbcDriver.getClassName()).getDeclaredConstructor().newInstance();
             url = String.format(jdbcDriver.getUrlTemplate(), serverState.getHost(),
                     serverState.getPort(jdbcDriver.getDefaultPort()), serverState.getDatabase(), serverState.getUser(),
-                    serverState.getPassword());
+                    serverState.getPassword(), compression);
             conn = driver.connect(url, new Properties());
 
             try (Statement s = conn.createStatement()) {

clickhouse-benchmark/src/main/java/com/clickhouse/benchmark/jdbc/JdbcDriver.java

@@ -5,32 +5,38 @@
 public enum JdbcDriver {
     // ClickHouse4j
     Clickhouse4j("cc.blynk.clickhouse.ClickHouseDriver",
-            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC",
+            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC&compress=%s",
             Constants.HTTP_PORT),
     // ClickHouse JDBC Driver
+    ClickhouseHttpJdbc("com.clickhouse.jdbc.ClickHouseDriver",
+            "jdbc:ch://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC&compress=%s",
+            Constants.HTTP_PORT),
+    ClickhouseGrpcJdbc("com.clickhouse.jdbc.ClickHouseDriver",
+            "jdbc:ch:grpc://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC&compress=%s",
+            Constants.GRPC_PORT),
     ClickhouseJdbc("ru.yandex.clickhouse.ClickHouseDriver",
-            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC",
+            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC&compress=%s",
             Constants.HTTP_PORT),
     // ClickHouse Native JDBC Driver
     ClickhouseNativeJdbcShaded("com.github.housepower.jdbc.ClickHouseDriver",
-            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC",
+            "jdbc:clickhouse://%s:%s/%s?ssl=false&user=%s&password=%s&use_server_time_zone=false&use_time_zone=UTC&compress=%s",
             Constants.NATIVE_PORT),
 
     // MariaDB Java Client
     MariadbJavaClient("org.mariadb.jdbc.Driver",
-            "jdbc:mariadb://%s:%s/%s?user=%s&password=%s&useSSL=false&useCompression=true&useServerPrepStmts=false"
+            "jdbc:mariadb://%s:%s/%s?user=%s&password=%s&useSSL=false&useServerPrepStmts=false&useCompression=%s"
                     + "&rewriteBatchedStatements=true&cachePrepStmts=true&serverTimezone=UTC",
             Constants.MYSQL_PORT),
 
     // MySQL Connector/J
     MysqlConnectorJava("com.mysql.cj.jdbc.Driver",
-            "jdbc:mysql://%s:%s/%s?user=%s&password=%s&useSSL=false&useCompression=true&useServerPrepStmts=false"
-                    + "&rewriteBatchedStatements=true&cachePrepStmts=true&connectionTimeZone=UTC",
+            "jdbc:mysql://%s:%s/%s?user=%s&password=%s&useSSL=false&useServerPrepStmts=false"
+                    + "&rewriteBatchedStatements=true&cachePrepStmts=true&connectionTimeZone=UTC&useCompression=%s",
             Constants.MYSQL_PORT),
 
     // PostgreSQL JDBC Driver
     PostgresqlJdbc("org.postgresql.Driver",
-            "jdbc:postgresql://%s:%s/%s?user=%s&password=%s&ssl=false&sslmode=disable&preferQueryMode=simple",
+            "jdbc:postgresql://%s:%s/%s?user=%s&password=%s&ssl=false&sslmode=disable&preferQueryMode=simple&compress=%s",
             Constants.POSTGRESQL_PORT);
 
     private final String className;