通过JDBC方式连接ClickHouse

下载ClickHouse JDBC驱动

首先，需要下载ClickHouse JDBC驱动。可以从这里下载最新版本的ClickHouse JDBC驱动：https://github.com/ClickHouse/clickhouse-jdbc/releases

添加ClickHouse JDBC驱动到项目中

将下载的ClickHouse JDBC驱动添加到项目的classpath中。

连接ClickHouse数据库

使用以下代码连接ClickHouse数据库：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class ClickHouseJdbcExample {

    public static void main(String[] args) {
        Connection conn = null;
        try {
            // 注册ClickHouse JDBC驱动
            Class.forName("ru.yandex.clickhouse.ClickHouseDriver");

            // 连接ClickHouse数据库
            String url = "jdbc:clickhouse://localhost:8123/default";
            String user = "default";
            String password = "";
            conn = DriverManager.getConnection(url, user, password);

            System.out.println("连接成功！");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的代码中，我们使用了ClickHouse JDBC驱动的默认URL：jdbc:clickhouse://localhost:8123/default，其中localhost是ClickHouse服务器的主机名或IP地址，8123是ClickHouse服务器的端口号，default是要连接的数据库名称。如果ClickHouse服务器的端口号不是8123，则需要将URL中的端口号修改为实际的端口号。

此外，我们还指定了默认的用户名default和空密码。如果ClickHouse服务器的用户名和密码不是默认值，则需要将上面的代码中的用户名和密码修改为实际的用户名和密码。

执行SQL语句

连接成功后，可以使用Connection对象执行SQL语句。例如：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class ClickHouseJdbcExample {

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 注册ClickHouse JDBC驱动
            Class.forName("ru.yandex.clickhouse.ClickHouseDriver");

            // 连接ClickHouse数据库
            String url = "jdbc:clickhouse://localhost:8123/default";
            String user = "default";
            String password = "";
            conn = DriverManager.getConnection(url, user, password);

            // 执行SQL语句
            stmt = conn.createStatement();
            rs = stmt.executeQuery("SELECT * FROM test");

            // 处理查询结果
            while (rs.next()) {
                System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (rs != null) {
                    rs.close();
                }
                if (stmt != null) {
                    stmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

上面的代码执行了一个简单的查询语句，将test表中的所有数据输出到控制台。如果要执行其他SQL语句，只需要将上面的查询语句替换为实际的SQL语句即可。

总结

通过以上步骤，我们可以使用JDBC方式连接ClickHouse数据库，并执行SQL语句。需要注意的是，ClickHouse JDBC驱动的性能比原生的ClickHouse客户端要差，因此不建议在生产环境中使用JDBC方式连接ClickHouse数据库。