PostgreSQL 字典源

设置示例：

DDL

SOURCE(POSTGRESQL(
    port 5432
    host 'postgresql-hostname'
    user 'postgres_user'
    password 'postgres_password'
    db 'db_name'
    table 'table_name'
    replica(host 'example01-1' port 5432 priority 1)
    replica(host 'example01-2' port 5432 priority 2)
    where 'id=10'
    invalidate_query 'SQL_QUERY'
    query 'SELECT id, value_1, value_2 FROM db_name.table_name'
))

配置文件

<source>
  <postgresql>
      <host>postgresql-hostname</hoat>
      <port>5432</port>
      <user>clickhouse</user>
      <password>qwerty</password>
      <db>db_name</db>
      <table>table_name</table>
      <where>id=10</where>
      <invalidate_query>SQL_QUERY</invalidate_query>
      <query>SELECT id, value_1, value_2 FROM db_name.table_name</query>
  </postgresql>
</source>

设置字段：

Setting	Description
host	PostgreSQL 服务器上的主机地址。可为所有副本统一指定，或者为每个副本单独指定（在 <replica> 内）。
port	PostgreSQL 服务器上的端口。可为所有副本统一指定，或者为每个副本单独指定（在 <replica> 内）。
user	PostgreSQL 用户名。可为所有副本统一指定，或者为每个副本单独指定（在 <replica> 内）。
password	PostgreSQL 用户的密码。可为所有副本统一指定，或者为每个副本单独指定（在 <replica> 内）。
replica	副本配置部分。可以包含多个此类部分。
replica/host	PostgreSQL 主机地址。
replica/port	PostgreSQL 端口。
replica/priority	副本优先级。尝试连接时，ClickHouse 会按优先级顺序遍历副本。数字越小，优先级越高。
db	数据库名称。
table	表名称。
where	选择条件。条件语法与 PostgreSQL 中 WHERE 子句相同。例如，id > 10 AND id < 20。可选。
invalidate_query	用于检查字典状态的查询。可选。详情参见章节 使用 LIFETIME 刷新字典数据。
background_reconnect	当连接失败时在后台重新连接到副本。可选。
query	自定义查询。可选。

注意

table 或 where 字段不能与 query 字段同时使用，并且必须声明 table 或 query 字段中的一个。