连接到集群

BalancedClickhouseDataSource

我们可以通过包含多个 clickhouse 实例地址的 JDBC URL 初始化 BalancedClickhouseDataSource，这样每次调用 #getConnection 时， 就可以获得的一个指向集群任一实例的健康连接。

目前, 我们只支持随机算法选择实例。

BalancedClickhouseDataSource 是线程安全的。

• 示例代码:

DataSource singleDataSource = new BalancedClickhouseDataSource("jdbc:clickhouse://127.0.0.1:9000");

DataSource dualDataSource = new BalancedClickhouseDataSource("jdbc:clickhouse://127.0.0.1:9000,127.0.0.1:9000");

Connection conn1 = dualDataSource.getConnection();
conn1.createStatement().execute("CREATE DATABASE IF NOT EXISTS test");

Connection conn2 = dualDataSource.getConnection();
conn2.createStatement().execute("DROP TABLE IF EXISTS test.insert_test");
conn2.createStatement().execute("CREATE TABLE IF NOT EXISTS test.insert_test (i Int32, s String) ENGINE = TinyLog");