> ## Documentation Index
> Fetch the complete documentation index at: https://clickhouse.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.
# PostgreSQL
> Postgres と ClickHouse の統合方法を説明するページ
export const ExperimentalBadge = () => {
return ;
};
export const CloudNotSupportedBadge = () => {
return
ClickHouse Cloud では利用できません
;
};
> データモデリングや対応する概念に関するアドバイスを含む、PostgreSQL から ClickHouse への完全な移行ガイドは、[こちら](/docs/ja/get-started/migrate/postgres/overview)を参照してください。以下では、ClickHouse と PostgreSQL を接続する方法について説明します。
このページでは、PostgreSQL を ClickHouse と統合するための次の方法について説明します。
* PostgreSQL のテーブルから読み取るために `PostgreSQL` テーブルエンジンを使用する
* PostgreSQL 内のデータベースを ClickHouse 内のデータベースと同期するために、実験的な `MaterializedPostgreSQL` データベースエンジンを使用する
[Managed Postgres](/docs/ja/products/managed-postgres/overview) サービスもぜひご覧ください。コンピュートと物理的に同じ場所に配置された NVMe ストレージを基盤としており、EBS のようなネットワーク接続型ストレージを使用する代替手段と比べて、ディスク I/O がボトルネックとなるワークロードで最大 10 倍のパフォーマンスを実現します。また、ClickPipes の Postgres CDC (変更データキャプチャ) コネクタを使用して、Postgres のデータを ClickHouse にレプリケートできます。
## PostgreSQL テーブルエンジン を使う
`PostgreSQL` テーブルエンジンを使用すると、ClickHouse からリモートの PostgreSQL サーバーに保存されているデータに対して **SELECT** および **INSERT** 操作を実行できます。
この記事では、1 つのテーブルを使った基本的なインテグレーション方法を紹介します。
### 1. PostgreSQL の設定
1. PostgreSQL がネットワークインターフェイスで待ち受けるよう、`postgresql.conf` に次のエントリを追加します:
```text theme={null}
listen_addresses = '*'
```
2. ClickHouse から接続するためのユーザーを作成します。説明用として、この例ではスーパーユーザー権限をすべて付与します。
```sql theme={null}
CREATE ROLE clickhouse_user SUPERUSER LOGIN PASSWORD 'ClickHouse_123';
```
3. PostgreSQL で新しいデータベースを作成します:
```sql theme={null}
CREATE DATABASE db_in_psg;
```
4. 新しいテーブルを作成します:
```sql theme={null}
CREATE TABLE table1 (
id integer primary key,
column1 varchar(10)
);
```
5. テスト用に数行追加しましょう:
```sql theme={null}
INSERT INTO table1
(id, column1)
VALUES
(1, 'abc'),
(2, 'def');
```
6. レプリケーションのために、新しいユーザーによる新しいデータベースへの接続を許可するよう PostgreSQL を設定するには、次のエントリを `pg_hba.conf` ファイルに追加します。アドレス行は、PostgreSQL サーバーのサブネットまたは IP アドレスに合わせて更新してください。
```text theme={null}
# TYPE DATABASE USER ADDRESS METHOD
host db_in_psg clickhouse_user 192.168.1.0/24 password
```
7. `pg_hba.conf` の設定を再読み込みします (このコマンドは、使用しているバージョンに応じて調整してください) :
```text theme={null}
/usr/pgsql-12/bin/pg_ctl reload
```
8. 新しい `clickhouse_user` でログインできることを確認します:
```text theme={null}
psql -U clickhouse_user -W -d db_in_psg -h
```
この機能を ClickHouse Cloud で使用する場合は、ClickHouse Cloud の IP アドレスから PostgreSQL インスタンスへアクセスできるよう許可が必要になることがあります。
外向きトラフィックの詳細については、ClickHouse の [Cloud Endpoints API](/docs/ja/products/cloud/guides/sql-console/query-endpoints) を確認してください。
### 2. ClickHouseでテーブルを定義する
1. `clickhouse-client` に接続します:
```bash theme={null}
clickhouse-client --user default --password ClickHouse123!
```
2. 新しいデータベースを作成します。
```sql theme={null}
CREATE DATABASE db_in_ch;
```
3. `PostgreSQL` を使用するテーブルを作成します:
```sql theme={null}
CREATE TABLE db_in_ch.table1
(
id UInt64,
column1 String
)
ENGINE = PostgreSQL('postgres-host.domain.com:5432', 'db_in_psg', 'table1', 'clickhouse_user', 'ClickHouse_123');
```
必要な最小限のパラメータは次のとおりです。
| パラメータ | 説明 | 例 |
| --------- | ---------------------- | ----------------------------- |
| host:port | ホスト名または IP アドレスとポート | postgres-host.domain.com:5432 |
| database | PostgreSQL のデータベース名 | db\_in\_psg |
| user | Postgres に接続するためのユーザー名 | clickhouse\_user |
| password | Postgres に接続するためのパスワード | ClickHouse\_123 |
パラメータの完全な一覧については、[PostgreSQL テーブルエンジン](/docs/ja/reference/engines/table-engines/integrations/postgresql) のドキュメントページを参照してください。
### 3 インテグレーションをテストする
1. ClickHouse で、初期状態の行を表示します:
```sql theme={null}
SELECT * FROM db_in_ch.table1
```
ClickHouse のテーブルには、PostgreSQL のテーブルにすでに存在していた 2 行が自動的に取り込まれているはずです。
```response theme={null}
Query id: 34193d31-fe21-44ac-a182-36aaefbd78bf
┌─id─┬─column1─┐
│ 1 │ abc │
│ 2 │ def │
└────┴─────────┘
```
2. PostgreSQL に戻り、テーブルに2行ほど追加します:
```sql theme={null}
INSERT INTO table1
(id, column1)
VALUES
(3, 'ghi'),
(4, 'jkl');
```
4. その2つの新しい行がClickHouseのテーブルに表示されるはずです:
```sql theme={null}
SELECT * FROM db_in_ch.table1
```
応答は次のとおりです。
```response theme={null}
Query id: 86fa2c62-d320-4e47-b564-47ebf3d5d27b
┌─id─┬─column1─┐
│ 1 │ abc │
│ 2 │ def │
│ 3 │ ghi │
│ 4 │ jkl │
└────┴─────────┘
```
5. ClickHouseのテーブルに行を追加するとどうなるか、見てみましょう：
```sql theme={null}
INSERT INTO db_in_ch.table1
(id, column1)
VALUES
(5, 'mno'),
(6, 'pqr');
```
6. ClickHouse に追加した行が、PostgreSQL のテーブルに表示されているはずです:
```sql theme={null}
db_in_psg=# SELECT * FROM table1;
id | column1
----+---------
1 | abc
2 | def
3 | ghi
4 | jkl
5 | mno
6 | pqr
(6 rows)
```
この例では、`PostrgeSQL` テーブルエンジン を使用した、PostgreSQL と ClickHouse の基本的なインテグレーションを紹介しました。
スキーマの指定、一部のカラムのみを返す設定、複数のレプリカへの接続など、さらに多くの機能については、[PostgreSQL テーブルエンジン のドキュメントページ](/docs/ja/reference/engines/table-engines/integrations/postgresql)をご覧ください。あわせて、ブログ記事 [ClickHouse and PostgreSQL - a match made in data heaven - part 1](https://clickhouse.com/blog/migrating-data-between-clickhouse-postgres) もご覧ください。
## MaterializedPostgreSQL データベースエンジンを使用する
PostgreSQL データベースエンジンは、PostgreSQL のレプリケーション機能を使用して、データベース全体、またはその一部のスキーマやテーブルを含むデータベースのレプリカを作成します。
この記事では、1 つのデータベース、1 つのスキーマ、1 つのテーブルを使った基本的なインテグレーション方法を説明します。
***以下の手順では、PostgreSQL CLI (psql) と ClickHouse CLI (clickhouse-client) を使用します。PostgreSQL サーバーは Linux にインストールされています。以下は、PostgreSQL データベースが新規のテストインストールである場合の最小構成です。***
### 1. PostgreSQL で
1. `postgresql.conf` で、最小の listen レベル、レプリケーション用の WAL レベル、およびレプリケーションスロットを設定します。
次のエントリを追加します。
```text theme={null}
listen_addresses = '*'
max_replication_slots = 10
wal_level = logical
```
\**ClickHouse には、最低でも `logical` の WAL レベルと、`2` つ以上のレプリケーションスロットが必要です*
2. 管理者アカウントを使用して、ClickHouse から接続するためのユーザーを作成します:
```sql theme={null}
CREATE ROLE clickhouse_user SUPERUSER LOGIN PASSWORD 'ClickHouse_123';
```
\**説明のため、完全なスーパーユーザー権限を付与しています。*
3. 新しいデータベースを作成します:
```sql theme={null}
CREATE DATABASE db1;
```
4. `psql` で新しいデータベースに接続します：
```text theme={null}
\connect db1
```
5. 新しいテーブルを作成します:
```sql theme={null}
CREATE TABLE table1 (
id integer primary key,
column1 varchar(10)
);
```
6. 初期データを追加します:
```sql theme={null}
INSERT INTO table1
(id, column1)
VALUES
(1, 'abc'),
(2, 'def');
```
7. レプリケーション用の新しいユーザーによる新しいデータベースへの接続を許可するように、PostgreSQL を設定します。以下は、`pg_hba.conf` ファイルに追加する最小限のエントリです。
```text theme={null}
# TYPE DATABASE USER ADDRESS METHOD
host db1 clickhouse_user 192.168.1.0/24 password
```
\**説明用の例として、ここでは平文パスワードによる認証方式を使用しています。PostgreSQL のドキュメントに従って、address 行はサブネットまたはサーバーのアドレスに更新してください*
8. 次のように `pg_hba.conf` の設定を再読み込みします (お使いのバージョンに応じて調整してください) :
```text theme={null}
/usr/pgsql-12/bin/pg_ctl reload
```
9. 新しい`clickhouse_user`でログインを確認します:
```text theme={null}
psql -U clickhouse_user -W -d db1 -h
```
### 2. ClickHouse で
1. ClickHouse CLI にログインします
```bash theme={null}
clickhouse-client --user default --password ClickHouse123!
```
2. PostgreSQL データベースエンジンの実験的機能を有効にします:
```sql theme={null}
SET allow_experimental_database_materialized_postgresql=1
```
3. レプリケーション対象の新しいデータベースを作成し、初期テーブルを定義します。
```sql theme={null}
CREATE DATABASE db1_postgres
ENGINE = MaterializedPostgreSQL('postgres-host.domain.com:5432', 'db1', 'clickhouse_user', 'ClickHouse_123')
SETTINGS materialized_postgresql_tables_list = 'table1';
```
最小限のオプション:
| パラメータ | 説明 | 例 |
| --------- | ---------------------- | ------------------------------------------------- |
| host:port | ホスト名または IP アドレスとポート | postgres-host.domain.com:5432 |
| database | PostgreSQL のデータベース名 | db1 |
| user | Postgres に接続するためのユーザー名 | clickhouse\_user |
| password | Postgres に接続するためのパスワード | ClickHouse\_123 |
| settings | エンジンの追加設定 | materialized\_postgresql\_tables\_list = 'table1' |
PostgreSQL データベースエンジンの完全なガイドについては、[https://clickhouse.com/docs/engines/database-engines/materialized-postgresql/#settings](https://clickhouse.com/docs/engines/database-engines/materialized-postgresql/#settings) を参照してください。
4. 初期テーブルにデータがあることを確認します:
```sql theme={null}
ch_env_2 :) select * from db1_postgres.table1;
SELECT *
FROM db1_postgres.table1
```
```response theme={null}
Query id: df2381ac-4e30-4535-b22e-8be3894aaafc
┌─id─┬─column1─┐
│ 1 │ abc │
└────┴─────────┘
┌─id─┬─column1─┐
│ 2 │ def │
└────┴─────────┘
```
### 3. 基本レプリケーションをテストする
1. PostgreSQL で新しい行を追加します:
```sql theme={null}
INSERT INTO table1
(id, column1)
VALUES
(3, 'ghi'),
(4, 'jkl');
```
2. ClickHouse で、新しい行が表示されることを確認します:
```sql theme={null}
ch_env_2 :) select * from db1_postgres.table1;
SELECT *
FROM db1_postgres.table1
```
```response theme={null}
Query id: b0729816-3917-44d3-8d1a-fed912fb59ce
┌─id─┬─column1─┐
│ 1 │ abc │
└────┴─────────┘
┌─id─┬─column1─┐
│ 4 │ jkl │
└────┴─────────┘
┌─id─┬─column1─┐
│ 3 │ ghi │
└────┴─────────┘
┌─id─┬─column1─┐
│ 2 │ def │
└────┴─────────┘
```
### 4. まとめ
このインテグレーションガイドでは、テーブルを 1 つ含むデータベースをレプリケートするシンプルな例に焦点を当てましたが、データベース全体をレプリケートしたり、既存のレプリケーションに新しいテーブルやスキーマを追加したりする、より高度なオプションもあります。このレプリケーションでは DDL コマンドはサポートされていませんが、構造変更が行われた際に変更を検出してテーブルを再読み込みするようにエンジンを設定できます。
高度なオプションで利用できるその他の機能については、[参照ドキュメント](/docs/ja/reference/engines/database-engines/materialized-postgresql)を参照してください。