ApsaraDB RDS:EncJDBC

Cara kerja

EncJDBC menggunakan proses dua langkah:

1. Saat koneksi, EncJDBC mendistribusikan MEK Anda ke server menggunakan Enkripsi amplop, memastikan kunci tidak pernah dikirim dalam bentuk teks biasa.

2. Untuk setiap kueri, EncJDBC secara otomatis mengenkripsi parameter yang ditujukan ke kolom terenkripsi dan mendekripsi hasilnya sebelum mengembalikannya ke aplikasi Anda.

Kode aplikasi Anda tetap bekerja dengan nilai teks biasa—tidak diperlukan perubahan pada logika kueri.

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Fitur always-confidential database diaktifkan pada instans ApsaraDB RDS for MySQL Anda. Lihat Aktifkan fitur always-confidential database.

• Detail koneksi untuk instans: hostname, port, nama database, username, dan password.

• Aturan perlindungan data yang telah dikonfigurasi. Lihat Konfigurasikan aturan perlindungan data.

• JDK 1.8 atau versi yang lebih baru.

Contoh dalam topik ini menggunakan Maven 3.9.2 dan IntelliJ IDEA Community Edition 2022.3.2.

Tambahkan dependensi Maven

Tambahkan dependensi berikut ke file pom.xml proyek Anda:

<dependencies>
  <dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-encdb-mysql-jdbc</artifactId>
    <version>1.0.9-1</version>
  </dependency>
</dependencies>

Konfigurasi dan koneksi

EncJDBC menggunakan format URL JDBC jdbc:mysql:encdb://{hostname}:{port}/{dbname} dan kelas driver com.aliyun.encdb.mysql.jdbc.EncDriver.

Sebelum melakukan koneksi, konfigurasikan dua parameter yang diperlukan:

Algoritma enkripsi yang didukung:

Hindari AES_128_ECB dan SM4_128_ECB—mode ini tidak memberikan jaminan keamanan yang kuat.

// Ganti placeholder dengan detail koneksi instans Anda.
String hostname = "<hostname>";
String port     = "<port>";
String dbname   = "<dbname>";
String username = "<username>";
String password = "<password>";

String mek     = "<your-mek>";   // string heksadesimal 32 karakter
String encAlgo = "<enc-algo>";   // contoh: SM4_128_GCM

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

String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");
Connection connection = DriverManager.getConnection(dbUrl, props);

MEK=<your-mek>
ENC_ALGO=<enc-algo>

String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");
Connection connection = DriverManager.getConnection(dbUrl, username, password);

String dbUrl = String.format(
    "jdbc:mysql:encdb://%s:%s/%s?MEK=%s&ENC_ALGO=%s",
    hostname, port, dbname, mek, encAlgo
);
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");
Connection connection = DriverManager.getConnection(dbUrl, username, password);

Contoh lengkap

Contoh berikut menggunakan JDBC properties untuk terhubung, memasukkan baris ke tabel, dan mengambil hasil teks biasa.

// Ganti placeholder dengan detail koneksi instans Anda.
String hostname = "hostname";
String port     = "port";
String dbname   = "db";
String username = "user";
String password = "password";

// Gunakan MEK yang kuat dan dihasilkan secara acak di lingkungan produksi.
String mek     = "00112233445566778899aabbccddeeff";
String encAlgo = "SM4_128_CBC";

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

String dbUrl = String.format("jdbc:mysql:encdb://%s:%s/%s", hostname, port, dbname);
Class.forName("com.aliyun.encdb.mysql.jdbc.EncDriver");
Connection connection = DriverManager.getConnection(dbUrl, props);

int[]    intData = {1, 2, 3, 4, 5, 6};
String[] strData = {"abc", "bcd", "1", "def", "efg", "fgi"};

// Buat tabel.
connection.createStatement().executeUpdate("drop table if exists test");
connection.createStatement().executeUpdate("create table test (a int, b text)");

// Masukkan baris menggunakan PreparedStatement.
// EncJDBC secara otomatis mengenkripsi nilai yang ditujukan ke kolom terenkripsi.
for (int i = 0; i < 6; i++) {
    PreparedStatement pstmt = connection.prepareStatement("insert into test values (?,?)");
    pstmt.setInt(1, intData[i]);
    pstmt.setString(2, strData[i]);
    pstmt.executeUpdate();
}

// Ambil baris. EncJDBC secara otomatis mendekripsi hasil sebelum mengembalikannya.
ResultSet rs = connection.createStatement().executeQuery("select * from test");
while (rs.next()) {
    for (int i = 0; i < rs.getMetaData().getColumnCount(); i++) {
        System.out.print(rs.getString(i + 1));
        System.out.print("\t");
    }
    System.out.print("\n");
}

Output yang diharapkan:

1	abc
2	bcd
3	cde
4	def
5	efg
6	fgi

Perhatikan hal berikut:

• Semua operasi baca dan tulis ke kolom terenkripsi dilakukan melalui PreparedStatement. Driver secara otomatis mengenkripsi parameter dan mendekripsi hasil—tidak diperlukan perubahan pada logika kueri Anda.

• Nilai yang diteruskan ke kolom yang tidak terenkripsi tidak terpengaruh.

Pemecahan masalah

--add-exports=java.base/com.sun.crypto.provider=ALL-UNNAMED