AnalyticDB：Tulis data menggunakan Client SDK

Repositori Maven

Anda dapat menggunakan Maven untuk mengelola dan mengonfigurasi versi SDK. Berikut adalah konfigurasi Maven-nya:

<dependency>
  <groupId>com.alibaba.cloud.analyticdb</groupId>
  <artifactId>adb4pgclient</artifactId>
  <version>1.0.16</version>
</dependency>

Anda dapat mengunduh paket JAR offline dari tautan berikut: adb4pgclient-1.0.16.jar dan adb4pgclient-1.0.16-jar-with-dependencies.jar.

Metode

Contoh kode

public class Adb4pgClientUsage {
    public void demo() {
        DatabaseConfig databaseConfig = new DatabaseConfig();
        // Harus menyetel host atau URL database Anda yang sebenarnya
        databaseConfig.setHost("100.100.100.100");
        // Harus menyetel port database Anda yang sebenarnya
        databaseConfig.setPort(8888);
        // Username untuk koneksi database.
        databaseConfig.setUser("your user name");
        // Password untuk koneksi database.
        databaseConfig.setPassword("your password");
      // Database yang akan dihubungkan.
        databaseConfig.setDatabase("your database name");
        // Menyetel daftar tabel yang akan ditulis.
        List<String> tables = new ArrayList<String>();
        tables.add("your table name 1");
        tables.add("your table name 2");

        // Anda dapat memanggil addTable secara terpisah untuk tabel-tabel dalam skema berbeda. Namun, setelah instans Client dibuat dari DatabaseConfig, konfigurasi tabel tidak dapat diubah. /
        // Jika Anda mengirimkan null untuk skema, skema default 'public' akan digunakan.
        databaseConfig.addTable(tables, "table schema name");

        // Menyetel kolom-kolom tabel yang akan ditulis.
        List<String> columns = new ArrayList<String>();
        columns.add("column1");
        columns.add("column2");
        // Untuk menulis ke semua kolom, gunakan columns.add("*").
        databaseConfig.setColumns(columns, "your table name 1", "table schema name");
        databaseConfig.setColumns(Collections.singletonList("*"),"your table name 2", "table schema name");


        // Jika nilai kolom kosong, atur sebagai null
        databaseConfig.setEmptyAsNull(false);
        // Gunakan metode 'insert ignore' untuk penyisipan.
        databaseConfig.setInsertIgnore(true);
        // Coba ulang tiga kali jika terjadi exception saat menulis ke database selama commit.
        databaseConfig.setRetryTimes(3);
        // Interval percobaan ulang adalah 1 detik. Satuannya ms.
        databaseConfig.setRetryIntervalTime(1000);
        // Inisialisasi AdbClient. Setelah instans diinisialisasi, pengaturan DatabaseConfig tidak dapat diubah.
        Adb4pgClient adbClient = new Adb4pgClient(databaseConfig);

        // Batch data. Tambahkan beberapa kali, lalu commit. Untuk detail ukuran batch, lihat bagian "Catatan".
        for (int i = 0; i < 10; i++) {
            // Tambahkan baris ke buffer. Satu instance untuk satu catatan
            Row row = new Row(columns.size());
            // Setel kolom
            // indeks kolom harus sama dengan urutan kolom
            // nilai kolom bisa berupa tipe apa pun, secara internal akan diformat sesuai tipe kolom
            row.setColumn(0, i); // Nilai angka
            row.setColumn(1, "string value"); // Nilai string
            // Jika buffer penuh, autocommit dipicu selama pemanggilan addRow atau addMap.
            // Jika commit gagal, AdbClientException dikembalikan dengan kode kesalahan COMMIT_ERROR_DATA_LIST.
            adbClient.addRow(row, "your table name 1", "table schema name");
        }

        Row row = new Row();
        row.setColumn(0, 10); // Nilai angka
        row.setColumn(1, "2018-01-01 08:00:00"); // Nilai tanggal/waktu
        adbClient.addRow(row, "your table name 1", "table schema name");
        // Perbarui kolom. Instance Row dapat digunakan ulang.
        row.updateColumn(0, 11);
        row.updateColumn(1, "2018-01-02 08:00:00");
        adbClient.addRow(row, "your table name 1", "table schema name");

        // Tambahkan map ke buffer
        Map<String, String> rowMap = new HashMap<String, String>();
        rowMap.put("t1", "12");
        rowMap.put("t2", "string value");
        // Batch diperlukan di sini. Kami menyarankan melakukan commit setelah beberapa pemanggilan add.
        adbClient.addMap(rowMap, "your table name 2", "table schema name");

        // Commit buffer ke ADS
        // Buffer dibersihkan setelah berhasil di-commit ke ADS
        try {
            adbClient.commit();
        } catch (Exception e) {
            // TODO: Tangani exception di sini
        } finally {
            adbClient.stop();
        }
    }

}

Catatan

• AnalyticDB for PostgreSQL Client SDK tidak thread-safe. Di lingkungan multi-threaded, setiap thread harus memiliki objek `Client` sendiri.

  Penting

  Kami tidak menyarankan berbagi instans SDK di antara beberapa thread. Selain masalah keamanan thread, client yang dibagikan dapat dengan mudah menjadi bottleneck kinerja penulisan.

• Data dianggap berhasil ditulis ke AnalyticDB for PostgreSQL hanya setelah pemanggilan `commit` berhasil.

• Saat client melemparkan exception, Anda harus memutuskan cara menanganinya berdasarkan kode kesalahan. Jika terjadi kesalahan penulisan data, Anda dapat mengirim ulang data tersebut, atau mencatat data bermasalah lalu melewatkannya.

• Menggunakan lebih banyak thread penulisan tidak selalu menghasilkan kinerja yang lebih baik. Karena aplikasi sering melakukan batching data, konsumsi memori bisa tinggi. Oleh karena itu, Anda harus memantau status garbage collection (GC) aplikasi secara ketat.

• Jangan gunakan ukuran batch yang terlalu kecil. Jika tidak, manfaat penulisan batch akan hilang. Jika memungkinkan, kami menyarankan menambahkan minimal 10.000 catatan sebelum melakukan commit data.

• Anda harus menyetel semua item konfigurasi `DatabaseConfig` sebelum objek client diinisialisasi. Pengaturan ini tidak dapat diubah setelah objek client dibuat.

• Client SDK dirancang untuk mengoptimalkan kinerja penulisan (INSERT). Untuk operasi SQL lainnya, ambil koneksi JDBC menggunakan metode getConnection() dan tangani operasi tersebut melalui antarmuka JDBC standar.