使用CDC需要如下基本步骤:

  1. 使用informix用户连接到syscdcv1数据库(准备工作中创建的)。
  2. 调用cdc_opensess()函数,cdc_opensess()函数会返回一个session ID
  3. 调用cdc_set_fullrowlogging()函数打开full-row logging。每个需要捕获的表都要调用一次。
  4. 调用cdc_startcapture()通知数据库需要捕获哪些表(数据名+表名)和哪些列需要捕获。每个表需要调用一次。
  5. 调用dc_activatesess()函数启动数据库捕获过程。
  6. CDC数据通过智能大对象返回。需要通过智能大对象读取函数例如mi_lo_read()进行读取。使用session ID作为智能大对象的文件描述符参数。
  7. 解析智能大对象中返回的数据。在Java程序中可以使用IfxToJavaType类将一个byte stream转换为java的类和类型。
  8. 为每一个表调用一次cdc_endcapture()函数。
  9. 为每一个表调用一次dc_set_fullrowlogging()函数,关闭full-row logging
  10. 调用cdc_closesess()关闭CDC的session。

Logo

DAMO开发者矩阵,由阿里巴巴达摩院和中国互联网协会联合发起,致力于探讨最前沿的技术趋势与应用成果,搭建高质量的交流与分享平台,推动技术创新与产业应用链接,围绕“人工智能与新型计算”构建开放共享的开发者生态。

更多推荐