ApsaraDB RDS:SSL 経由で ApsaraDB RDS for MySQL に接続する

Java

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 を設定します。使用可能なオプションについては、MySQL 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");
          
            // データベースエンドポイント
            mysqlDS.setServerName("rm-xxxxxx.mysql.rds.aliyuncs.com");
            // データベースポート
            mysqlDS.setPort(3306);
            // データベースユーザー名
            mysqlDS.setUser("xxxxxx");
            // データベースパスワード
            mysqlDS.setPassword("xxxxxx");
            // データベース名
            mysqlDS.setDatabaseName("xxxxxx");

            conn = mysqlDS.getConnection();

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

}

Python

# pymysql をインストールします：pip install pymysql

import pymysql

try:
    ssl_config = {"ca":"/path/to/path/ca.crt", "mode":"VERIFY_CA"}   # "ca" は CA 証明書のパス、"mode" は ssl-mode です。
    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

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. keytool ユーティリティは PEM 形式からのプライベートキーと証明書のインポートを直接サポートしていないため、OpenSSL を使用してクライアント証明書とプライベートキーを PKCS#12 形式に変換します。

   openssl pkcs12 -export -in {custom-ca-certificate} -inkey {custom-ca-private-key} -out keystore.p12 -name ganyang -CAfile {custom-ca-certificate}
   # パスワードを入力します。このパスワードは接続を確立する際に必要です。
   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 ファイルの取得：インポートが成功したら、実行ディレクトリで 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 を設定します。使用可能なオプションについては、MySQL CLI セクションをご参照ください。
            mysqlDS.setSslMode("VERIFY_IDENTITY");

            // トラストストアの値は、カスタム証明書から生成した JKS ファイルのパスとパスワードに置き換えてください。
            // トラストストアは CA 証明書を保存します。トラストストアのタイプは JKS に設定されています。
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // file:/ の後のパスを、カスタム JKS ファイルのパスに置き換えてください。
            mysqlDS.setTrustCertificateKeyStoreUrl("file:/path/to/your/keystore.jks");
            // カスタム JKS ファイル作成時に設定したパスワードを使用してください。
            mysqlDS.setTrustCertificateKeyStorePassword("{your-jks-password}");
          
            // データベースエンドポイント
            mysqlDS.setServerName("rm-xxxxxx.mysql.rds.aliyuncs.com");
            // データベースポート
            mysqlDS.setPort(3306);
            // データベースユーザー名
            mysqlDS.setUser("xxxxxx");
            // データベースパスワード
            mysqlDS.setPassword("xxxxxx");
            // データベース名
            mysqlDS.setDatabaseName("xxxxxx");

            conn = mysqlDS.getConnection();

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

}

Python

# pymysql をインストールします：pip install pymysql

import pymysql

try:
    ssl_config = {"ca":"/path/to/path/ca.crt", "mode":"VERIFY_CA"}   # "ca" は CA 証明書のパス、"mode" は ssl-mode です。
    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)