初始化插件
通过pgxc_ctl新建一个双CN、双DN的实例,并开启服务。
通过telesql连接到CN节点。
在配置文件中设置加载shared_preload_libraries。
创建插件
通过telesql连接到CN节点。
执行sql “create extension teledbx_cdc”
执行telesql命令\dx,查看插件teledbx_cdc是否存在。
执行sql “select teledbx_init_cdc_meta();”对元数据进行初始化。
管理cdc复制槽
执行以下语法在所有数据节点创建逻辑复制槽
select * from teledbx_create_logical_replication_slot('cdc_demo','teledbx_cdc');
执行以下语法查看元数据
select * from teledbx.cdc_slot;
执行以下语法删除逻辑复制槽
select * from teledbx_drop_logical_replication_slot('cdc_demo');
读取变更数据
执行以下语法对变更数据进行可重复读,返回结果为text类型
select * from teledbx_cdc_peek_changes('slot_name', batch_count, optional-value);
执行以下语法对变更数据进行可重复读,返回结果为binary类型
select * from teledbx_cdc_peek_binary_changes('slot_name', batch_count, optional-value);
执行以下语法推高逻辑复制槽位点
teledb=
执行以下语法对变更数据进行不可重复读,返回结果为text类型
select * from teledbx_cdc_get_changes('slot_name', batch_count, optional-value);
执行以下语法对变更数据进行不可重复读
select * from teledbx_cdc_get_binary_changes('slot_name', batch_count, optional-value);