快速入门

在此，我们将简要介绍 ADBC 与 Java PostgreSQL 驱动程序的基本功能。

安装

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

<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”。

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