メインコンテンツへスキップ
メインコンテンツへスキップ

PostgreSQL

リモート PostgreSQL サーバー上のデータベースに接続できます。ClickHouse と PostgreSQL 間でデータをやり取りするために、読み取りおよび書き込み操作（SELECT および INSERT クエリ）をサポートします。

SHOW TABLES および DESCRIBE TABLE クエリを利用して、リモート PostgreSQL 上のテーブル一覧およびテーブル構造にリアルタイムでアクセスできます。

テーブル構造の変更（ALTER TABLE ... ADD|DROP COLUMN）をサポートします。use_table_cache パラメータ（後述の Engine パラメータを参照）が 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。

データ型のサポート​

PostgreSQLClickHouse
DATEDate
TIMESTAMPDateTime
REALFloat32
DOUBLEFloat64
DECIMAL, NUMERICDecimal
SMALLINTInt16
INTEGERInt32
BIGINTInt64
SERIALUInt32
BIGSERIALUInt64
TEXT, CHARString
INTEGERNullable(Int32)
ARRAYArray

利用例​

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

関連コンテンツ​