ApsaraDB RDS：Gunakan driver enkripsi kolom berbasis JDBC

Langkah 1: Konfigurasikan dependensi Maven

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

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

Langkah 2: Konfigurasikan URL dan MEK

Sebelum menggunakan driver enkripsi kolom berbasis JDBC untuk mengakses kolom terenkripsi, konfigurasikan parameter yang diperlukan, termasuk MEK dan URL untuk menghubungkan ke instance RDS.

Konfigurasikan MEK

Berikut adalah metode yang dapat digunakan untuk mengonfigurasi MEK. Jika menggunakan lebih dari satu metode, prioritas diberikan dalam urutan berikut: konfigurasi properti JDBC, file konfigurasi, dan konfigurasi URL.

// Dapatkan informasi koneksi seperti Titik akhir (hostname), nomor port (port), nama instance (dbname), nama pengguna (username), dan kata sandi (password).
// ...

String mek=****;

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


String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);
Connection connection = DriverManager.getConnection(dbUrl, props);

// ... Mulai query. ...

MEK=****

// Dapatkan informasi koneksi seperti Titik akhir (hostname), nomor port (port), nama instance (dbname), nama pengguna (username), dan kata sandi (password).
// ...

String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... Mulai query. ...

// Dapatkan informasi koneksi seperti Titik akhir (hostname), nomor port (port), nama instance (dbname), nama pengguna (username), dan kata sandi (password).
// ...

String mek=****;

String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s?MEK=%s", hostname, port, dbname, mek);
Connection connection = DriverManager.getConnection(dbUrl, username, password);

// ... Mulai query. ...

Contoh kode lengkap

Potongan kode berikut menunjukkan cara menggunakan properti JDBC untuk mengonfigurasi MEK. Sebelum menggunakan driver enkripsi kolom berbasis JDBC untuk mengakses kolom terenkripsi, selesaikan pengaturan enkripsi kolom pada instance RDS Anda.

package org.example;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class Main {
    public static void main(String[] args) throws SQLException {
        // Perbarui informasi koneksi, termasuk hostname, port, dbname, username, dan password, sesuai dengan kebutuhan bisnis Anda.
        String hostname = "pgm-****.pg.rds.aliyuncs.com"; // Titik akhir instance RDS. Anda harus menggunakan Titik akhir yang sebenarnya.
        String port = "5432"; // Nomor port database. Anda harus menggunakan nomor port yang sebenarnya.
        String dbname = "testdb"; // Nama database. Anda harus menggunakan nama database yang sebenarnya.
        String username = "user"; // Nama pengguna akun yang digunakan untuk masuk ke database. Anda harus menggunakan nama pengguna yang memiliki izin ciphertext permission (JDBC decryption).
        String password = "password"; // Kata sandi akun yang digunakan untuk masuk ke database.
        
        // Contoh MEK. Kami merekomendasikan agar Anda menggunakan MEK yang kuat untuk memastikan keamanan.
        String MEK = "00112233445566778899aabbccddeeff";
        
       // Buat properti koneksi database.
        Properties props = new Properties();
        props.setProperty("user", username);
        props.setProperty("password", password);
        props.setProperty("MEK", MEK);

        // Format URL yang digunakan untuk menghubungkan ke database.
        String dbUrl = String.format("jdbc:postgresql:encdb://%s:%s/%s", hostname, port, dbname);

        // Gunakan DriverManager untuk mendapatkan koneksi database.
        Connection connection = DriverManager.getConnection(dbUrl, props);

        // Jalankan query untuk mendapatkan data dalam tabel uji.
        ResultSet rs = connection.createStatement().executeQuery("SELECT * FROM test_table");
        while (rs.next()) {
            for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) { // Indeks kolom dimulai dari 1.
                System.out.print(rs.getString(i) + "\t");
            }
            System.out.println(); // Baris baru.
        }

        // Nonaktifkan sumber daya.
        rs.close();  // Tutup set hasil.
        connection.close(); // Tutup koneksi.
    }
}