ApsaraDB RDS:JDBC ベースの列暗号化ドライバを使用する

ステップ 1：Maven の依存関係を設定する

Maven プロジェクトの pom.xml ファイルに次の依存関係を追加します。

<dependencies>
   ...
  <dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-cls-jdbc</artifactId>
    <version>1.0.10-1</version>
  </dependency>
   ...
</dependencies>

ステップ 2：URL と MEK を設定する

JDBC ベースの列暗号化ドライバを使用して暗号化された列にアクセスする前に、RDS インスタンスへの接続に使用する MEK と URL を含む、必要なパラメーターを設定する必要があります。

MEK を設定する

このセクションでは、MEK を設定するために使用できる方法について説明します。JDBC ベースの列暗号化ドライバのパラメーターを設定するために複数の方法を使用する場合、JDBC プロパティ設定、設定ファイル、URL 設定の順に優先されます。

// エンドポイント（hostname）、ポート番号（port）、インスタンス名（dbname）、ユーザー名（username）、パスワード（password）などの接続情報を取得します。
// ...

String mek=****;

Properties props = new Properties();
props.setProperty("user", username);
props.setProperty("password", password);
props.setProperty("MEK", mek);


String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);
Connection connection = DriverManager.getConnection(dbUrl, props);

// ... クエリを開始します。 ...

MEK=****

// エンドポイント（hostname）、ポート番号（port）、インスタンス名（dbname）、ユーザー名（username）、パスワード（password）などの接続情報を取得します。
// ...

String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... クエリを開始します。 ...

// エンドポイント（hostname）、ポート番号（port）、インスタンス名（dbname）、ユーザー名（username）、パスワード（password）などの接続情報を取得します。
// ...

String mek=****;

String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s?MEK=%s", hostname, port, dbname, mek);
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... クエリを開始します。 ...

完全なサンプルコード

次のコードスニペットは、JDBC プロパティを使用して MEK を設定する方法を示しています。JDBC ベースの列暗号化ドライバを使用して暗号化された列にアクセスする前に、RDS インスタンスで列暗号化設定を完了する必要があります。

package org.example;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class Main {
    public static void main(String[] args) throws SQLException {
        // ビジネス要件に基づいて、hostname、port、dbname、username、password などの接続情報を更新します。
        String hostname = "pgm-****.pg.rds.aliyuncs.com"; // RDS インスタンスのエンドポイント。実際のエンドポイントを使用する必要があります。
        String port = "5432"; // データベースのポート番号。実際のポート番号を使用する必要があります。
        String dbname = "testdb"; // データベースの名前。実際のデータベース名を使用する必要があります。
        String username = "user"; // データベースにログインするために使用するアカウントのユーザー名。暗号文権限（JDBC 復号）を持つユーザーの名前を使用する必要があります。
        String password = "password"; // データベースにログインするために使用するアカウントのパスワード。
        
        // サンプル MEK。セキュリティを確保するために、強力な MEK を使用することをお勧めします。
        String MEK = "00112233445566778899aabbccddeeff";
        
       // データベース接続プロパティを作成します。
        Properties props = new Properties();
        props.setProperty("user", username);
        props.setProperty("password", password);
        props.setProperty("MEK", MEK);

        // データベースに接続するために使用する URL をフォーマットします。
        String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);

        // DriverManager を使用してデータベース接続を取得します。
        Connection connection = DriverManager.getConnection(dbUrl, props);

        // クエリを実行して、test テーブルのデータを取得します。
        ResultSet rs = connection.createStatement().executeQuery("SELECT * FROM test_table");
        while (rs.next()) {
            for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) { // 列インデックスは 1 から始まります。
                System.out.print(rs.getString(i) + "\t");
            }
            System.out.println(); // 改行。
        }

        // リソースを無効にします。
        rs.close();  // 結果セットを閉じます。
        connection.close(); // 接続を閉じます。
    }
}