PolarDB：Integrasikan EncJDBC

Langkah 1: Konfigurasikan izin akses KMS

1. Dapatkan pasangan AccessKey: Dapatkan AccessKeyId dan AccessKeySecret dari pengguna RAM. Hal ini memungkinkan aplikasi untuk memperoleh kunci enkripsi utama (MEK) yang dikelola oleh KMS.

   1. Jika Anda sudah memiliki pengguna RAM yang sesuai untuk mengakses KMS, Anda dapat menggunakan pengguna tersebut.

   2. Jika belum memiliki pengguna RAM yang sesuai, buka Konsol RAM. Di panel navigasi sebelah kiri, pilih Identity Management > Users. Klik Create User dan ikuti petunjuk di layar untuk membuat pengguna.

2. Berikan izin kepada pengguna RAM:

   1. Buka Konsol RAM. Di panel navigasi sebelah kiri, pilih Permission Management > Access Policies. Klik Create Access Policy. Beralih ke editor skrip, salin konten berikut, lalu klik OK. Masukkan nama kebijakan dan selesaikan pembuatan.

      {
          "Version": "1",
          "Statement": [
              {
                  "Effect": "Allow",
                  "Action": "KMS:Decrypt",
                  "Resource": "*"
              }
          ]
      }

   2. Kembali ke Konsol RAM. Di panel navigasi sebelah kiri, pilih Identity Management > Users. Temukan pengguna RAM target. Di kolom Actions, klik Add Permissions. Berikan kebijakan akses yang baru dibuat kepada pengguna tersebut. Hal ini memungkinkan PolarDB untuk mendekripsi data secara dinamis.

3. Dapatkan titik akhir instans KMS:

   • VPC endpoint (default): Secara default, kunci dalam instans KMS hanya dapat diakses dari dalam VPC. Anda dapat membuka halaman manajemen instans KMS, pilih wilayah tempat instans berada, temukan instans KMS target, lalu klik Details di kolom Actions. Kemudian, pada tab Basic Information, Anda dapat melihat VPC endpoint instans tersebut.

   • Public endpoint: Untuk mengakses kunci melalui Internet, Anda harus mengaktifkan akses jaringan publik pada tab RD Multi-Account. Setelah mengaktifkan akses publik, Anda dapat melihat Public Endpoint pada tab Basic Information.

Langkah 2: Instal dependensi

Tambahkan dependensi berikut ke file pom.xml proyek Maven Anda.

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-cls-jdbc</artifactId>
    <version>1.0.10-1</version>
</dependency>

Langkah 3: Konfigurasikan MEK untuk terhubung ke database

Anda dapat mengonfigurasi MEK menggunakan JDBC properties, file, atau URL. Jika Anda mengonfigurasi JDBC menggunakan dua metode atau lebih, prioritasnya adalah sebagai berikut: konfigurasi JDBC properties > konfigurasi file > konfigurasi URL.

// Siapkan informasi koneksi seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
String hostname = "your-hostname";
String port = "your-port";
String dbname = "your-database-name";
String username = "your-username";
String password = "your-password";

// Dapatkan AccessKey ID dan AccessKey secret dari variabel lingkungan.
String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
// Jika Anda menggunakan kredensial akses STS temporary untuk membaca kunci KMS, Anda juga perlu mengisi token Security Token Service (SecurityToken) yang diperoleh.
// String stsToken= "yourSecurityToken";

// Untuk titik akhir instans KMS, gunakan public endpoint untuk akses jaringan publik. Gunakan instance VPC endpoint untuk akses dalam VPC.
String kmsEndpoint = "your-kms-endpoint";

Properties props = new Properties();
props.setProperty("user", username);
props.setProperty("password", password);
props.setProperty("ALIBABA_CLOUD_ACCESS_KEY_ID", accessKeyId);
props.setProperty("ALIBABA_CLOUD_ACCESS_KEY_SECRET", accessKeySecret);
props.setProperty("ALIBABA_CLOUD_KMS_ENDPOINT", kmsEndpoint);
// props.setProperty("ALIBABA_CLOUD_STS_TOKEN","stsToken");

// Berikut adalah format URL koneksi untuk database MySQL: "jdbc:mysql:encdb://%s:%s/%s".
String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);

// Berikut memuat driver EncJDBC untuk database MySQL.
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

// Dapatkan koneksi database.
Connection connection = DriverManager.getConnection(dbUrl, props);

// ... Lakukan kueri ...

// Siapkan informasi koneksi seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
String hostname = "your-hostname";
String port = "your-port";
String dbname = "your-database-name";
String username = "your-username";
String password = "your-password";

