PostgreSQL - ClickHouse Documentation

リモートのPostgreSQLサーバー上のデータベースに接続できます。ClickHouseとPostgreSQLの間でデータをやり取りするための読み取りおよび書き込み操作 (SELECT および INSERT クエリ) をサポートします。 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	Date
TIMESTAMP	DateTime
REAL	Float32
DOUBLE	Float64
DECIMAL, NUMERIC	Decimal (以下の注を参照)
SMALLINT	Int16
INTEGER	Int32
BIGINT	Int64
SERIAL	UInt32
BIGSERIAL	UInt64
TEXT, CHAR	String
INTEGER	Nullable(Int32)
ARRAY	Array

精度 p が 76 (Decimal256 でサポートされる最大値) を超える PostgreSQL の numeric(p, 0) — たとえば、256 ビット整数の保存によく使われる numeric(78, 0) — は、Decimal ではなく Int256 にマッピングされます。Int256 の範囲に収まらない値はエラーとして拒否されます。

使用例

PostgreSQL サーバーとデータをやり取りする ClickHouse のデータベース：

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)  │
└────────┴───────────────────┘

​データベースの作成

​データ型の対応

​使用例

​関連コンテンツ

データベースの作成

データ型の対応

使用例

関連コンテンツ