PolarDB:SSL 暗号化の設定

Java

Connector/J (mysql-connector-java) は、MySQL が提供する公式の Java Database Connectivity (JDBC) ドライバーです。この例では、依存関係として mysql-connector-java バージョン 8.0.19 を使用します。

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

サンプルコード：

package com.example.ssltest;

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

public class Main {
    public static void main(String[] args) {
       Connection conn = null;
        MysqlDataSource mysqlDS=null;

        try{
            mysqlDS = new MysqlDataSource();
            // 必要に応じて SslMode を設定します。このプロパティのオプションの詳細については、コマンドライン接続方法をご参照ください。
            mysqlDS.setSslMode("VERIFY_IDENTITY");
          
            // トラストストアは CA 証明書を格納するために使用されます。トラストストアのタイプを JKS に設定します。
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // file:// の後のパスを、ご自身の ApsaraDB-CA-Chain.jks ファイルのパスに置き換えます。
            mysqlDS.setTrustCertificateKeyStoreUrl("file://{path_to_CA_certificate}/ApsaraDB-CA-Chain.jks");
            // ダウンロードした JKS ファイルのパスワードは apsaradb であり、変更できません。
            mysqlDS.setTrustCertificateKeyStorePassword("apsaradb");
          
            // ご利用のデータベースエンドポイント
            mysqlDS.setServerName("your_polardb_host");
            // ご利用のデータベースポート
            mysqlDS.setPort(3306);
            // ご利用のデータベースユーザー名
            mysqlDS.setUser("your_username");
            // ご利用のデータベースパスワード
            mysqlDS.setPassword("your_password");
            // ご利用のデータベース名
            mysqlDS.setDatabaseName("your_database");

            System.out.println("データベースへの接続を試みています...");
            conn = mysqlDS.getConnection();
            System.out.println("データベース接続に成功しました！");
            
            // try-with-resources を使用して、Statement と ResultSet が自動的にクローズされるようにします
            try (Statement stmt = conn.createStatement();
                 ResultSet rs = stmt.executeQuery("SELECT VERSION()")) {
                
                // クエリが結果を返したかどうかを確認します
                if (rs.next()) {
                    // 最初の列から結果を取得して出力します
                    String dbVersion = rs.getString(1);
                    System.out.println("データベースのバージョン: " + dbVersion);
                } else {
                    System.out.println("データベースのバージョン情報の取得に失敗しました。");
                }
            }

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

Python

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

import pymysql

# --- データベース情報を設定します ---
db_config = {
    'host': 'your_polardb_host',          # ご利用のクラスターエンドポイント
    'user': 'your_username',            # ご利用のユーザー名
    'password': 'your_password',        # ご利用のパスワード
    'database': 'your_database',        # 接続したいデータベース
    'port': 3306
}

# --- SSL 情報を設定します ---
ssl_args = {
    'ca': '{path_to_CA_certificate}/ApsaraDB-CA-Chain.pem',
    'mode': 'VERIFY_CA'
}

try:
    # 接続を確立し、ssl パラメーターを渡します
    print("SSL を使用して MySQL への接続を試みています...")
    connection = pymysql.connect(**db_config, ssl=ssl_args)
    print("SSL 接続に成功しました！")

    with connection.cursor() as cursor:
        # 簡単なクエリを実行して接続を検証します
        cursor.execute("SELECT VERSION()")
        version = cursor.fetchone()
        print(f"データベースのバージョン: {version[0]}")

except pymysql.MySQLError as e:
    # SSL 関連のエラーを出力すると役立ちます
    print(f"接続に失敗しました: {e}")
finally:
    if 'connection' in locals() and connection.open:
        connection.close()
        print("データベース接続が閉じられました。")