PostgreSQL

Permite conectar-se a bancos de dados em um servidor PostgreSQL remoto. Suporta operações de leitura e escrita (consultas SELECT e INSERT) para troca de dados entre o ClickHouse e o PostgreSQL. Fornece acesso em tempo real à lista e à estrutura das tabelas no PostgreSQL remoto por meio das consultas SHOW TABLES e DESCRIBE TABLE. Suporta alterações na estrutura da tabela (ALTER TABLE ... ADD|DROP COLUMN). Se o parâmetro use_table_cache (consulte Parâmetros do mecanismo abaixo) estiver definido como 1, a estrutura da tabela será armazenada em cache e não será verificada em busca de alterações, mas poderá ser atualizada com as consultas DETACH e ATTACH.

Criar um banco de dados

CREATE DATABASE test_database
ENGINE = PostgreSQL('host:port', 'database', 'user', 'password'[, `schema`, `use_table_cache`]);

Parâmetros do mecanismo

host:port — Endereço do servidor PostgreSQL.
database — Nome do banco de dados remoto.
user — Usuário do PostgreSQL.
password — Senha do usuário.
schema — Esquema do PostgreSQL.
use_table_cache — Define se a estrutura da tabela do banco de dados é armazenada em cache ou não. Opcional. Valor padrão: 0.

Os parâmetros TLS/SSL são encaminhados ao libpq e podem ser fornecidos por meio de uma coleção nomeada ou como argumentos chave-valor ao final: sslmode (disable, allow, prefer, require, verify-ca ou verify-full) e os certificados e a chave em uma de duas formas. sslrootcert (certificado da CA), sslcert (certificado do cliente) e sslkey (chave privada do cliente) são caminhos para arquivos locais do servidor, aceitos somente em uma coleção nomeada definida no arquivo de configuração do servidor. sslrootcert_pem, sslcert_pem e sslkey_pem aceitam, em vez disso, o conteúdo literal do arquivo correspondente, podem ser especificados em SQL (por exemplo, ENGINE = PostgreSQL('host:port', 'database', 'user', 'password', sslmode = 'verify-full', sslrootcert_pem = '...')) e são mascarados nos logs e nas consultas SHOW, como uma senha. Quando não definidos, são aplicados os padrões do libpq (sslmode=prefer).

Suporte a tipos de dados

PostgreSQL	ClickHouse
DATE	Date
TIMESTAMP	DateTime
REAL	Float32
DOUBLE	Float64
DECIMAL, NUMERIC	Decimal (veja a nota abaixo)
SMALLINT	Int16
INTEGER	Int32
BIGINT	Int64
SERIAL	UInt32
BIGSERIAL	UInt64
TEXT, CHAR	String
INTEGER	Nullable(Int32)
ARRAY	Array

numeric(p, 0) no PostgreSQL, com precisão p maior que 76 (o máximo suportado por Decimal256) — por exemplo, numeric(78, 0), comumente usado para armazenar inteiros de 256 bits — é mapeado para Int256 em vez de Decimal. Valores que não cabem no intervalo de Int256 são rejeitados com um erro.

Exemplos de uso

Banco de dados no ClickHouse, trocando dados com o servidor 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 │
└────────────┘

Lendo dados da tabela do PostgreSQL:

SELECT * FROM test_database.test_table;

┌─id─┬─value─┐
│  1 │     2 │
└────┴───────┘

Gravando dados na tabela do PostgreSQL:

INSERT INTO test_database.test_table VALUES (3,4);
SELECT * FROM test_database.test_table;

┌─int_id─┬─value─┐
│      1 │     2 │
│      3 │     4 │
└────────┴───────┘

Considere que a estrutura da tabela foi alterada no PostgreSQL:

postgre> ALTER TABLE test_table ADD COLUMN data Text

Como o parâmetro use_table_cache foi definido como 1 quando o banco de dados foi criado, a estrutura da tabela no ClickHouse ficou armazenada em cache e, por isso, não foi modificada:

DESCRIBE TABLE test_database.test_table;

┌─name───┬─type──────────────┐
│ id     │ Nullable(Integer) │
│ value  │ Nullable(Integer) │
└────────┴───────────────────┘

Depois de desanexar a tabela e anexá-la novamente, a estrutura foi atualizada:

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

Referência de SQL

Tipos de dados

Motores

Funções

Formatos

Configurações

Tabelas do sistema

Lagos de dados

Criar um banco de dados

Suporte a tipos de dados

Exemplos de uso

​Criar um banco de dados

​Suporte a tipos de dados

​Exemplos de uso

​Conteúdo relacionado

Criar um banco de dados

Suporte a tipos de dados

Exemplos de uso

Conteúdo relacionado