更新日期:2024年09月11日
数据同步系统通过Oracle Golden Gate(OGG)、GBase RTSync 等工具复制
GBase 8a MPP Cluster 技术白皮书
南大通用数据技术股份有限公司
- 17 -
Oracle、
GBase 8s 等数据库的业务数据,
通过kafka 同步到GBase 8a MPP Cluster,
为了应对业务系统可能的峰值,在系统中加入Kafka 消息队列作为缓冲区。总
体流程如下:
图 4-1 处理流程
OGG 发送端(GoldenGate
Extract)从Oracle 的在线日志和归档日志中抽
取事务信息,
生成Trail 文件。
OGG 接收端
(GoldenGate
Replicat)
收到Trail
文件抽取事务信息转换为目标格式,并生产事务消息到Kafka。Consumer 从
Kafka 中消费事务消息,将数据更新到8a MPP Cluster 中。
Kafka consumer 的主要功能就是同步Kafka 数据到8a MPP Cluster:
1) 根据配置,可以指定需要同步的业务;
2) 在同步过程中,提供同步状态查询功能;
3) 实现数据同步的高可用性和事务数据一致性。
虚拟集群及镜像集群
示例1
两个操作数都是整型。
gbase> SELECT 3/5 FROM t;
+-------------+
| 3/5 |
+-------------+
| 0.600000000 |
+-------------+
1 row in set
示例2
除数为0,返回值为NULL。
gbase> SELECT 102/(1-1) FROM t;
+-----------+
| 102/(1-1) |
GBase UP 产品手册 5 数据库管理指南
文档版本04(2021-04-21) 南大通用数据技术股份有限公司 450
+-----------+
| NULL |
+-----------+
1 row in set
说明
只有当在一个结果被转换到一个整数的上下文中执行时,
除法才会以BIGINT 进行算术计算。