Hologres:JDBC

Langkah 1: Tambahkan dependensi driver

Sebagian besar alat klien SQL menyertakan driver PostgreSQL bawaan — gunakan jika tersedia. Untuk aplikasi Java, tambahkan PostgreSQL JDBC Driver ke proyek Maven Anda. Unduh dari jdbc.postgresql.org/download dan gunakan versi 42.3.2 atau lebih baru (disarankan menggunakan versi stabil terbaru).

Hologres menggunakan PostgreSQL JDBC Driver standar — tidak ada driver khusus Hologres yang perlu diinstal.

Tambahkan dependensi berikut ke file pom.xml Anda:

<dependencies>
    <dependency>
        <groupId>org.postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>42.3.2</version>
    </dependency>
</dependencies>

Langkah 2: Buat string koneksi

Format string koneksi adalah:

jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?user=<ACCESS_ID>&password=<ACCESS_KEY>

Parameter wajib

Parameter opsional

Tambahkan parameter berikut ke string koneksi sesuai kebutuhan. Pisahkan beberapa parameter dengan &.

Contoh string koneksi dengan opsi yang direkomendasikan:

jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?user=<ACCESS_ID>&password=<ACCESS_KEY>&ApplicationName=myApp&reWriteBatchedInserts=true

Langkah 3: Simpan kredensial dalam variabel lingkungan

Hardcoding kredensial dalam string koneksi menimbulkan risiko keamanan. Simpan sebagai variabel lingkungan sebagai gantinya. Di Linux, tambahkan baris berikut ke file ~/.bash_profile Anda:

export ALIBABA_CLOUD_USER=<ACCESS_ID>
export ALIBABA_CLOUD_PASSWORD=<ACCESS_KEY>

Langkah 4: Terhubung dan jalankan kueri

Contoh berikut membaca kredensial dari variabel lingkungan, mengatur properti timeout, terhubung ke Hologres, dan menjalankan kueri SELECT dasar menggunakan Statement standar:

public class HologresTest {

    private void jdbcExample() throws SQLException {
        String user = System.getenv("ALIBABA_CLOUD_USER");
        String password = System.getenv("ALIBABA_CLOUD_PASSWORD");
        String url = String.format(
            "jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?currentSchema=<SCHEMA_NAME>&user=%s&password=%s",
            user, password
        );
        Properties props = new Properties();
        // Atur SOCKET_TIMEOUT berdasarkan waktu eksekusi kueri aktual untuk menghindari
        // timeout prematur sebelum kueri selesai.
        PGProperty.SOCKET_TIMEOUT.set(props, 3600);
        PGProperty.LOGIN_TIMEOUT.set(props, 60);
        PGProperty.TCP_KEEP_ALIVE.set(props, true);
        try (Connection conn = DriverManager.getConnection(url, props)) {
            try (Statement st = conn.createStatement()) {
                String sql = "SELECT * FROM table where xxx limit 100";
                try (ResultSet rs = st.executeQuery(sql)) {
                    while (rs.next()) {
                        // Baca nilai kolom pertama
                        String c1 = rs.getString(1);
                    }
                }
            }
        }
    }
}

Tulis data

Anda dapat menulis data menggunakan mode Statement atau Prepared Statement di JDBC. Gunakan mode Prepared Statement untuk operasi tulis. Dalam mode ini, server menyimpan cache hasil kompilasi SQL, yang mengurangi latensi tulis dan meningkatkan throughput. Atur ukuran batch menjadi kelipatan 256 — ukuran batch minimum yang direkomendasikan adalah 256.

Batch insert

/*
 * Tulis data dalam batch menggunakan mode Prepared Statement.
 * Ukuran batch: 256 baris (minimum yang direkomendasikan).
 */
private static void writeBatchWithPreparedStatement(Connection conn) throws Exception {
    try (PreparedStatement stmt = conn.prepareStatement("insert into test_tb values (?,?,?,?)")) {
        int batchSize = 256;
        for (int i = 0; i < batchSize; ++i) {
            stmt.setInt(1, 1000 + i);
            stmt.setString(2, "1");
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date parsedDate = dateFormat.parse("1990-11-11 00:00:00");
            stmt.setTimestamp(3, new java.sql.Timestamp(parsedDate.getTime()));
            stmt.setDouble(4, 0.1);
            stmt.addBatch();
        }
        stmt.executeBatch();
    }
}

Upsert dengan INSERT ON CONFLICT

Untuk memperbarui baris yang sudah ada saat terjadi konflik, gunakan sintaksis PostgreSQL INSERT ON CONFLICT. Tabel tujuan harus memiliki primary key.

private static void insertOverwrite(Connection conn) throws Exception {
    try (PreparedStatement stmt = conn.prepareStatement(
        "insert into test_tb values (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?), (?,?,?,?) " +
        "on conflict(pk) do update set f1 = excluded.f1, f2 = excluded.f2, f3 = excluded.f3"
    )) {
        int batchSize = 6;
        for (int i = 0; i < batchSize; ++i) {
            stmt.setInt(i * 4 + 1, i);
            stmt.setString(i * 4 + 2, "1");
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date parsedDate = dateFormat.parse("1990-11-11 00:00:00");
            stmt.setTimestamp(i * 4 + 3, new java.sql.Timestamp(parsedDate.getTime()));
            stmt.setDouble(i * 4 + 4, 0.1);
        }
        int affectedRows = stmt.executeUpdate();
        System.out.println("affected rows => " + affectedRows);
    }
}

Contoh berikut menggunakan mode Prepared Statement untuk operasi tulis, yang meningkatkan throughput untuk insert berulang:

private void jdbcPreparedStmtExample() throws SQLException {
    String user = System.getenv("ALIBABA_CLOUD_USER");
    String password = System.getenv("ALIBABA_CLOUD_PASSWORD");
    String url = String.format(
        "jdbc:postgresql://<ENDPOINT>:<PORT>/<DBNAME>?currentSchema=<SCHEMA_NAME>&user=%s&password=%s",
        user, password
    );
    try (Connection conn = DriverManager.getConnection(url)) {
        String sql = "insert into test values" +
                "(?, ?), (?, ?), (?, ?), (?, ?), (?, ?), " +
                "(?, ?), (?, ?), (?, ?), (?, ?), (?, ?)";
        try (PreparedStatement st = conn.prepareStatement(sql)) {
            for (int i = 0; i < 10; ++i) {
                for (int j = 0; j < 2 * 10; ++j) {
                    st.setString(j + 1, UUID.randomUUID().toString());
                }
                System.out.println("affected row => " + st.executeUpdate());
            }
        }
    }
}

Kueri data

Gunakan pernyataan SELECT SQL standar untuk mengambil data dari tabel Hologres. Contoh SELECT dasar di Langkah 4 menunjukkan pola ini.