PostgreSQL

원격 PostgreSQL 서버의 데이터베이스에 연결할 수 있습니다.

원격 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

​

사용 예시

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

​

관련 콘텐츠

• 블로그: ClickHouse와 PostgreSQL - 데이터 세계의 찰떡궁합 - 1부
• 블로그: ClickHouse와 PostgreSQL - 데이터 세계의 찰떡궁합 - 2부