PolarDB:Integrasikan EncJDBC

Langkah 1: Konfigurasikan izin akses KMS

1. Dapatkan pasangan AccessKey: Dapatkan AccessKey ID dan AccessKey secret dari pengguna RAM. Hal ini memungkinkan aplikasi Anda memperoleh Master Encryption Key (MEK) yang dikelola oleh KMS.

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

   2. Jika Anda belum memiliki pengguna RAM yang sesuai, buka Konsol RAM. Di panel navigasi 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 kiri, pilih Permission Management > Policies. Klik Create Policy. Beralih ke editor skrip, salin konten berikut, lalu klik OK. Masukkan nama kebijakan untuk membuat kebijakan tersebut.

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

   2. Kembali ke Konsol RAM. Di panel navigasi kiri, pilih Identity Management > Users. Temukan pengguna RAM target, klik Add Permissions di kolom Actions, lalu berikan kebijakan akses yang baru dibuat kepada pengguna tersebut. Hal ini memungkinkan aplikasi klien mendekripsi data menggunakan KMS.

3. Dapatkan titik akhir instans KMS:

   • Titik akhir VPC (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, di tab Basic Information, lihat titik akhir VPC instans tersebut.

   • Titik akhir publik: Untuk mengakses kunci melalui internet, aktifkan akses publik di tab RD Multi-Account. Setelah Anda mengaktifkan akses publik, Anda dapat melihat Public network address di tab Basic Information.

Langkah 2: Tambahkan 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 parameter koneksi

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

// Siapkan informasi koneksi, seperti titik akhir (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";

// 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 harus menentukan token keamanan yang diperoleh.
// String stsToken = "yourSecurityToken";

// Tentukan 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);

// 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);

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

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

// ... Eksekusi kueri ...

// Siapkan informasi koneksi, seperti titik akhir (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";

// 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 harus menentukan token keamanan yang diperoleh.
// String stsToken = "yourSecurityToken";

// Tentukan titik akhir instans KMS. Gunakan titik akhir publik untuk akses internet atau titik akhir VPC 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);

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

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

// ... Eksekusi kueri ...

Langkah 4: Kueri data

Setelah terhubung ke database, Anda dapat melakukan operasi database seperti halnya kueri JDBC biasa. EncJDBC secara otomatis mendekripsi data di kolom terenkripsi dan mengembalikannya sebagai 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 detail koneksi berikut dengan informasi instans Anda, seperti hostname, port, 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 harus menentukan token keamanan yang diperoleh.
        // String stsToken = "yourSecurityToken";

        // Tentukan 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);

        // Eksekusi 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: Klien mengirimkan MEK ke server database secara aman menggunakan enkripsi amplop, sehingga kunci tidak pernah terekspos dalam bentuk teks biasa selama transit.

Rentang nilai: String heksadesimal 16 byte (32 karakter). Contoh: 00112233445566778899aabbccddeeff.

Metode umum pembuatan: Gunakan tool pembuatan password atau fungsi acak dalam bahasa pemrograman.

Contoh

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

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

• Pada sistem Windows, instal paket OpenSSL.

Langkah 2: Tambahkan 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: Mengonfigurasi koneksi MEK database

Anda dapat mengonfigurasi MEK menggunakan JDBC properties, file, atau URL. Jika Anda menggunakan dua metode atau lebih, urutan prioritas berikut berlaku: JDBC properties > File > URL.

// Siapkan informasi koneksi, seperti titik akhir (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 master pelanggan.
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);

// ... Eksekusi kueri ...

MEK=00112233445566778899aabbccddeeff

// Siapkan informasi koneksi, seperti titik akhir (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 master pelanggan.
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);

// ... Eksekusi kueri ...

Langkah 4: Kueri data

Setelah terhubung ke database, Anda dapat melakukan operasi database seperti halnya kueri JDBC biasa. EncJDBC secara otomatis mendekripsi data di kolom terenkripsi dan mengembalikannya sebagai 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 detail koneksi berikut dengan informasi instans Anda, seperti hostname, port, 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 adalah contoh kunci. Kami menyarankan agar Anda menggunakan kunci yang lebih kompleks di lingkungan produksi.
        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);

        // Eksekusi 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();
        }
    }
}