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

Maven リポジトリ

Maven を使用して SDK のバージョンを管理および構成できます。以下は Maven の構成です。

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

次のリンクからオフライン JAR パッケージをダウンロードできます: adb4pgclient-1.0.16.jar および adb4pgclient-1.0.16-jar-with-dependencies.jar。

メソッド

コード例

public class Adb4pgClientUsage {
    public void demo() {
        DatabaseConfig databaseConfig = new DatabaseConfig();
        // データベースの実際のホストまたは URL を設定する必要があります
        databaseConfig.setHost("100.100.100.100");
        // データベースの実際のポートを設定する必要があります
        databaseConfig.setPort(8888);
        // データベース接続用のユーザー名。
        databaseConfig.setUser("ご利用のユーザー名");
        // データベース接続用のパスワード。
        databaseConfig.setPassword("ご利用のパスワード");
      // 接続するデータベース。
        databaseConfig.setDatabase("ご利用のデータベース名");
        // 書き込み対象のテーブルのリストを設定します。
        List<String> tables = new ArrayList<String>();
        tables.add("ご利用のテーブル名 1");
        tables.add("ご利用のテーブル名 2");

        // 異なるスキーマのテーブルに対して addTable を個別に呼び出すことができます。ただし、DatabaseConfig から Client インスタンスが作成された後は、テーブル構成を変更することはできません。 /
        // スキーマに null を渡すと、デフォルトのスキーマ 'public' が使用されます。
        databaseConfig.addTable(tables, "テーブルスキーマ名");

        // 書き込み対象のテーブルの列を設定します。
        List<String> columns = new ArrayList<String>();
        columns.add("column1");
        columns.add("column2");
        // すべての列に書き込むには、columns.add("*") を使用します。
        databaseConfig.setColumns(columns, "ご利用のテーブル名 1", "テーブルスキーマ名");
        databaseConfig.setColumns(Collections.singletonList("*"),"ご利用のテーブル名 2", "テーブルスキーマ名");


        // 列の値が空の場合は、null を設定します
        databaseConfig.setEmptyAsNull(false);
        // 挿入には 'insert ignore' メソッドを使用します。
        databaseConfig.setInsertIgnore(true);
        // コミット中にデータベースへの書き込みで例外が発生した場合、3 回リトライします。
        databaseConfig.setRetryTimes(3);
        // 再試行間隔は 1 秒です。単位は ms です。
        databaseConfig.setRetryIntervalTime(1000);
        // AdbClient を初期化します。インスタンスが初期化された後は、DatabaseConfig の設定を変更することはできません。
        Adb4pgClient adbClient = new Adb4pgClient(databaseConfig);

        // データをバッチ処理します。複数回追加してからコミットします。バッチサイズの詳細については、「注意事項」セクションをご参照ください。
        for (int i = 0; i < 10; i++) {
            // 行をバッファーに追加します。1 レコードにつき 1 インスタンスです
            Row row = new Row(columns.size());
            // 列を設定
            // 列のインデックスは、列のシーケンスと同じでなければなりません
            // 列の値は任意の型にできます。内部的には列の型に応じてフォーマットされます
            row.setColumn(0, i); // 数値
            row.setColumn(1, "string value"); // 文字列値
            // バッファーがいっぱいになると、addRow または addMap の呼び出し中に自動コミットがトリガーされます。
            // コミットが失敗した場合、エラーコード COMMIT_ERROR_DATA_LIST を持つ AdbClientException が返されます。
            adbClient.addRow(row, "ご利用のテーブル名 1", "テーブルスキーマ名");
        }

        Row row = new Row();
        row.setColumn(0, 10); // 数値
        row.setColumn(1, "2018-01-01 08:00:00"); // 日付/タイムスタンプ/時刻の値
        adbClient.addRow(row, "ご利用のテーブル名 1", "テーブルスキーマ名");
        // 列を更新します。Row インスタンスは再利用できます。
        row.updateColumn(0, 11);
        row.updateColumn(1, "2018-01-02 08:00:00");
        adbClient.addRow(row, "ご利用のテーブル名 1", "テーブルスキーマ名");

        // マップをバッファーに追加
        Map<String, String> rowMap = new HashMap<String, String>();
        rowMap.put("t1", "12");
        rowMap.put("t2", "string value");
        // ここではバッチ処理が必要です。複数回の add 呼び出しの後にコミットすることを推奨します。
        adbClient.addMap(rowMap, "ご利用のテーブル名 2", "テーブルスキーマ名");

        // バッファーをデータベースにコミットします
        // データベースへのコミットが成功するとバッファーはクリアされます
        try {
            adbClient.commit();
        } catch (Exception e) {
            // TODO: ここで例外を処理します
        } finally {
            adbClient.stop();
        }
    }

}

注意事項

• AnalyticDB for PostgreSQL クライアント SDK はスレッドセーフではありません。マルチスレッド環境では、各スレッドが独自の `Client` オブジェクトを維持する必要があります。

  重要

  複数のスレッド間で SDK インスタンスを共有することは推奨されません。スレッドセーフの問題に加えて、共有クライアントは書き込みパフォーマンスのボトルネックになりやすいためです。

• データが AnalyticDB for PostgreSQL に正常に書き込まれたと見なされるのは、`commit` の呼び出しが成功した後のみです。

• クライアントが例外をスローした場合、エラーコードに基づいてその処理方法を決定する必要があります。データ書き込みエラーが発生した場合は、データを再送信するか、問題のあるデータをログに記録してからスキップすることができます。

• 書き込みスレッドを増やしても、必ずしもパフォーマンスが向上するとは限りません。アプリケーションはデータをバッチ処理することが多いため、メモリ消費量が高くなる可能性があります。したがって、アプリケーションのガベージコレクション (GC) の状態を注意深くモニターする必要があります。

• バッチサイズを小さくしすぎないでください。そうしないと、バッチ書き込みの利点が失われます。可能であれば、データをコミットする前に少なくとも 10,000 レコードを追加することを推奨します。

• クライアントオブジェクトが初期化される前に、すべての `DatabaseConfig` 設定項目を設定する必要があります。これらの設定は、クライアントオブジェクトがインスタンス化された後は変更できません。

• クライアント SDK は、書き込み (INSERT) パフォーマンスを最適化するように設計されています。他の SQL 操作については、getConnection() メソッドを使用して JDBC 接続を取得し、標準の JDBC インターフェイスを介して操作を処理してください。