> ## Documentation Index
> Fetch the complete documentation index at: https://private-7c7dfe99-fix-nav-issues.mintlify.site/llms.txt
> Use this file to discover all available pages before exploring further.

> PostgreSQL エンジンでは、リモートの PostgreSQL サーバーに保存されているデータに対して `SELECT` および `INSERT` クエリを実行できます。

# PostgreSQL テーブルエンジン

PostgreSQL エンジンでは、リモートの PostgreSQL サーバーに保存されているデータに対して `SELECT` および `INSERT` クエリを実行できます。

<Note>
  現在、テーブルエンジンでサポートされているのは PostgreSQL バージョン 12 以降のみです。
</Note>

<Tip>
  [Managed Postgres](/ja/products/managed-postgres/overview) サービスもご利用いただけます。コンピュートと物理的に同一配置された NVMe ストレージを基盤としており、EBS のようなネットワーク接続型ストレージを使用する代替手段と比べて、ディスク I/O がボトルネックになるワークロードで最大 10 倍高速なパフォーマンスを実現します。さらに、ClickPipes の Postgres CDC (変更データキャプチャ) コネクタを使用して、Postgres データを ClickHouse にレプリケートできます。
</Tip>

<div id="creating-a-table">
  ## テーブルの作成
</div>

```sql theme={null}
CREATE TABLE [IF NOT EXISTS] [db.]table_name [ON CLUSTER cluster]
(
    name1 type1 [DEFAULT|MATERIALIZED|ALIAS expr1] [TTL expr1],
    name2 type2 [DEFAULT|MATERIALIZED|ALIAS expr2] [TTL expr2],
    ...
) ENGINE = PostgreSQL({host:port, database, table, user, password[, schema, [, on_conflict]] | named_collection[, option=value [,..]]})
```

[CREATE TABLE](/ja/reference/statements/create/table) クエリの詳細な説明を参照してください。

テーブル構造は、元の PostgreSQL テーブル構造と異なる場合があります。

