AnalyticDB:AnalyticDB for PostgreSQLクライアントSDKを使用したデータの書き込み

Mavenリポジトリ

Mavenを使用して、AnalyticDB for PostgreSQLクライアントSDKのバージョンを設定できます。 サンプルコード：

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

AnalyticDB for PostgreSQLクライアントSDKのJARパッケージ: adb4pgclient-1.0.4.jar

関連する API 操作

サンプルコード

public class Adb4pgClientUsage {
    public void demo() {
        DatabaseConfig databaseConfig = new DatabaseConfig();
        // Should set your database real host or url
        databaseConfig.setHost("100.100.100.100");
        // Should set your database real port
        databaseConfig.setPort(8888);
        // Specify the database account that is used to connect to your AnalyticDB for PostgreSQL database. 
        databaseConfig.setUser("your user name");
        // Specify the password that is used to connect to your AnalyticDB for PostgreSQL database. 
        databaseConfig.setPassword("your password");
      // Specify the name of your AnalyticDB for PostgreSQL database. 
        databaseConfig.setDatabase("your database name");
        // Specify the tables into which you want to insert data. 
        List<String> tables = new ArrayList<String>();
        tables.add("your table name 1");
        tables.add("your table name 2");

        // You can call the addTable operation to specify tables that use the same schema. After you use the DatabaseConfig class to create an Adb4pgClient object, the specified tables cannot be changed. /
        // If you set the table schema name parameter to null, the public schema is used. 
        databaseConfig.addTable(tables, "table schema name");

        // Specify the columns that you want to insert into a table. 
        List<String> columns = new ArrayList<String>();
        columns.add("column1");
        columns.add("column2");
        // If you want to insert all columns into a table, set the columns parameter to columns.add("*"). 
        databaseConfig.setColumns(columns, "your table name 1", "table schema name");
        databaseConfig.setColumns(Collections.singletonList("*"),"your table name 2", "table schema name");


        // If the value of column is empty, set null
        databaseConfig.setEmptyAsNull(false);
        // Specify whether to ignore the rows that have conflicting primary keys. 
        databaseConfig.setInsertIgnore(true);
        // If data fails to be committed into AnalyticDB for PostgreSQL, you can retry to commit the data up to three times. 
        databaseConfig.setRetryTimes(3);
        // Specify a 1000-millisecond retry interval. 
        databaseConfig.setRetryIntervalTime(1000);
        // Initialize the Adb4pgClient object. After you initialize the Adb4pgClient object, you cannot modify the configuration of the DatabaseConfig class. 
        Adb4pgClient adbClient = new Adb4pgClient(databaseConfig);

        // Store data records to the buffer of AnalyticDB for PostgreSQL Client SDK and then commit the records at a time. For more information, see the "Usage notes" section of this topic. 
        for (int i = 0; i < 10; i++) {
            // Add row(s) to buffer. One instance for one record
            Row row = new Row(columns.size());
            // Set column
            // the column index must be same as the sequence of columns
            // the column value can be any type, internally it will be formatted according to column type
            row.setColumn(0, i); // Number value
            row.setColumn(1, "string value"); // String value
            // If the amount of data records in the buffer reaches the upper limit, the system automatically commits the records when you call the addRow or addMap operation. 
            // If the automatic commit fails, the system returns the COMMIT_ERROR_DATA_LIST error. 
            adbClient.addRow(row, "your table name 1", "table schema name");
        }

        Row row = new Row();
        row.setColumn(0, 10); // Number value
        row.setColumn(1, "2018-01-01 08:00:00"); // Date/Timestamp/Time value
        adbClient.addRow(row, "your table name 1", "table schema name");
        // Update columns. A Row object can be reused. 
        row.updateColumn(0, 11);
        row.updateColumn(1, "2018-01-02 08:00:00");
        adbClient.addRow(row, "your table name 1", "table schema name");

        // Add map(s) to buffer
        Map<String, String> rowMap = new HashMap<String, String>();
        rowMap.put("t1", "12");
        rowMap.put("t2", "string value");
        // If you want to commit multiple data records, we recommend that you store the records to the buffer of AnalyticDB for PostgreSQL Client SDK and then commit the records at a time. 
        adbClient.addMap(rowMap, "your table name 2", "table schema name");

        // Commit buffer to ADS
        // Buffer is cleaned after successfully commit to ADS
        try {
            adbClient.commit();
        } catch (Exception e) {
            // TODO: Handle exception here
        } finally {
            adbClient.stop();
        }
    }

}

使用上の注意

• AnalyticDB for PostgreSQLクライアントSDKはスレッドセーフではありません。 複数のスレッドを呼び出す場合は、各スレッドが独自のAdb4pgClientオブジェクトを保持していることを確認してください。

  重要

  複数のスレッドが同じAdb4pgClientオブジェクトを共有すると、セキュリティの問題が発生し、データ書き込みパフォーマンスが低下します。

• データレコードは、レコードがコミットされた後にのみAnalyticDB for PostgreSQLに書き込まれたと見なされます。

• Adb4pgClientオブジェクトがエラーを返した場合は、エラー情報に基づいてエラーを処理する必要があります。 データレコードをコミットできない場合は、レコードのコミットを再試行できます。 レコードをメモした後、失敗したデータレコードをスキップすることもできます。

• AnalyticDB for PostgreSQLにデータを書き込むと、データレコードがバッファに格納され、バッチがコミットされる場合があります。 これにより、CPU利用率が増加する。 適切な数のスレッドを維持し、アプリケーションのガベージコレクションのステータスを監視することを推奨します。

• 一度に10,000のデータレコードをコミットすることを推奨します。

• Adb4pgClientオブジェクトを作成する前に、DatabaseConfigクラスの設定を完了する必要があります。 Adb4pgClientオブジェクトを作成した後、DatabaseConfigクラスの構成を変更することはできません。

• AnalyticDB for PostgreSQLクライアントSDKは、データ書き込み (INSERTステートメント) の最適化を目指しています。 他のSQL文の実行を最適化するには、getConnection() 操作を呼び出してJDBC接続を確立します。