CDC CDC是一种用于捕获,处理和同步TeleDBX实例数据变化的工具,允许将实例中的变更数据实时地同步到下游系统。本页为您介绍CDC的使用和管理操作。 初始化插件 1. 通过pgxcctl新建一个双CN、双DN的实例,并开启服务。 2. 通过telesql连接到CN节点。 3. 在配置文件中设置加载sharedpreloadlibraries。 创建插件 1. 通过telesql连接到CN节点。 执行sql “create extension teledbxcdc” 2. 执行telesql命令dx,查看插件teledbxcdc是否存在。 3. 执行sql “select teledbxinitcdcmeta();”对元数据进行初始化。 管理cdc复制槽 1. 执行以下语法在所有数据节点创建逻辑复制槽 plaintext select from teledbxcreatelogicalreplicationslot('cdcdemo','teledbxcdc'); 2. 执行以下语法查看元数据 plaintext select from teledbx.cdcslot; 3. 执行以下语法删除逻辑复制槽 plaintext select from teledbxdroplogicalreplicationslot('cdcdemo'); 读取变更数据 1. 执行以下语法对变更数据进行可重复读,返回结果为text类型 plaintext select from teledbxcdcpeekchanges('slotname', batchcount, optionalvalue); 2. 执行以下语法对变更数据进行可重复读,返回结果为binary类型 plaintext select from teledbxcdcpeekbinarychanges('slotname', batchcount, optionalvalue); 3. 执行以下语法推高逻辑复制槽位点 plaintext teledb 4. 执行以下语法对变更数据进行不可重复读,返回结果为text类型 plaintext select from teledbxcdcgetchanges('slotname', batchcount, optionalvalue); 5. 执行以下语法对变更数据进行不可重复读 plaintext select from teledbxcdcgetbinarychanges('slotname', batchcount, optionalvalue);