1. pom 引入

        <dependency><groupId>com.clickhouse</groupId><artifactId>clickhouse-jdbc</artifactId><version>0.4.6</version></dependency><dependency><groupId>org.roaringbitmap</groupId><artifactId>RoaringBitmap</artifactId><version>0.9.31</version></dependency>

RoaringBitmap 个人觉得比较好用，可以不用引入。

2. JDBC 配置

    /*** 在高版本中 ClickHouseProperties 类已去掉，直接使用Properties。* url 格式：jdbc:clickhouse://host1:port,host2:port.../db* 集群模式也不再使用 BalancedClickhouseDataSource * @return* @throws SQLException*/public ClickHouseConnection getConnection() throws SQLException {Properties pro = new Properties();pro.setProperty("socket_timeout", 60000);//pro.setProperty(ClickHouseClientOption.SOCKET_TIMEOUT.getKey(),60000);ClickHouseDataSource clickHouseDataSource = new ClickHouseDataSource(url,pro);return clickHouseDataSource.getConnection(username,password);}/*** 和 ClickHouseDataSource 创建连接底层一致都是用 ClickHouseJdbcUrlParser.parse(url, properties)* @return* @throws SQLException*/public Connection getConnectionByJDBC() throws SQLException {//DriverManager.getConnection(url, pro );return DriverManager.getConnection(url, username, password);}

源码中有注明 jdbcurl 格式，集群模式，多个节点直接用","隔开

客户端参数设置，源码中ClickHouseClientOption 类中设置了参数的默认值，可以查看该类，依据自己需要通过Properties进行修改。

还有非客户端参数，可以通过 ClickHouseHttpOption 里面的参数设置，如：设置custom_http_headers 相关参数

pro.set(ClickHouseHttpOption.CUSTOM_HEADERS.getKey(),"xxx")

可以参考官方 github 升级说明：clickhouse-java/clickhouse-jdbc at v0.4.6 · ClickHouse/clickhouse-java · GitHub

3. 查询

    /*** 执行查询，返回ResultSet* @param sql* @return* @throws SQLException*/public static ResultSet executeQuery(String sql) throws SQLException {return getConnection().createStatement().executeQuery(sql);}/*** 获取bitmap, sql 只返回一个字段 字段结构为bitmap* @param sql* @return* @throws SQLException*/public static ClickHouseBitmap getBitmap(String sql) throws SQLException {ResultSet resultSet = executeQuery(sql);if (resultSet.next()){return resultSet.getObject(1,ClickHouseBitmap.class);}else {return ClickHouseBitmap.empty();}}/*** 将结果转为 RoaringBitmap，比 ClickHouseRoaringBitmap 好用一些* @param sql* @return* @throws SQLException*/public static RoaringBitmap getRoaringBitmap(String sql) throws SQLException {ClickHouseBitmap clickHouseBitmap = getBitmap(sql);return (RoaringBitmap) clickHouseBitmap.unwrap();}

ResultSet 必须调用 next() 方法。查看源码currentRow 初始为null,直接取ResultSet 取不到。

获取ResultSet 中的多个字段

        ResultSet resultSet = ClickhouseService.executeQuery(sql);while (resultSet.next()){ResultSetMetaData rsmd = resultSet.getMetaData();String column1= resultSet.getString(rsmd.getColumnName(1));String column2= resultSet.getString(rsmd.getColumnName(2));String column3= resultSet.getString(rsmd.getColumnName(3));}