文档反馈官招募中，报名立赚积分兑换代金券！> HOT
文档中心>TDSQL-H LibraDB>开发指南>使用 JDBC 连接 TDSQL-H LibraDB

使用 JDBC 连接 TDSQL-H LibraDB

最近更新时间：2024-10-17 20:41:22

我的收藏

本页目录：

TDSQL-H LibraDB JDBC 驱动是 TDSQL-H LibraDB 提供的 Java 数据库连接接口。本文为您介绍如何使用 JDBC 连接 TDSQL-H LibraDB，并提供示例代码。

背景信息

本文以使用 IntelliJ IDEA 工具为例，介绍如何使用 JDBC 连接 TDSQL-H LibraDB。

前提条件

已 创建 TDSQL-H LibraDB 实例。
已获取访问 TDSQL-H LibraDB 实例的账号和密码。
获取 JDBC 连接 TDSQL-H LibraDB 实例时的主机地址。访问 TDSQL-H LibraDB 实例方式不同，获取的主机地址不同，请根据实际选择。
若通过搭建代理使用外网访问 TDSQL-H LibraDB 实例，请获取搭建代理时使用的 CVM 云服务器的公网 IP，并确保外网连接使用的 CVM 安全组已添加 TCP:8123、TCP:9000 协议端口。本文中的操作以此方式为例。 搭建代理的具体操作，请参见 连接实例分析引擎 中的外网连接相关内容。
若使用镜像为 Windows 的 CVM，安装 DBeaver 并连接 TDSQL-H LibraDB 实例，请获取 TDSQL-H LibraDB 实例的内网 IP。 镜像为 Windows 的 CVM 与 TDSQL-H LibraDB 实例必须为相同的 VPC，并确保 CVM 安全组已添加 TCP:8123、TCP:9000 协议端口。
已下载并安装 IntelliJ IDEA。 推荐使用 IntelliJ IDEA 版本 IntelliJ IDEA 2021.3.1，其他版本可能存在兼容性问题。本文中的 IntelliJ IDEA 示例版本为 IntelliJ IDEA 2021.3.1。

JDBC 下载

使用 IntelliJ IDEA 工具，创建 Maven 项目在对象模型 POM（Project Object Model）引入 ClickHouse 驱动依赖包。
<dependency>
   <groupId>ru.yandex.clickhouse</groupId>
   <artifactId>clickhouse-jdbc</artifactId>
   <version>0.3.2</version>
</dependency>

连接 TDSQL-H LibraDB

1. 加载 TDSQL-H LibraDB JDBC 驱动。
Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
2. 通过 DriverManager 创建 Connection。
Connection connection = DriverManager.getConnection(connectionStr, username, password);
connectionStr：格式为 jdbc:clickhouse://" + url + ":8123。其中，url 为前提条件获取的 JDBC 连接 TDSQL-H LibraDB 实例时的主机地址。
username：访问 TDSQL-H LibraDB 实例的账号。
password：访问 TDSQL-H LibraDB 实例账号对应的密码。
3. 执行查询。
Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery("SELECT foo FROM bar");

while (rs.next()) {
  // process the results
}

rs.close();
stmt.close();
connection.close();

示例代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

public class Test {
    private static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
    private static final SimpleDateFormat SIMPLE_DATE_FORMAT = new SimpleDateFormat(DATE_FORMAT);

    public static void main(String[] args) throws ClassNotFoundException, SQLException, InterruptedException, ParseException {
        String url = "your url";
        String username = "your username";
        String password = "your password";

        Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
        String connectionStr = "jdbc:clickhouse://" + url + ":8123";

        try (Connection connection = DriverManager.getConnection(connectionStr, username, password);
             Statement stmt = connection.createStatement()) {

            {
                String createTableDDL = "create table test_table_local on cluster default_cluster " +
                        "(id UInt32, " +
                        "dt_str String, " +
                        "dt_col DateTime) " +
                        "engine=ReplicatedMergeTree('/clickhouse/tables/{database}/{table}/{shard}', '{replica}')" +
                        "partition by toYYYYMM(dt_col)" +
                        "order by (id)" +
                        "primary key (id)" +
                        "sample by (id)" +
                        "settings index_granularity = 8192;";
                stmt.execute(createTableDDL);
                System.out.println("create local table done.");
            }
            {
                String createTableDDL = "create table test_table on cluster default_cluster " +
                        "as default.test_table_local " +
                        "engine=Distributed(default_cluster, default, test_table_local, rand());";
                stmt.execute(createTableDDL);
                System.out.println("create distributed table done");
            }

            System.out.println("write 100000 rows...");
            long startTime = System.currentTimeMillis();

            // Write 10 batch
            for (int batch = 0; batch < 10; batch++) {
                StringBuilder sb = new StringBuilder();

                // Build one batch
                sb.append("insert into test_table values(" + (batch * 10000) + ", '2020-02-19 16:00:00', '2020-02-19 16:00:00')");
                for (int row = 1; row < 10000; row++) {
                    sb.append(", (" + (batch * 10000 + row) + ", '2020-02-19 16:00:00', '2020-02-19 16:00:00')");
                }

                // Write one batch: 10000 rows
                stmt.execute(sb.toString());
            }

            long endTime = System.currentTimeMillis();
            System.out.println("total time cost to write 10W rows: " + (endTime - startTime) + "ms");

            Thread.sleep(2 * 1000);

            System.out.println("Select count(id)...");
            try (ResultSet rs = stmt.executeQuery("select count(id) from test_table");) {
                while (rs.next()) {
                    int count = rs.getInt(1);
                    System.out.println("id count: " + count);
                }
            }

            try (ResultSet rs = stmt.executeQuery("select id, dt_str, dt_col from test_table limit 10");) {
                while (rs.next()) {
                    int id = rs.getInt(1);
                    String dateStr = rs.getString(2);
                    Timestamp time = rs.getTimestamp(3);

                    String defaultDate = SIMPLE_DATE_FORMAT.format(new Date(time.getTime()));
                    System.out.println("id: " + id
                            + ", date_str:" + dateStr
                            + ", date_col:" + defaultDate);
                }
            }
        }
    }
}
中国站
目录