PolarDB:Konfigurasikan enkripsi SSL

Java

Connector/J (mysql-connector-java) adalah driver JDBC resmi untuk MySQL. Contoh ini menggunakan mysql-connector-java versi 8.0.19 sebagai dependensi.

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

Kode contoh:

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();
            // Setel SslMode sesuai kebutuhan. Untuk opsi, lihat petunjuk koneksi command-line.
            mysqlDS.setSslMode("VERIFY_IDENTITY");
            // Truststore berisi sertifikat CA. Atur jenis truststore ke JKS.
            mysqlDS.setTrustCertificateKeyStoreType("JKS");
            // Ganti jalur setelah file:/ dengan jalur file ApsaraDB-CA-Chain.jks Anda.
            mysqlDS.setTrustCertificateKeyStoreUrl("file://{CA certificate path}/ApsaraDB-CA-Chain.jks");
            // Kata sandi untuk file JKS yang diunduh adalah apsaradb dan tidak dapat diubah.
            mysqlDS.setTrustCertificateKeyStorePassword("apsaradb");
            // Titik akhir database Anda
            mysqlDS.setServerName("your_polardb_host");
            // Port database Anda
            mysqlDS.setPort(3306);
            // Username database Anda
            mysqlDS.setUser("your_username");
            // Password database Anda
            mysqlDS.setPassword("your_password");
            // Nama database Anda
            mysqlDS.setDatabaseName("your_database");
            System.out.println("Mencoba terhubung ke database...");
            conn = mysqlDS.getConnection();
            System.out.println("Koneksi database berhasil!");
            // Gunakan try-with-resources untuk memastikan Statement dan ResultSet ditutup secara otomatis.
            try (Statement stmt = conn.createStatement();
                 ResultSet rs = stmt.executeQuery("SELECT VERSION()")) {
                // Periksa apakah kueri mengembalikan hasil.
                if (rs.next()) {
                    // Ambil hasil dari kolom pertama dan cetak.
                    String dbVersion = rs.getString(1);
                    System.out.println("Versi database: " + dbVersion);
                } else {
                    System.out.println("Gagal mengambil informasi versi database.");
                }
            }
        }catch(Exception e){
            e.printStackTrace();
        } finally {
            try {
                if (conn != null)
                    conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

Python

# Instal pymysql
# pip install pymysql
import pymysql
# --- Konfigurasikan informasi database Anda ---
db_config = {
    'host': 'your_polardb_host',          # Titik akhir kluster Anda
    'user': 'your_username',            # Username Anda
    'password': 'your_password',        # Password Anda
    'database': 'your_database',        # Database yang ingin Anda hubungi
    'port': 3306
}
# --- Konfigurasikan informasi SSL ---
ssl_args = {
    'ca': '{CA certificate path}/ApsaraDB-CA-Chain.pem',
    'mode': 'VERIFY_CA'
}
try:
    # Buat koneksi, dengan melewatkan parameter ssl
    print("Mencoba terhubung ke MySQL dengan SSL...")
    connection = pymysql.connect(**db_config, ssl=ssl_args)
    print("Koneksi SSL berhasil!")
    with connection.cursor() as cursor:
        # Jalankan kueri sederhana untuk memverifikasi koneksi
        cursor.execute("SELECT VERSION()")
        version = cursor.fetchone()
        print(f"Versi database: {version[0]}")
except pymysql.MySQLError as e:
    # Mencetak kesalahan terkait SSL dapat membantu troubleshooting
    print(f"Koneksi gagal: {e}")
finally:
    if 'connection' in locals() and connection.open:
        connection.close()
        print("Koneksi database ditutup.")