快速入门

在此我们将简要介绍 ADBC 的基本功能以及适用于 Java 的 PostgreSQL 驱动程序。

安装

要在 Maven 项目中包含 ADBC，请添加以下依赖项

<dependency>
    <groupId>org.apache.arrow.adbc</groupId>
    <artifactId>adbc-driver-jdbc</artifactId>
    <version>${adbc.version}</version>
</dependency>

本节中的示例需要以下导入

import org.apache.arrow.adbc.core.AdbcConnection;
import org.apache.arrow.adbc.core.AdbcDatabase;
import org.apache.arrow.adbc.core.AdbcDriver;
import org.apache.arrow.adbc.core.AdbcException;
import org.apache.arrow.adbc.core.AdbcStatement;

JDBC 风格的 API

ADBC 提供了 JDBC 标准风格的高级 API。

用法

final Map<String, Object> parameters = new HashMap<>();
AdbcDriver.PARAM_URI.set(parameters, "jdbc:postgresql://:5432/postgres");
try (
    BufferAllocator allocator = new RootAllocator();
    AdbcDatabase db = new JdbcDriver(allocator).open(parameters);
    AdbcConnection adbcConnection = db.connect();
    AdbcStatement stmt = adbcConnection.createStatement()

) {
    stmt.setSqlQuery("select * from foo");
    AdbcStatement.QueryResult queryResult = stmt.executeQuery();
    while (queryResult.getReader().loadNextBatch()) {
        // process batch
    }
}  catch (AdbcException e) {
    // throw
}

在应用程序代码中，使用后必须关闭连接，否则可能会导致内存泄漏。建议将连接包装在 try-with-resources 块中以实现自动资源管理。在此示例中，我们连接到 PostgreSQL 数据库，特别是默认数据库“postgres”。

请注意，创建语句也包装在 try-with-resources 块中。假设我们在数据库中有一个表“foo”，还提供了一个设置和执行查询的示例。