PolarDB：設定SSL加密

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.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");
          
            //truststore用於儲存CA認證，這裡設定truststore類型為JKS。
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // 請將file:/後面的路徑改為您的ApsaraDB-CA-Chain.jks檔案的路徑。
            mysqlDS.setTrustCertificateKeyStoreUrl("file://{CA憑證路徑}/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': '{CA憑證路徑}/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("資料庫連接已關閉。")