3.2. Debezium Db2 连接器如何工作

流程

1. 发送 SQL 查询，将临时增量快照请求添加到信号表中：

   INSERT INTO <signalTable> (id, type, data) VALUES ('<id>', '<snapshotType>', '{"data-collections": ["<tableName>","<tableName>"],"type":"<snapshotType>","additional-condition":"<additional-condition>"}');

   例如，

   INSERT INTO myschema.debezium_signal (id, type, data) 

   1

   
   values ('ad-hoc-1',   

   2

   
       'execute-snapshot',  

   3

   
       '{"data-collections": ["schema1.table1", "schema2.table2"], 

   4

   
       "type":"incremental"}, 

   5

   
       "additional-condition":"color=blue"}'); 

   6

   命令中的 id、type 和 data 参数的值对应于 信号表的字段。

   下表描述了示例中的参数：

   表 3.2. 向信号表发送增量快照信号的 SQL 命令中的字段描述

   项	值	描述
   1	myschema.debezium_signal	指定源数据库上信号表的完全限定名称。
   2	ad-hoc-1	id 参数指定分配给信号请求的 id 标识符的任意字符串。 使用此字符串来标识到信号表中条目的日志消息。Debezium 不使用此字符串。相反，在快照中，Debebe 会生成自己的 id 字符串作为水位信号。
   3	execute-snapshot	type 参数指定信号要触发的操作。
   4	data-collections	信号的 data 字段所需的组件，用于指定表名称或正则表达式数组，以匹配快照中包含的表名称。 数组列出了根据完全限定名称匹配表的正则表达式，其格式与您用来指定 signal.data.collection 配置属性中的连接器信号表的名称相同。
   5	增量	信号的 data 字段的可选 类型 组件，用于指定要运行的快照操作类型。 目前，唯一有效选项是默认值 增量。 如果没有指定值，连接器将运行一个增量快照。
   6	additional-condition	可选字符串，它根据表的列指定条件，用于捕获表内容的子集。有关 additional-condition 参数的详情请参考 带有额外条件的临时增量快照。

流程

1. 发送 SQL 查询以停止临时增量快照到信号表：

   INSERT INTO <signalTable> (id, type, data) values ('<id>', 'stop-snapshot', '{"data-collections": ["<tableName>","<tableName>"],"type":"incremental"}');

   例如，

   INSERT INTO myschema.debezium_signal (id, type, data) 

   1

   
   values ('ad-hoc-1',   

   2

   
       'stop-snapshot',  

   3

   
       '{"data-collections": ["schema1.table1", "schema2.table2"], 

   4

   
       "type":"incremental"}'); 

   5

   signal 命令中的 id、type 和 data 参数的值对应于 信号表的字段。

   下表描述了示例中的参数：

   表 3.3. 向信号表发送停止增量快照信号的 SQL 命令中的字段描述

   项	值	描述
   1	myschema.debezium_signal	指定源数据库上信号表的完全限定名称。
   2	ad-hoc-1	id 参数指定分配给信号请求的 id 标识符的任意字符串。 使用此字符串来标识到信号表中条目的日志消息。Debezium 不使用此字符串。
   3	stop-snapshot	指定 type 参数指定信号要触发的操作。
   4	data-collections	信号的 data 字段的可选组件，用于指定表名称或正则表达式数组，以匹配要从快照中删除的表名称。 数组列出了根据完全限定名称匹配表的正则表达式，其格式与您用来指定 signal.data.collection 配置属性中的连接器信号表的名称相同。如果省略了 data 字段的此组件，则信号将停止正在进行的整个增量快照。
   5	增量	信号的 data 字段所需的组件，用于指定要停止的快照操作类型。 目前，唯一有效选项是 增量的。 如果没有指定 类型 值，则信号无法停止增量快照。