// Dapatkan AccessKey ID dan AccessKey secret dari variabel lingkungan.
String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
// Jika Anda menggunakan kredensial akses STS temporary untuk membaca kunci KMS, Anda juga perlu mengisi token Security Token Service (SecurityToken) yang diperoleh.
// String stsToken= "yourSecurityToken";

// Untuk titik akhir instans KMS, gunakan public endpoint untuk akses jaringan publik. Gunakan instance VPC endpoint untuk akses dalam VPC.
String kmsEndpoint = "your-kms-endpoint";

// Berikut adalah format URL koneksi untuk database MySQL.
String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s?ALIBABA_CLOUD_ACCESS_KEY_ID=%s&ALIBABA_CLOUD_ACCESS_KEY_SECRET=%s&ALIBABA_CLOUD_KMS_ENDPOINT=%s", hostname, port, dbname, accessKeyId, accessKeySecret, kmsEndpoint);
// Gunakan token STS.
// String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s?ALIBABA_CLOUD_ACCESS_KEY_ID=%s&ALIBABA_CLOUD_ACCESS_KEY_SECRET=%s&ALIBABA_CLOUD_KMS_ENDPOINT=%s&ALIBABA_CLOUD_STS_TOKEN=%s", hostname, port, dbname, accessKeyId, accessKeySecret, kmsEndpoint, stsToken);

// Berikut memuat driver EncJDBC untuk database MySQL.
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

// Dapatkan koneksi database.
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... Lakukan kueri ...

Langkah 4: Kueri data teks biasa dari kolom terenkripsi

Setelah berhasil terhubung ke database, Anda dapat melakukan operasi database seperti halnya kueri JDBC biasa. EncJDBC secara otomatis mendekripsi kolom terenkripsi dan mengembalikan data teks biasa.

Contoh

// Buat pernyataan kueri.
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table_name");

// Telusuri set hasil.
while (resultSet.next()) {
    for (int i = 0; i < resultSet.getMetaData().getColumnCount(); i++) {
        System.out.print(resultSet.getString(i + 1));
        System.out.print("\t");
    }
    System.out.print("\n");
}

Lampiran: Contoh kode lengkap

import java.sql.*;
import java.util.Properties;

public class EncryptedColumnAccess {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // Perbarui informasi koneksi berikut dengan detail instans Anda, seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
        String hostname = "your-hostname";
        String port = "your-port";
        String dbname = "your-database-name";
        String username = "your-username";
        String password = "your-password";

        // Dapatkan AccessKey ID dan AccessKey secret dari variabel lingkungan.
        String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
        String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
        // Jika Anda menggunakan kredensial akses STS temporary untuk membaca kunci KMS, Anda juga perlu mengisi token Security Token Service (SecurityToken) yang diperoleh.
        // String stsToken= "yourSecurityToken";

        // Untuk titik akhir instans KMS, gunakan public endpoint untuk akses jaringan publik. Gunakan instance VPC endpoint untuk akses dalam VPC.
        String kmsEndpoint = "your-kms-endpoint";

        Properties props = new Properties();
        props.setProperty("user", username);
        props.setProperty("password", password);
        props.setProperty("ALIBABA_CLOUD_ACCESS_KEY_ID", accessKeyId);
        props.setProperty("ALIBABA_CLOUD_ACCESS_KEY_SECRET", accessKeySecret);
        props.setProperty("ALIBABA_CLOUD_KMS_ENDPOINT", kmsEndpoint);
        // props.setProperty("ALIBABA_CLOUD_STS_TOKEN","stsToken");

        // Format URL koneksi untuk database MySQL adalah "jdbc:mysql:encdb://%s:%s/%s".
        String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);

        // Muat driver EncJDBC.
        Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

        // Dapatkan koneksi database.
        Connection connection = DriverManager.getConnection(dbUrl, props);

        // Lakukan kueri.
        try {
            // Buat pernyataan kueri.
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery("SELECT * FROM users");

            // Telusuri set hasil.
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("username");
                String phone = resultSet.getString("phone");

                // Proses field lain berdasarkan skema tabel Anda.
                System.out.println("ID: " + id + ", Name: " + name + ", Phone: " + phone);
            }

            // Tutup resource.
            resultSet.close();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

Langkah 1: Hasilkan MEK

MEK: MEK dikirim dari klien ke server database menggunakan protokol enkripsi kunci asimetris yang aman. Hal ini memungkinkan server dan klien berbagi kunci yang sama untuk transmisi data aman melalui enkripsi simetris.

