> ## 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.
# 将 ClickHouse 连接到 PostgreSQL
> 介绍将 PostgreSQL 连接到 ClickHouse 的多种方式的页面
export const ExperimentalBadge = () => {
return ;
};
export const CloudNotSupportedBadge = () => {
return ;
};
本页介绍了将 PostgreSQL 与 ClickHouse 集成的以下方式：
* 使用 `PostgreSQL` 表引擎读取 PostgreSQL 表中的数据
* 使用 Experimental 的 `MaterializedPostgreSQL` 数据库引擎，将 PostgreSQL 中的数据库与 ClickHouse 中的数据库同步
了解我们的 [Managed Postgres](/docs/zh/products/managed-postgres/overview) 服务。该服务采用与计算资源物理同置的 NVMe 存储；与使用 EBS 等网络附加存储的替代方案相比，对于受磁盘 IO 限制的工作负载，性能最高可提升 10 倍，并支持通过 ClickPipes 中的 Postgres CDC connector 将 Postgres 数据复制到 ClickHouse。
## 使用 PostgreSQL 表引擎
`PostgreSQL` 表引擎允许在 ClickHouse 中对存储在远程 PostgreSQL 服务器上的数据执行 **SELECT** 和 **INSERT** 操作。
本文将通过一个表来说明集成的基本方法。
1. 在 `postgresql.conf` 中，添加以下配置项以使 PostgreSQL 在网络接口上监听：
```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` 文件中。将 address 行更新为您的 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/zh/products/cloud/guides/sql-console/query-endpoints)。
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');
```
所需的最少参数如下：
| parameter | Description | example |
| --------- | ------------------ | ----------------------------- |
| host:port | 主机名或 IP 地址及端口 | postgres-host.domain.com:5432 |
| database | PostgreSQL 数据库名称 | db\_in\_psg |
| user | 用于连接 Postgres 的用户名 | clickhouse\_user |
| password | 用于连接 Postgres 的密码 | ClickHouse\_123 |
请参阅 [PostgreSQL 表引擎](/docs/zh/reference/engines/table-engines/integrations/postgresql) 文档页面，获取完整的参数列表。
1. 在 ClickHouse 中，查看初始数据行：
```sql theme={null}
SELECT * FROM db_in_ch.table1
```
ClickHouse 表中应会自动出现 PostgreSQL 中该表里原已存在的两行数据：
```response theme={null}
Query id: 34193d31-fe21-44ac-a182-36aaefbd78bf
┌─id─┬─column1─┐
│ 1 │ abc │
│ 2 │ def │
└────┴─────────┘
```
2. 回到 PostgreSQL，在表中添加几条数据：
```sql theme={null}
INSERT INTO table1
(id, column1)
VALUES
(3, 'ghi'),
(4, 'jkl');
```
4. 这两行新数据应该会出现在您的 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/zh/reference/engines/table-engines/integrations/postgresql) 了解更多功能，例如指定 schema、仅返回部分列，以及连接到多个副本。另请参阅博客 [ClickHouse and PostgreSQL - 数据世界中的天作之合 - 第 1 部分](https://clickhouse.com/blog/migrating-data-between-clickhouse-postgres)。
## 使用 MaterializedPostgreSQL 数据库引擎
PostgreSQL 数据库引擎使用 PostgreSQL 的复制功能，为数据库中全部或部分 schema 和表创建副本。
本文旨在说明使用一个数据库、一个 schema 和一张表进行集成的基本方法。
***在以下步骤中，将使用 PostgreSQL 命令行客户端 (`psql`) 和 ClickHouse 命令行客户端 (`clickhouse-client`)。PostgreSQL 服务器安装在 Linux 上。如果 PostgreSQL 数据库是全新的测试安装，则以下内容为最小配置。***
1. 在 `postgresql.conf` 中，设置最小监听级别、复制 wal level 和 replication slots：
添加以下配置项：
```text theme={null}
listen_addresses = '*'
max_replication_slots = 10
wal_level = logical
```
\**ClickHouse 至少需要将 wal level 设为 `logical`，并且至少需要 `2` 个 replication slots*
2. 使用管理员账户，创建一个供 ClickHouse 连接的用户：
```sql theme={null}
CREATE ROLE clickhouse_user SUPERUSER LOGIN PASSWORD 'ClickHouse_123';
```
\**仅为演示起见，已授予完整的 superuser 权限。*
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
```
1. 登录到 ClickHouse 命令行客户端
```bash theme={null}
clickhouse-client --user default --password ClickHouse123!
```
2. 为该数据库引擎启用 PostgreSQL Experimental 功能：
```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';
```
最小配置项：
| parameter | Description | example |
| --------- | ------------------- | ------------------------------------------------- |
| 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 │
└────┴─────────┘
```
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 │
└────┴─────────┘
```
本集成指南主要通过一个简单示例说明如何复制包含单个表的数据库，不过，也提供了更高级的选项，例如复制整个数据库，或向现有复制中添加新表和 schema。尽管这种复制不支持 DDL 命令，但可以将该引擎设置为检测更改，并在发生结构变更时重新加载表。
如需了解高级选项支持的更多功能，请参阅[参考文档](/docs/zh/reference/engines/database-engines/materialized-postgresql)。