示例-从 PostgreSQL 同步到 ProtonBase

postgres=# grant select on all tables in schema ${schema1}，[${other_schema}] to ${user};
postgres=# grant usage on ${schema1}，[${other_schema}]  to ${user};

psql postgres://${user}:${password}@${host}:5432/${your_database_name}

CREATE USER ${cdc_user} WITH REPLICATION ENCRYPTED PASSWORD '${cdc_user_passord}';

postgres=# grant select on all tables in schema schema1，[other_schema] to ${cdc_user};
postgres=# grant usage on schema schema1，[other_schema] to ${cdc_user};

psql -h ${host} -p 5432 -U ${user}  "dbname=${your_database_name} replication=database" -W

CREATE PUBLICATION teleport_pub FOR ALL TABLES;

CREATE PUBLICATION teleport_pub FOR TABLE ${your_schema}.${your_table}, ...;

concat(SOURCE_DATABASE, '.', SOURCE_SCHEMA, '.', SOURCE_OBJECT)