Nilai valid: string heksadesimal 16-byte dengan panjang 32 karakter. Misalnya, 00112233445566778899aabbccddeeff.

Metode pembuatan umum: Anda dapat menggunakan tool pembuatan password atau fungsi acak dalam bahasa pemrograman.

Contoh

• Pada Linux, Anda dapat menggunakan tool OpenSSL bawaan. Jalankan openssl rand -hex 16 untuk menghasilkan kunci.

  # Gunakan OpenSSL untuk menghasilkan kunci acak yang aman
  openssl rand -hex 16
  # Contoh output: 11ce9a9489fab7355cf710837cea5d5b

• Pada Windows, Anda dapat menginstal paket OpenSSL.

Langkah 2: Instal dependensi

Tambahkan dependensi berikut ke file pom.xml proyek Maven Anda.

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-cls-jdbc</artifactId>
    <version>1.0.10-1</version>
</dependency>

Langkah 3: Konfigurasikan MEK untuk terhubung ke database

Anda dapat mengonfigurasi MEK menggunakan JDBC properties, file, atau URL. Jika Anda mengonfigurasi JDBC menggunakan dua metode atau lebih, prioritasnya adalah sebagai berikut: konfigurasi JDBC properties > konfigurasi file > konfigurasi URL.

// Siapkan informasi koneksi seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
String hostname = "your-hostname";
String port = "your-port";
String dbname = "your-database-name";
String username = "your-username";
String password = "your-password";

// Customer master key.
String mek = "00112233445566778899aabbccddeeff"; 

Properties props = new Properties();
props.setProperty("user", username);
props.setProperty("password", password);
props.setProperty("MEK", mek);

// Format URL koneksi untuk database MySQL adalah "jdbc:mysql:encdb://%s:%s/%s".
String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);

// Muat driver EncJDBC untuk database MySQL.
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

// Dapatkan koneksi database.
Connection connection = DriverManager.getConnection(dbUrl, props);

// ... Lakukan kueri ...

MEK=00112233445566778899aabbccddeeff

// Siapkan informasi koneksi seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
String hostname = "your-hostname";
String port = "your-port";
String dbname = "your-database-name";
String username = "your-username";
String password = "your-password";

 // Customer master key.
String mek = "00112233445566778899aabbccddeeff";

// Format URL koneksi untuk database MySQL adalah "jdbc:mysql:encdb://%s:%s/%s?MEK=%s".
String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s?MEK=%s", hostname, port, dbname, mek);

// Muat driver EncJDBC untuk database MySQL.
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

// Dapatkan koneksi database.
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... Lakukan kueri ...

Langkah 4: Kueri data teks biasa dari kolom terenkripsi

Setelah berhasil terhubung ke database, Anda dapat melakukan operasi database seperti halnya kueri JDBC biasa. EncJDBC secara otomatis mendekripsi kolom terenkripsi dan mengembalikan data teks biasa.

Contoh

// Buat pernyataan kueri.
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table_name");

// Telusuri set hasil.
while (resultSet.next()) {
    for (int i = 0; i < resultSet.getMetaData().getColumnCount(); i++) {
        System.out.print(resultSet.getString(i + 1));
        System.out.print("\t");
    }
    System.out.print("\n");
}

Lampiran: Contoh kode lengkap

import java.sql.*;
import java.util.Properties;

public class EncryptedColumnAccess {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // Perbarui informasi koneksi berikut dengan detail instans Anda, seperti titik akhir (hostname), port, nama instans database (dbname), username, dan password.
        String hostname = "your-hostname";
        String port = "your-port";
        String dbname = "your-database-name";
        String username = "your-username";
        String password = "your-password";
        
        // Ini hanya contoh. Gunakan kunci yang lebih kompleks.
        String mek="00112233445566778899aabbccddeeff";

        Properties props = new Properties();
        props.setProperty("user", username);
        props.setProperty("password", password);
        props.setProperty("MEK", mek);
        
        // Format URL koneksi untuk database MySQL adalah "jdbc:mysql:encdb://%s:%s/%s".
        String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);

        // Muat driver EncJDBC.
        Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");

        // Dapatkan koneksi database.
        Connection connection = DriverManager.getConnection(dbUrl, props);

        // Lakukan kueri.
        try {
            // Buat pernyataan kueri.
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery("SELECT * FROM users");

            // Telusuri set hasil.
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("username");
                String phone = resultSet.getString("phone");

                // Proses field lain berdasarkan skema tabel Anda.
                System.out.println("ID: " + id + ", Name: " + name + ", Phone: " + phone);
            }

            // Tutup resource.
            resultSet.close();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}