ApsaraDB RDS:SSL 経由での ApsaraDB RDS for PostgreSQL インスタンスへの接続

ステップ 1：証明書ファイルの取得

Java アプリケーションが実行されるホストに、以下のファイルをダウンロードします：

• server-ca.crt：サーバー CA 証明書。取得方法については、前提条件のセクションをご参照ください。

• client.crt と client.key：クライアント CA 証明書を設定した場合にのみ必須です。

ステップ 2：クライアント秘密鍵を PKCS8 (PK8) フォーマットに変換

JDBC はクライアント秘密鍵を PKCS8 (PK8) フォーマットで要求します。アプリケーションが実行されるホストで以下のコマンドを実行してください：

openssl pkcs8 -topk8 -inform PEM -in client.key -outform der -out client.pk8 -v1 PBE-MD5-DES
# プロンプトが表示されたら暗号化パスワードを入力します。このパスワードはコード内で使用します。
Enter Encryption Password:
Verifying - Enter Encryption Password:

ステップ 3：PostgreSQL JDBC ドライバーの依存関係を追加

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

<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <version>42.2.10</version>
</dependency>

ステップ 4：RDS インスタンスへの接続

以下の例では、カスタム証明書 (server-ca.crt) を使用します。クラウド証明書を使用するには、server-ca.crt を ApsaraDB-CA-Chain.pem に置き換えてください。

public class PgSslDemo {
    public static void main(String[] args) {
        // RDS インスタンスのエンドポイント
        String hostname = "pgm-bp1gclw58u36s6****.pg.rds.aliyuncs.com";
        // ポート番号 (デフォルト： 5432)
        String port = "5432";
        // データベース名
        String dbname = "postgres";

        String jdbcUrl = "jdbc:postgresql://" + hostname + ":" + port + "/" + dbname + "?binaryTransfer=true";

        Properties properties = new Properties();
        // データベースアカウントのユーザー名
        properties.setProperty("user", "test_user");
        // データベースアカウントのパスワード
        properties.setProperty("password", "test_pwd");
        // 証明書ファイルが保存されているディレクトリ
        String path = "D:\\ssl\\";

        // SSL を有効にする
        properties.setProperty("ssl", "true");
        // サーバー CA 証明書へのパス
        properties.setProperty("sslrootcert", path + "/" + "server-ca.crt");
        // クライアント秘密鍵へのパス (PKCS8 フォーマット)
        properties.setProperty("sslkey", path + "/" + "client.pk8");
        // クライアント証明書へのパス
        properties.setProperty("sslcert", path + "/" + "client.crt");
        // client.key を PKCS8 フォーマットに変換する際に設定した暗号化パスワード
        properties.setProperty("sslpassword", "test_ssl_pwd");

        // SSL モード： require、verify-ca、または verify-full
        properties.setProperty("sslmode", "verify-ca");

        try {
            Class.forName("org.postgresql.Driver");
            Connection connection = DriverManager.getConnection(jdbcUrl, properties);
            // 例： students01 テーブルからすべての行をクエリする
            PreparedStatement preparedStatement = connection.prepareStatement("select * from students01");
            ResultSet resultSet = preparedStatement.executeQuery();
            while (resultSet.next()) {
                ResultSetMetaData rsmd = resultSet.getMetaData();
                int columnCount = rsmd.getColumnCount();
                Map map = new HashMap();
                for (int i = 0; i < columnCount; i++) {
                    map.put(rsmd.getColumnName(i + 1).toLowerCase(), resultSet.getObject(i + 1));
                }
                System.out.println(map);
            }
        } catch (Exception exception) {
            exception.printStackTrace();
        }
    }
}