tencent cloud

CREATE TABLE postgres_cdc_source_table (
  id INT,
  name STRING,
  PRIMARY KEY (`id`) NOT ENFORCED -- Define the primary key here if the database table to be synced has it defined.
) WITH (
  'connector' = 'postgres-cdc',             -- Here, it should be'postgres-cdc'.
  'hostname' = 'yourHostname',              -- IP of the database server.
  'port' = '5432',                --  Integer port number of the database server.
  'username' = 'yourUserName',              Name of the PostgreSQL database to use when connecting to the PostgreSQL database server (REPLICATION, LOGIN, SCHEMA, DATABASE, and SELECT permissions are required).
  'password' = 'psw'  -- Password to use when connecting to the PostgreSQL database server.
  'database-name' = 'yourDatabaseName',     -- Database name of the PostgreSQL server to monitor.
  'schema-name' = 'yourSchemaName',         -- Schema name of the PostgreSQL database to monitor (a regex is supported).
  'table-name' = 'yourTableName',           -- Table name of the PostgreSQL database to monitor (a regex is supported).
  'debezium.slot.name' = 'customslotname'   -- Define a unique slot name, which supports lowercase letters, digits, and underscores.
);

CREATE TABLE postgres_cdc_source_table (
  id INT,
  name STRING,
  PRIMARY KEY (`id`) NOT ENFORCED -- Define the primary key here if the database table to be synced has it defined.
) WITH (
  'connector' = 'postgres-cdc',             -- Here, it should be'postgres-cdc'.
  'hostname' = 'yourHostname',              -- IP of the database server.
  'port' = '5432',                --  Integer port number of the database server.
  'username' = 'yourUserName',              Name of the PostgreSQL database to use when connecting to the PostgreSQL database server (REPLICATION, LOGIN, SCHEMA, DATABASE, and SELECT permissions are required).
  'password' = 'psw'  -- Password to use when connecting to the PostgreSQL database server.
  'database-name' = 'yourDatabaseName',     -- Database name of the PostgreSQL server to monitor.
  'schema-name' = 'yourSchemaName',         -- Schema name of the PostgreSQL database to monitor (a regex is supported).
  'table-name' = 'yourTableName',           -- Table name of the PostgreSQL database to monitor (a regex is supported).
  'debezium.slot.name' = 'customslotname'   -- Define a unique slot name, which supports lowercase letters, digits, and underscores.
);

CREATE TABLE `print_table` (
  `id` INT,
  `name` STRING
) WITH (
 'connector' = 'print'
);
insert into print_table select * from postgres_cdc_source_table;

CREATE ROLE debezium_user REPLICATION LOGIN; 
GRANT USAGE ON SCHEMA schema_name TO debezium_user;
GRANT USAGE ON DATABASE schema_name TO debezium_user;
GRANT SELECT ON scheam_name.table_name, scheam_name.table_name TO debezium_user;