当前位置：首页 > Java

java如何连接cratedb

2026-03-21 04:19:55Java

连接 CrateDB 的方法

在 Java 中连接 CrateDB 可以通过 JDBC 驱动程序实现。CrateDB 兼容 PostgreSQL 协议，因此可以使用 PostgreSQL 的 JDBC 驱动来连接。

java如何连接cratedb

添加依赖

在 Maven 项目中，添加 PostgreSQL JDBC 驱动的依赖：

java如何连接cratedb

<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <version>42.6.0</version>
</dependency>

建立连接

使用 JDBC 连接 CrateDB 的示例代码：

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

public class CrateDBConnection {
    public static void main(String[] args) {
        String url = "jdbc:postgresql://<hostname>:<port>/doc";
        String username = "crate";
        String password = "";

        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            System.out.println("Connected to CrateDB successfully");
        } catch (SQLException e) {
            System.err.println("Connection failed: " + e.getMessage());
        }
    }
}

执行查询

连接成功后，可以执行 SQL 查询：

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

public class CrateDBQuery {
    public static void main(String[] args) {
        String url = "jdbc:postgresql://<hostname>:<port>/doc";
        String username = "crate";
        String password = "";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement();
             ResultSet resultSet = statement.executeQuery("SELECT * FROM my_table LIMIT 10")) {

            while (resultSet.next()) {
                System.out.println(resultSet.getString(1));
            }
        } catch (Exception e) {
            System.err.println("Error executing query: " + e.getMessage());
        }
    }
}