Перейти к основному содержимому
Перейти к основному содержимому

PostgreSQL

Позволяет подключаться к базам данных на удаленном PostgreSQL сервере. Поддерживает операции чтения и записи (запросы SELECT и INSERT) для обмена данными между ClickHouse и PostgreSQL.

Предоставляет доступ в реальном времени к списку таблиц и структуре таблиц из удаленного PostgreSQL с помощью запросов SHOW TABLES и DESCRIBE TABLE.

Поддерживает изменения структуры таблицы (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.

Поддержка типов данных​

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

Связанный контент​