Hologres:JDBC

ステップ 1：ドライバーの依存関係の追加

ほとんどの SQL クライアントツールには、PostgreSQL ドライバーが組み込まれています。利用可能な場合は、それを使用してください。Java アプリケーションの場合は、PostgreSQL JDBC ドライバーを Maven プロジェクトに追加します。jdbc.postgresql.org/download からダウンロードし、バージョン 42.3.2 以降 (最新の安定バージョンを推奨) を使用してください。

Hologres は標準の PostgreSQL JDBC ドライバーを使用します。インストールが必要な Hologres 専用のドライバーはありません。

pom.xml に以下の依存関係を追加します。

<dependencies>
    <dependency>
        <groupId>org.postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>42.3.2</version>
    </dependency>
</dependencies>

ステップ 2：接続文字列の構築

接続文字列のフォーマットは以下の通りです。

jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?user=<ACCESS_ID>&password=<ACCESS_KEY>

必須パラメーター

オプションパラメーター

必要に応じて、これらのパラメーターを接続文字列に追加します。複数のパラメーターは & で区切ります。

推奨オプションを含む接続文字列の例：

jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?user=<ACCESS_ID>&password=<ACCESS_KEY>&ApplicationName=myApp&reWriteBatchedInserts=true

ステップ 3：環境変数への認証情報の保存

接続文字列に認証情報をハードコーディングすると、セキュリティリスクが生じます。代わりに環境変数として保存してください。Linux では、以下の内容を ~/.bash_profile に追加します。

export ALIBABA_CLOUD_USER=<ACCESS_ID>
export ALIBABA_CLOUD_PASSWORD=<ACCESS_KEY>

ステップ 4：接続とクエリの実行

以下の例では、環境変数から認証情報を読み取り、タイムアウトプロパティを設定し、Hologres に接続し、標準の Statement を使用して基本的な SELECT クエリを実行します。

public class HologresTest {

    private void jdbcExample() throws SQLException {
        String user = System.getenv("ALIBABA_CLOUD_USER");
        String password = System.getenv("ALIBABA_CLOUD_PASSWORD");
        String url = String.format(
            "jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?currentSchema=<SCHEMA_NAME>&user=%s&password=%s",
            user, password
        );
        Properties props = new Properties();
        // クエリが完了する前に早期にタイムアウトしないように、
        // 実際のクエリ実行時間に基づいて SOCKET_TIMEOUT を設定します。
        PGProperty.SOCKET_TIMEOUT.set(props, 3600);
        PGProperty.LOGIN_TIMEOUT.set(props, 60);
        PGProperty.TCP_KEEP_ALIVE.set(props, true);
        try (Connection conn = DriverManager.getConnection(url, props)) {
            try (Statement st = conn.createStatement()) {
                String sql = "SELECT * FROM table where xxx limit 100";
                try (ResultSet rs = st.executeQuery(sql)) {
                    while (rs.next()) {
                        // 最初の列の値を読み取る
                        String c1 = rs.getString(1);
                    }
                }
            }
        }
    }
}

データの書き込み

JDBC の Statement モードまたは Prepared Statement モードを使用してデータを書き込むことができます。書き込み操作には Prepared Statement モードを使用してください。このモードでは、サーバーが SQL のコンパイル結果をキャッシュするため、書き込みレイテンシが短縮され、スループットが向上します。バッチサイズは 256 の倍数に設定してください。推奨される最小バッチサイズは 256 です。

バッチ挿入

/*
 * Prepared Statement モードを使用してデータをバッチで書き込みます。
 * バッチサイズ：256 行 (最小推奨値)。
 */
private static void writeBatchWithPreparedStatement(Connection conn) throws Exception {
    try (PreparedStatement stmt = conn.prepareStatement("insert into test_tb values (?,?,?,?)")) {
        int batchSize = 256;
        for (int i = 0; i < batchSize; ++i) {
            stmt.setInt(1, 1000 + i);
            stmt.setString(2, "1");
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date parsedDate = dateFormat.parse("1990-11-11 00:00:00");
            stmt.setTimestamp(3, new java.sql.Timestamp(parsedDate.getTime()));
            stmt.setDouble(4, 0.1);
            stmt.addBatch();
        }
        stmt.executeBatch();
    }
}

INSERT ON CONFLICT を使用したアップサート

競合時に既存の行を更新するには、PostgreSQL の INSERT ON CONFLICT 構文を使用します。送信先のテーブルにはプライマリキーが必要です。

private static void insertOverwrite(Connection conn) throws Exception {
    try (PreparedStatement stmt = conn.prepareStatement(
        "insert into test_tb values (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?) " +
        "on conflict(pk) do update set f1 = excluded.f1, f2 = excluded.f2, f3 = excluded.f3"
    )) {
        int batchSize = 6;
        for (int i = 0; i < batchSize; ++i) {
            stmt.setInt(i * 4 + 1, i);
            stmt.setString(i * 4 + 2, "1");
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date parsedDate = dateFormat.parse("1990-11-11 00:00:00");
            stmt.setTimestamp(i * 4 + 3, new java.sql.Timestamp(parsedDate.getTime()));
            stmt.setDouble(i * 4 + 4, 0.1);
        }
        int affectedRows = stmt.executeUpdate();
        System.out.println("affected rows => " + affectedRows);
    }
}

以下の例では、書き込み操作に Prepared Statement モードを使用しており、繰り返し挿入のスループットを向上させます。

private void jdbcPreparedStmtExample() throws SQLException {
    String user = System.getenv("ALIBABA_CLOUD_USER");
    String password = System.getenv("ALIBABA_CLOUD_PASSWORD");
    String url = String.format(
        "jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?currentSchema=<SCHEMA_NAME>&user=%s&password=%s",
        user, password
    );
    try (Connection conn = DriverManager.getConnection(url)) {
        String sql = "insert into test values" +
                "(?, ?), (?, ?), (?, ?), (?, ?), (?, ?), " +
                "(?, ?), (?, ?), (?, ?), (?, ?), (?, ?)";
        try (PreparedStatement st = conn.prepareStatement(sql)) {
            for (int i = 0; i < 10; ++i) {
                for (int j = 0; j < 2 * 10; ++j) {
                    st.setString(j + 1, UUID.randomUUID().toString());
                }
                System.out.println("affected row => " + st.executeUpdate());
            }
        }
    }
}

データのクエリ

標準の SQL SELECT 文を使用して、Hologres テーブルからデータをクエリします。ステップ 4 の基本的な SELECT の例は、このパターンを示しています。