본문으로 바로가기
본문으로 바로가기

PostgreSQL

원격 PostgreSQL 서버의 데이터베이스에 연결할 수 있도록 합니다. ClickHouse와 PostgreSQL 간에 데이터를 교환하기 위한 읽기 및 쓰기 작업(SELECT 및 INSERT 쿼리)을 지원합니다.

SHOW TABLES 및 DESCRIBE TABLE 쿼리를 통해 원격 PostgreSQL의 테이블 목록과 테이블 구조에 실시간으로 액세스할 수 있습니다.

테이블 구조 변경(ALTER TABLE ... ADD|DROP COLUMN)을 지원합니다. use_table_cache 파라미터(아래 Engine Parameters 참조)가 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한 뒤 다시 attach하자, 구조가 업데이트되었습니다:

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

관련 자료​