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 で暗号化されたデータにアクセスする前に、MEK や URL などのパラメータを設定します。

MEK の設定

MEK は 3 つの方法で設定できます。JDBC 接続で複数の方法を設定した場合、優先順位は次のとおりです：JDBC プロパティの設定 > ファイルの設定 > URL の設定。

// ホスト名、ポート、データベース名、ユーザー名、パスワードなどの接続情報を準備します。
// ...
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=****

// ホスト名、ポート、データベース名、ユーザー名、パスワードなどの接続情報を準備します。
// ...
String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);
Connection connection = DriverManager.getConnection(dbUrl, 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 を設定する完全な例です。このコードを実行する前に、ターゲットデータベースで列レベルの暗号化が設定されていることを確認してください。

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 {
        // 実際の環境に基づいて、次の接続情報 (ホスト名、ポート、データベース名、ユーザー名、パスワード) を更新してください。
        String hostname = "pgm-****.pg.rds.aliyuncs.com"; // インスタンスエンドポイント。実際の値に置き換えてください。
        String port = "5432"; // データベースポート。実際の値に置き換えてください。
        String dbname = "testdb"; // データベース名。実際の値に置き換えてください。
        String username = "user"; // データベースユーザー名。暗号文権限 (JDBC 復号) を持つユーザーを使用してください。
        String password = "password"; // データベースユーザーのパスワード。
        
        // これはサンプルキーです。セキュリティを向上させるため、より強力なキーを使用することを推奨します。
        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);
        
        // テストテーブルからデータを取得するクエリを実行します。
        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(); // 接続を閉じます。
    }
}