* カラム名は元の PostgreSQL テーブルと同じである必要がありますが、それらのうち一部のカラムのみを、任意の順序で使用できます。
* カラム型は元の PostgreSQL テーブルのものと異なっていてもかまいません。ClickHouse は値を ClickHouse のデータ型に[キャスト](/ja/reference/engines/database-engines/postgresql#data_types-support)しようとします。
* [external\_table\_functions\_use\_nulls](/ja/reference/settings/session-settings#external_table_functions_use_nulls) 設定は、Nullable カラムの扱いを定義します。デフォルト値は 1 です。0 の場合、テーブル関数は Nullable カラムを作成せず、null の代わりにデフォルト値を挿入します。これは配列内の NULL 値にも適用されます。

**エンジンパラメータ**

* `host:port` — PostgreSQL サーバーのアドレス。
* `database` — リモートデータベース名。
* `table` — リモートテーブル名。
* `user` — PostgreSQL ユーザー。
* `password` — ユーザーのパスワード。
* `schema` — デフォルト以外のテーブルスキーマ。省略可能です。
* `on_conflict` — 競合解決戦略。例: `ON CONFLICT DO NOTHING`。省略可能です。注意: このオプションを追加すると、挿入効率が低下します。

本番環境では、[名前付きコレクション](/ja/concepts/features/configuration/server-config/named-collections) (バージョン 21.11 以降で利用可能) の使用を推奨します。以下はその例です。

```xml theme={null}
<named_collections>
    <postgres_creds>
        <host>localhost</host>
        <port>5432</port>
        <user>postgres</user>
        <password>****</password>
        <schema>schema1</schema>
    </postgres_creds>
</named_collections>
```

一部のパラメータは、キー値引数で上書きできます：

```sql theme={null}
SELECT * FROM postgresql(postgres_creds, table='table1');
```

<div id="implementation-details">
  ## 実装の詳細
</div>

PostgreSQL 側の`SELECT`クエリは、読み取り専用の PostgreSQL トランザクション内で `COPY (SELECT ...) TO STDOUT` として実行され、各`SELECT`クエリの後にコミットされます。

`=`, `!=`, `>`, `>=`, `<`, `<=`, `IN` などの単純な`WHERE`句は、PostgreSQL サーバー上で実行されます。

すべての JOIN、集計、ソート、`IN [ array ]` 条件、および`LIMIT`によるサンプリング制約は、PostgreSQL へのクエリが完了した後にのみ ClickHouse で実行されます。

PostgreSQL 側の`INSERT`クエリは、PostgreSQL トランザクション内で `COPY "table_name" (field1, field2, ... fieldN) FROM STDIN` として実行され、各`INSERT`ステートメントの後に自動コミットされます。

PostgreSQL の`Array`型は ClickHouse の Array に変換されます。

<Note>
  注意してください。PostgreSQL では、`type_name[]` のように作成された配列データには、同じカラム内でも行ごとに次元数が異なる多次元配列を含めることができます。一方 ClickHouse では、同じカラム内のすべての行で次元数が同じ多次元配列しか許可されません。
</Note>

複数のレプリカをサポートしており、`|`で列挙する必要があります。例えば:

```sql theme={null}
CREATE TABLE test_replicas (id UInt32, name String) ENGINE = PostgreSQL(`postgres{2|3|4}:5432`, 'clickhouse', 'test_replicas', 'postgres', 'mysecretpassword');
```

PostgreSQL の Dictionary ソースでは、レプリカの優先度をサポートしています。マップ内の数値が大きいほど、優先度は低くなります。最も高い優先度は `0` です。

以下の例では、レプリカ `example01-1` の優先度が最も高くなっています。

```xml theme={null}
<postgresql>
    <port>5432</port>
    <user>clickhouse</user>
    <password>qwerty</password>
    <replica>
        <host>example01-1</host>
        <priority>1</priority>
    </replica>
    <replica>
        <host>example01-2</host>
        <priority>2</priority>
    </replica>
    <db>db_name</db>
    <table>table_name</table>
    <where>id=10</where>
    <invalidate_query>SQL_QUERY</invalidate_query>
</postgresql>
</source>
```

<div id="usage-example">
  ## 使用例
</div>

<div id="table-in-postgresql">
  ### PostgreSQL内のテーブル
</div>

```text theme={null}
postgres=# CREATE TABLE "public"."test" (
"int_id" SERIAL,
"int_nullable" INT NULL DEFAULT NULL,
"float" FLOAT NOT NULL,
"str" VARCHAR(100) NOT NULL DEFAULT '',
"float_nullable" FLOAT NULL DEFAULT NULL,
PRIMARY KEY (int_id));

CREATE TABLE

postgres=# INSERT INTO test (int_id, str, "float") VALUES (1,'test',2);
INSERT 0 1

postgresql> SELECT * FROM test;
  int_id | int_nullable | float | str  | float_nullable
 --------+--------------+-------+------+----------------
       1 |              |     2 | test |
 (1 row)
```

<div id="creating-table-in-clickhouse-and-connecting-to--postgresql-table-created-above">
  ### ClickHouse でテーブルを作成し、上で作成した PostgreSQL テーブルに接続する
</div>

この例では、[PostgreSQL テーブルエンジン](/ja/reference/engines/table-engines/integrations/postgresql) を使用して ClickHouse テーブルを PostgreSQL テーブルに接続し、PostgreSQL データベースに対して SELECT と INSERT の両方のステートメントを実行します。

```sql theme={null}
CREATE TABLE default.postgresql_table
(
    `float_nullable` Nullable(Float32),
    `str` String,
    `int_id` Int32
)
ENGINE = PostgreSQL('localhost:5432', 'public', 'test', 'postgres_user', 'postgres_password');
```

<div id="inserting-initial-data-from-postgresql-table-into-clickhouse-table-using-a-select-query">
  ### SELECTクエリを使用して、PostgreSQLテーブルからClickHouseテーブルに初期データを挿入する
</div>

[postgresqlテーブル関数](/ja/reference/functions/table-functions/postgresql) は、PostgreSQL から ClickHouse にデータをコピーします。これは、PostgreSQL ではなく ClickHouse でデータのクエリや分析を実行することで、クエリパフォーマンスを向上させる目的でよく使用されます。また、PostgreSQL から ClickHouse へのデータ移行にも使用できます。今回は PostgreSQL から ClickHouse にデータをコピーするため、ClickHouse で MergeTree テーブルエンジンを使用し、これを postgresql\_copy と呼びます:

```sql theme={null}
CREATE TABLE default.postgresql_copy
(
    `float_nullable` Nullable(Float32),
    `str` String,
    `int_id` Int32
)
ENGINE = MergeTree
ORDER BY (int_id);
```

```sql theme={null}
INSERT INTO default.postgresql_copy
SELECT * FROM postgresql('localhost:5432', 'public', 'test', 'postgres_user', 'postgres_password');
```

<div id="inserting-incremental-data-from-postgresql-table-into-clickhouse-table">
  ### PostgreSQLテーブルからClickHouseテーブルにインクリメンタルデータを挿入する
</div>

初回の挿入後も PostgreSQLテーブルとClickHouseテーブルの継続的な同期を行う場合は、ClickHouse 側でWHERE句を使用し、タイムスタンプまたは一意のシーケンスIDを基準に、PostgreSQL に新たに追加されたデータだけを挿入できます。

そのためには、前回までに追加した最大のIDまたはタイムスタンプを、次のように追跡しておく必要があります。

```sql theme={null}
SELECT max(`int_id`) AS maxIntID FROM default.postgresql_copy;
```

次に、PostgreSQLテーブルから最大値を超える値を挿入します

```sql theme={null}
INSERT INTO default.postgresql_copy
SELECT * FROM postgresql('localhost:5432', 'public', 'test', 'postges_user', 'postgres_password');
WHERE int_id > maxIntID;
```

<div id="selecting-data-from-the-resulting-clickhouse-table">
  ### 作成された ClickHouse テーブルからデータを取得する
</div>

```sql theme={null}
SELECT * FROM postgresql_copy WHERE str IN ('test');
```

```text theme={null}
┌─float_nullable─┬─str──┬─int_id─┐
│           ᴺᵁᴸᴸ │ test │      1 │
└────────────────┴──────┴────────┘
```

<div id="using-non-default-schema">
  ### デフォルト以外のスキーマを使用する
</div>

```text theme={null}
postgres=# CREATE SCHEMA "nice.schema";

postgres=# CREATE TABLE "nice.schema"."nice.table" (a integer);

postgres=# INSERT INTO "nice.schema"."nice.table" SELECT i FROM generate_series(0, 99) as t(i)
```

```sql theme={null}
CREATE TABLE pg_table_schema_with_dots (a UInt32)
        ENGINE PostgreSQL('localhost:5432', 'clickhouse', 'nice.table', 'postgrsql_user', 'password', 'nice.schema');
```

**関連項目**

* [`postgresql` テーブル関数](/ja/reference/functions/table-functions/postgresql)
* [Dictionary ソースとして PostgreSQL を使用する](/ja/reference/statements/create/dictionary/sources/postgresql)

<div id="related-content">
  ## 関連コンテンツ
</div>

* ブログ: [ClickHouse and PostgreSQL - データ界の理想的な組み合わせ - 第1部](https://clickhouse.com/blog/migrating-data-between-clickhouse-postgres)
* ブログ: [ClickHouse and PostgreSQL - データ界の理想的な組み合わせ - 第2部](https://clickhouse.com/blog/migrating-data-between-clickhouse-postgres-part-2)