PolarDB:Integrasikan EncJDBC

Langkah 1: Konfigurasikan izin akses KMS

1. Peroleh Pasangan Kunci Akses: Dapatkan AccessKey ID dan AccessKey secret dari RAM user. Hal ini memungkinkan aplikasi Anda mengambil master encryption key (MEK) yang dikelola oleh Key Management Service (KMS).

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

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

2. Berikan izin kepada RAM user:

   1. Buka RAM console. Di panel navigasi kiri, pilih Permission Management > Policies. Klik Create Policy. Beralih ke tab JSON, salin konten berikut, lalu klik OK. Masukkan nama untuk membuat kebijakan.

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

   2. Kembali ke RAM console. Di panel navigasi kiri, pilih Identity Management > Users. Temukan RAM user target, klik Add Permissions di kolom Actions, dan berikan access policy yang baru dibuat kepada user tersebut. Hal ini memungkinkan PolarDB mendekripsi data secara dinamis.

3. Peroleh titik akhir instans KMS:

   • Titik akhir VPC (default): Secara default, kunci dalam instans KMS hanya dapat diakses dari jaringan VPC. Buka halaman manajemen instans KMS, pilih wilayah instans, temukan instans KMS target, lalu klik Details di kolom Actions. Di tab Basic Information, lihat VPC endpoint instans tersebut.

   • Titik akhir publik: Jika Anda perlu mengakses key melalui internet, Anda harus mengaktifkan akses publik di tab Multi-account Key. Setelah akses publik diaktifkan, Anda dapat melihat Public network address di tab Basic Information.

Langkah 2: Instal dependensi

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

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

Langkah 3: Konfigurasikan MEK

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

// Siapkan informasi koneksi, seperti hostname, port, nama 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";
// Peroleh 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 temporary STS access credential untuk membaca kunci KMS, Anda juga harus menyediakan STS token yang diperoleh.
// String stsToken= "yourSecurityToken";
// Untuk titik akhir instans KMS, gunakan titik akhir publik untuk akses internet atau titik akhir VPC 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 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 hostname, port, nama 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";
// Peroleh 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 temporary STS access credential untuk membaca kunci KMS, Anda juga harus menyediakan STS token yang diperoleh.
// String stsToken= "yourSecurityToken";
// Untuk titik akhir instans KMS, gunakan titik akhir publik untuk akses internet atau titik akhir VPC untuk akses dalam VPC.
String kmsEndpoint = "your-kms-endpoint";
// Sematkan parameter kunci KMS dalam URL koneksi.
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 STS token.
// 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);
// 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

Setelah terhubung ke database, Anda dapat melakukan operasi database seperti pada kueri JDBC standar. 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");
// Iterasi 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

import java.sql.*;
import java.util.Properties;
public class EncryptedColumnAccess {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // Ganti informasi koneksi berikut dengan detail instans Anda, seperti hostname, port, nama 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";
        // Peroleh 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 temporary STS access credential untuk membaca kunci KMS, Anda juga harus menyediakan STS token yang diperoleh.
        // String stsToken= "yourSecurityToken";
        // Untuk titik akhir instans KMS, gunakan titik akhir publik untuk akses internet atau titik akhir VPC 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");
            // Iterasi set hasil.
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("username");
                String phone = resultSet.getString("phone");
                // Proses bidang 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: Client mengirimkan MEK ke server database melalui protokol enkripsi asimetris yang aman. Hal ini memungkinkan client dan server berbagi key yang sama, sehingga memungkinkan transmisi data aman melalui enkripsi simetris.

Persyaratan nilai: String heksadesimal 16 byte (panjang 32 karakter). Contohnya, 00112233445566778899aabbccddeeff.

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

Contoh

• Pada Linux, gunakan tool OpenSSL bawaan. Jalankan openssl rand -hex 16 untuk menghasilkan key.

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

• Pada Windows, instal paket OpenSSL.

Langkah 2: Instal dependensi

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

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

Langkah 3: Konfigurasikan MEK

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

// Siapkan informasi koneksi, seperti hostname, port, nama 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";
// Kunci enkripsi utama.
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 hostname, port, nama 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";
 // Kunci enkripsi utama.
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

Setelah terhubung ke database, Anda dapat melakukan operasi database seperti pada kueri JDBC standar. 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");
// Iterasi 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

import java.sql.*;
import java.util.Properties;
public class EncryptedColumnAccess {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // Ganti informasi koneksi berikut dengan detail instans Anda, seperti hostname, port, nama 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. Kami menyarankan agar Anda menggunakan 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");
            // Iterasi set hasil.
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("username");
                String phone = resultSet.getString("phone");
                // Proses bidang 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();
        }
    }
}