ApsaraDB RDS:ApsaraDB RDS for MySQL インスタンスに SSL 経由で接続する

Java

MySQL Connector/J (mysql-connector-java) は、MySQL の公式 JDBC ドライバーです。この例では、mysql-connector-java 8.0.19 が依存関係として使用されています。

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.19</version>
</dependency>

サンプルコード:

package com.aliyun.sample;

import com.mysql.cj.jdbc.MysqlDataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class Sample {

    public static void main(String[] args) {

        Connection conn = null;
        MysqlDataSource mysqlDS=null;

        try{
            mysqlDS = new MysqlDataSource();
            // ビジネス要件に基づいて sslMode プロパティを指定できます。このプロパティのオプションの詳細については、このトピックの「CLI」セクションの説明をご参照ください。
            mysqlDS.setSslMode("VERIFY_IDENTITY");
          
            // トラストストアは CA 証明書を格納するために使用されます。この例では、トラストストアの種類は JKS に設定されています。
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // file:/ に続くコンテンツを、実際の ApsaraDB-CA-Chain.jks ファイルへのパスに置き換える必要があります。
            mysqlDS.setTrustCertificateKeyStoreUrl("file:/D:\\ApsaraDB-CA-Chain\\ApsaraDB-CA-Chain.jks");
            // ダウンロードした JKS ファイルのパスワードは apsaradb に固定されています。
            mysqlDS.setTrustCertificateKeyStorePassword("apsaradb");
          
            // RDS インスタンスのエンドポイント。
            mysqlDS.setServerName("rm-xxxxxx.mysql.rds.aliyuncs.com");
            // RDS インスタンスのポート番号。
            mysqlDS.setPort(3306);
            // RDS インスタンスへの接続に使用するアカウントのユーザー名。
            mysqlDS.setUser("xxxxxx");
            // RDS インスタンスへの接続に使用するアカウントのパスワード。
            mysqlDS.setPassword("xxxxxx");
            // RDS インスタンスで接続するデータベースの名前。
            mysqlDS.setDatabaseName("xxxxxx");

            conn = mysqlDS.getConnection();

        }catch(Exception e){
            e.printStackTrace();
        } finally {
            try {
                if (conn != null)
                    conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}

Python

# pip install pymysql コマンドを実行して PyMySQL をインストールします。

import pymysql

try:
    ssl_config = {"ca":"/path/to/path/ca.crt", "mode":"VERIFY_CA"} # ca を証明書へのパスに、mode を使用する SSL モードに設定する必要があります。
    conn = pymysql.connect(host='******.mysql.rds.aliyuncs.com', user='*****', passwd='******', db='*****', ssl=ssl_config)
    cursor = conn.cursor()
    cursor.execute('select version()')
    data = cursor.fetchone()
    print('Database version:', data[0])
    cursor.close()
except pymysql.Error as e:
    print(e)

Java

MySQL Connector/J (mysql-connector-java) は MySQL の公式 JDBC ドライバーです。この例では、mysql-connector-java 8.0.19 が依存関係として使用されています。

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.19</version>
</dependency>

1. OpenSSL を使用して、クライアント証明書と秘密鍵を PKCS#12 ファイルに変換します。keytool ユーティリティは、PEM 形式の秘密鍵または証明書をサポートしていません。

   openssl pkcs12 -export -in {カスタム CA 証明書} -inkey {カスタム CA 証明書の秘密鍵} -out keystore.p12 -name ganyang -CAfile {カスタム CA 証明書}
   # RDS インスタンスへの接続に使用するパスワードを入力します。
   Enter Encryption Password:
   Verifying - Enter Encryption Password:

2. keytool を使用して、新しく作成された PKCS#12 ファイルを新しい JKS ファイルにインポートします。

   keytool -importkeystore -deststorepass JKS-password -destkeypass key-password -destkeystore keystore.jks -deststoretype pkcs12 -srckeystore keystore.p12 -srcstoretype pkcs12 -srcstorepass P12-password -alias your-alias

   パラメーターの説明:

   -deststorepass: JKS ファイルに指定されたパスワード。
   -destkeypass: JKS ファイルのキーに指定されたパスワード。
   -destkeystore: 作成する JKS ファイル、または既存の JKS ファイル。
   -deststoretype: 作成するファイルの形式は PKCS#12 です。
   -srckeystore: 以前に作成された PKCS#12 ファイル。
   -srcstoretype: ソースファイルの形式は PKCS#12 です。
   -srcstorepass: PKCS#12 ファイルを保護するために使用されるパスワード。
   -alias: ユーザーのクライアント証明書と秘密鍵に指定されたエイリアス。

3. 作成された JKS ファイルを取得します。keytool ベースのインポートが成功すると、実行ディレクトリに keystore.jks ファイルがあります。

package com.aliyun.sample;

import com.mysql.cj.jdbc.MysqlDataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class Sample {

    public static void main(String[] args) {

        Connection conn = null;
        MysqlDataSource mysqlDS=null;

        try{
            mysqlDS = new MysqlDataSource();
            // ビジネス要件に基づいて sslMode プロパティを指定できます。このプロパティのオプションの詳細については、このトピックの「CLI」セクションの説明をご参照ください。
            mysqlDS.setSslMode("VERIFY_IDENTITY");

            // 次のコードは、クラウド証明書の JKS ファイルを使用する方法の例を示しています。カスタム証明書を使用する場合は、関連するパラメーターを、カスタム証明書を使用して生成された JKS ファイルのパスとパスワードに置き換える必要があります。
            // トラストストアは CA 証明書を格納するために使用されます。この例では、トラストストアの種類は JKS に設定されています。
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // file:/ に続くコンテンツを実際の ApsaraDB-CA-Chain.jks ファイルへのパスに置き換える必要があります。
            mysqlDS.setTrustCertificateKeyStoreUrl("file:/D:\\ApsaraDB-CA-Chain\\ApsaraDB-CA-Chain.jks");
            // ダウンロードした JKS ファイルのパスワードは apsaradb に固定されています。
            mysqlDS.setTrustCertificateKeyStorePassword("apsaradb");
          
            // RDS インスタンスのエンドポイント。
            mysqlDS.setServerName("rm-xxxxxx.mysql.rds.aliyuncs.com");
            // RDS インスタンスのポート番号。
            mysqlDS.setPort(3306);
            // RDS インスタンスへの接続に使用するアカウントのユーザー名。
            mysqlDS.setUser("xxxxxx");
            // RDS インスタンスへの接続に使用するアカウントのパスワード。
            mysqlDS.setPassword("xxxxxx");
            // RDS インスタンスで接続するデータベースの名前。
            mysqlDS.setDatabaseName("xxxxxx");

            conn = mysqlDS.getConnection();

        }catch(Exception e){
            e.printStackTrace();
        } finally {
            try {
                if (conn != null)
                    conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}

Python

# pip install pymysql コマンドを実行して PyMySQL をインストールします。

import pymysql

try:
    ssl_config = {"ca":"/path/to/path/ca.crt", "mode":"VERIFY_CA"} # ca を証明書へのパスに、mode を使用する SSL モードに設定する必要があります。
    conn = pymysql.connect(host='******.mysql.rds.aliyuncs.com', user='*****', passwd='******', db='*****', ssl=ssl_config)
    cursor = conn.cursor()
    cursor.execute('select version()')
    data = cursor.fetchone()
    print('Database version:', data[0])
    cursor.close()
except pymysql.Error as e:
    print(e)