Gbase 8s 数据捕获接口使用方法
免费下载
Gbase 8s
数据捕获接口使用方法
1 Change Data Capture API
简介
使外部的客户端程序能够捕获
的事务数据。用户可以
在各种客户端程序上使用这套接口，例如
。接口以智能
大对象的形式返回
记录，用户可以使用智能大对象读取函数读取
数据。用户根据
自己的应用可以决定如何处理这些数据。例如，可以编写一个程序将
数据库中的
数据复制到另外一个数据库上。
在开始捕获一个表的数据时，
输出了表的结构信息，用户可以
使用这些信息去创建一个表。当数据捕获开始以后，表结构变化时将不再提供新的表结构
数据。
仅提供变化的数据，它不提供数据库内容的初始快照。如果
用户需要迁移一个表，可以通过其它方式复制现有数据。然后再使用
在新表上进行数据更新。
只有当数据库的日志打开时，
才能够正常工作。
2 Change Data Capture API
使用方法
2.1
准备工作
在使用
之前需要做一些准备工作：
!
在需要进行
的数据库上打开日志开关。
"!
执行
#$%&'(&
目录下的
)* !+,
脚本，它会创建
)*
数据库，并
在
)*
数据库中创建若干表和函数。
-!
确认
)* !+,
脚本成功创建
)*
数据库。
.!
设置环境变量
/
，使它和需要进行
的数据库的本地化
0,1,2
设置相
同。
2.2 CDC API
的基本使用方法
使用
需要如下基本步骤
3
!
使用
451647
用户连接到
)*
数据库（准备工作中创建的）。
"!
调用
/102
函数，
/102
函数会返回一个
41
。
-!
调用
//5,,18,1402
函数打开
5,,18,14
。每个需要捕获的表都要调用
一次。
.!
调用
/02
通知数据库需要捕获哪些表（数据名
9
表名）和哪些列需要
捕获。每个表需要调用一次。
:!
调用
/;*02
函数启动数据库捕获过程。
<!
数据通过智能大对象返回。需要通过智能大对象读取函数例如
64/,1/02
进
行读取。使用
41
作为智能大对象的文件描述符参数。
=!
解析智能大对象中返回的数据。在
*
程序中可以使用
57>1*>)
类将一个
)6
转换为
?*
的类和类型。
!
为每一个表调用一次
/02
函数。
@!
为每一个表调用一次
//5,,18,1402
函数，关闭
5,,18,14
。
A!
调用
/,102
关闭
的
41
。
注意
: CDC
数据中在开头会包含表结构信息，需要按照
CDC_REC_TABSCHEMA
的格式进
行 解 析 。 解 析 之 后 可 以 获 得 表 的 字 段 组 成 ， 和 各 个 字 段 的 排 列 顺 序 ， 这 将 在 解 析
CDC_REC_INSERT /CDC_REC_UPDBEF / CDC_REC_UPDAFT /CDC_REC_DELETE
类型记录时使用
到。具体示例参见
4.3
节 。
2.3 CDC
记录基本格式
每条
记录通常由以下几个部分构成
3
Common header.
Record-specific header
Record-content
! 1661!
所有的
记录都是相同的。
1661
中的
&16
字段用来表明当
前 记 录 的 记 录 类 型 ， 需 要 使 用
&16
字 段 的 值 到
)*
数 据 库
))
表中去匹配
6
字段。根据匹配到的记录中的
6
字段可以
获取当前记录的类型。例如是
CDC_REC_INSERT
还是
CDC_REC_UPDBEF
。
"! &14B
这一部分根据
记录类型的不同而有着不同的格式。
-! &11
通常这一部分包含着数据变化部分内容。对于
/&/$&>/&/C%
/&/C%>/&/>
，内容由以下几部分组成：
!
可变长度列的长度
如果记录中存在可变长度列的内容，每个列将对应
.
个字节的长度说明。这些
长度说明的顺序与
/&/>D'
记录中列的排列顺序相同。
!
固定长度列数据
如果记录存在固定长度列的内容，这些列将按照
/&/>D'
记录中
列的排列顺序出现。具体数据格式参见第
<!
节 。
!
可变长度列数据
如果记录存在可变长度列的内容，这些列将按照
/&/>D'
记录中
列的排列顺序出现。具体数据格式参见第
<!"
节 。
举例说明：
数据库使用如下语句创建：
,, 04*42E
会话开始之后会首先收到一个
/&/>D'
记录（表中数据为
<
进制数
据）：
00 00 00 24 00 00 00 26 00 00 00 42 00 00 00 c8
00 00 00 00 00 00 00 00 00 00 00 08 00 00 00 02
00 00 00 01 61 20 69 6e 74 65 67 65 72 2c 20 63
20 69 6e 74 65 67 65 72 2c 20 62 20 76 61 72 63
68 61 72 28 32 30 2c 30 29 00
其中红色的部分是
1661!
最开始
.
个字节表明
1661
和
&1
4B
的合计长度是
A7".
（红色和绿色的部分的长度，因为
1661
固定
为
<
个字节，因此
&14B
长度为
"A
）。接下来的
.
个字节说明记录内容长
度是
A7"<
（黑色部分）
!
用户根据最后
.
个字段
AAAAAA
到
))
表中去查询
6
等于
A7
的记录，该条记录的
6
为
F/&/>D'F
。我们就可以知道
这是一条
/&/>D'
记录。
绿色的部分是
&14B
。接下来就可以根据参考文献【
】中的说明来解
析绿色的
&14B
部分。最开始的
.
个字节是在调用
/02
函数时
传入的
C
，它可以用来区分不同的表。接下来的
.
个字节必须为
A
。再接下来的
.
个字节说明固定长度字段占用了
个字节（两个
4
字段）。再接下来的
.
个字节说明有
"
个固定长度列。再接下来的
.
个字节说明有
个可变长度列。
最后黑色部分是各个字段的类型说明（
44
字符）：’
44*0"AA2G
。请注意这里的字段排列顺序。
of 4
免费下载
【版权声明】本文为墨天轮用户原创内容，转载时必须标注文档的来源（墨天轮），文档链接，文档作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
下载排行榜
1
2
9-数据库人的进阶之路：从PG分区、SQL优化到拥抱AI未来（罗敏）.pptx
3
1-PG版本兼容性案例（彭冲）.pptx
4
2-TDSQL PG在复杂查询场景中的挑战与实践-opensource.pdf
5
6-PostgreSQL 哈希索引原理浅析（文一）.pdf
6
3-AI时代的变革者-面向机器的接口语言(MOQL)_吕海波.pptx
7
8-基于PG向量和RAG技术的开源知识库问答系统MaxKB.pptx
8
4-IvorySQL V4：双解析器架构下的兼容性创新实践.pptx
9
7-拉起PG好伙伴DifySupaOdoo.pdf
10
《云原生安全攻防启示录》李帅臻.pdf
相关文档
评论