PostgreSQL
允许连接到远程 PostgreSQL 服务器上的数据库。支持读写操作(SELECT
和 INSERT
查询),以便在 ClickHouse 和 PostgreSQL 之间交换数据。
通过 SHOW TABLES
和 DESCRIBE TABLE
查询,实时访问远程 PostgreSQL 的表列表和表结构。
支持表结构修改(ALTER TABLE ... ADD|DROP COLUMN
)。如果 use_table_cache
参数(见下文引擎参数)设置为 1
,则表结构将被缓存,不会检查是否已修改,但可以通过 DETACH
和 ATTACH
查询更新。
创建数据库
CREATE DATABASE test_database
ENGINE = PostgreSQL('host:port', 'database', 'user', 'password'[, `schema`, `use_table_cache`]);
引擎参数
host:port
— PostgreSQL 服务器地址。database
— 远程数据库名称。user
— PostgreSQL 用户。password
— 用户密码。schema
— PostgreSQL 架构。use_table_cache
— 定义是否缓存数据库表结构。可选。默认值为:0
。
数据类型支持
PostgreSQL | ClickHouse |
---|---|
DATE | 日期 |
TIMESTAMP | 日期时间 |
REAL | Float32 |
DOUBLE | Float64 |
DECIMAL, NUMERIC | 小数 |
SMALLINT | Int16 |
INTEGER | Int32 |
BIGINT | Int64 |
SERIAL | UInt32 |
BIGSERIAL | UInt64 |
TEXT, CHAR | 字符串 |
INTEGER | Nullable(Int32) |
ARRAY | 数组 |
使用示例
ClickHouse 中的数据库,与 PostgreSQL 服务器交换数据
CREATE DATABASE test_database
ENGINE = PostgreSQL('postgres1:5432', 'test_database', 'postgres', 'mysecretpassword', 'schema_name',1);
SHOW DATABASES;
┌─name──────────┐
│ default │
│ test_database │
│ system │
└───────────────┘
SHOW TABLES FROM test_database;
┌─name───────┐
│ test_table │
└────────────┘
从 PostgreSQL 表中读取数据
SELECT * FROM test_database.test_table;
┌─id─┬─value─┐
│ 1 │ 2 │
└────┴───────┘
将数据写入 PostgreSQL 表
INSERT INTO test_database.test_table VALUES (3,4);
SELECT * FROM test_database.test_table;
┌─int_id─┬─value─┐
│ 1 │ 2 │
│ 3 │ 4 │
└────────┴───────┘
假设 PostgreSQL 中的表结构已修改
postgre> ALTER TABLE test_table ADD COLUMN data Text
由于创建数据库时 use_table_cache
参数设置为 1
,因此 ClickHouse 中的表结构被缓存,因此没有修改
DESCRIBE TABLE test_database.test_table;
┌─name───┬─type──────────────┐
│ id │ Nullable(Integer) │
│ value │ Nullable(Integer) │
└────────┴───────────────────┘
在分离表并再次附加后,结构已更新
DETACH TABLE test_database.test_table;
ATTACH TABLE test_database.test_table;
DESCRIBE TABLE test_database.test_table;
┌─name───┬─type──────────────┐
│ id │ Nullable(Integer) │
│ value │ Nullable(Integer) │
│ data │ Nullable(String) │
└────────┴───────────────────┘