返回首页

gbase数据、南大通用产品文档:GBase8a

更新日期:2024年09月11日

从DB2 CDC文件源中接收数据到GBase 8a
增量同步
在8.6.9.0 版本中增加了对DB2 CDC 文件源中数据的解析同步功能。支持
源端为DB2 CDC 文件,目标端为GBase 8a(Consumer)的增量同步。

GBase RTSync 同步工具手册
- 130 -
南大通用数据技术股份有限公司
由于在数据源DB2 CDC 文件中没有源表的元数据信息,所以只支持列级同
步;支持JSON 模式的同步。
目标端为GBase 8a(Consumer)时,需要配置为部分部署模式,即只配置
读端,配置方法参考2.3.6.11 章节。
支持断点续传功能。
config_task.xml 中,需要修改如下内容:
需要在标签下修改的部分:

增加isExitWhileError 属性,在遇到错误时是否强制退出服务,
而不考虑任务错误处理。默认为false。
需要在标签下修改的部分:

设置type=”CDCFILE”;

增加separator 属性,设置为数据中的分隔符,默认值
为’\x7C\x1C’;

增加logRetentionDays 属性,
设置为保留已经归档的数据文件的
最大天数;

增加logRetentionCheckIntervals 属性,
设置为检查归档数据是
否过期的周期,单位为秒;

增加logArchivedIntervals 属性,
设置为检查数据文件是否需要
归档的周期,单位为秒;
需要在每个

标签下修改的部分:

增加isContinueSyncWhileError 属性,
用于判断当该表的一条数
据解析或者同步出现问题时,是否继续同步该表后续的数据;如
果配置为true,则将该错误数据记录到日志中继续同步后面的数
据;配置为false 则将该错误数据记录到日志后,停止该表数据
的解析和同步。

GBase RTSync 同步工具手册
南大通用数据技术股份有限公司
- 131 -

GBase UP 以
“YYYY-MM-DD HH:MI:SS.ffffff”
格式显示DATETIME 值。
其中ffffff
表示微秒格式。
日期和时间的组合类型。
支持的范围是
“0001-01-01 00:00:00.000000”

“9999-12-31
23:59:59.999999”。

示例1:插入一个合法的DATETIME 值。
gbase> CREATE TABLE products (productDate DATETIME);
Query OK, 0 rows affected

GBase UP 产品手册 5 数据库管理指南
文档版本04(2021-04-21) 南大通用数据技术股份有限公司 353

gbase> INSERT INTO products(productDate) VALUES('2010-09-01 12:09:44');
Query OK, 1 row affected

gbase> SELECT productDate FROM products;
+---------------------+
| productDate |
+---------------------+
| 2010-09-01 12:09:44 |
+---------------------+
1 row in set

示例2:插入系统当前的DATATIME 值。
gbase> INSERT INTO products(productDate) VALUES(NOW());
Query OK, 1 row affected

gbase> SELECT productDate FROM products;
+---------------------+
| productDate |
+---------------------+
| 2013-10-16 17:51:38 |
+---------------------+
1 row in set

示例3:插入一个NULL 值。
gbase> INSERT INTO products(productDate) VALUES(NULL);
Query OK, 1 row affected

gbase> SELECT productDate FROM products;
+-------------+
| productDate |
+-------------+
| NULL |
+-------------+
1 row in set

示例4:插入一个带有微秒的DATETIME 数值。
gbase> INSERT INTO products(productDate) VALUES('2013-09-15 12:09:44.123456');
Query OK, 1 row affected

gbase> SELECT productDate FROM products;
+----------------------------+
| productDate |
+----------------------------+
| 2013-09-15 12:09:44.123456 |
+----------------------------+
1 row in set

GBase UP 产品手册 5 数据库管理指南
文档版本04(2021-04-21) 南大通用数据技术股份有限公司 354

示例5:插入一个非法的DATETIME 值,系统将报告错误信息。
gbase> INSERT INTO products(productDate) VALUES('2010-09-31 12:09:44');
ERROR 1292 (22007): Incorrect datetime value: '2010-09-31 12:09:44' for column
'productDate' at row 1

功能
这个参数用于设置SQL 批量执行的数量,
主要控制并发时,
下发到gnode 的SQL
数量。
参数取值含义说明

参数= 0 :不进行控制,SQL 全部下发到gnode;

参数= 其他值:进行控制。
该参数的默认值是0。
表6- 19 参数值范围说明表
默认值
最小值
最大值
0
0
65536