1 .一种源端并发导致触发器增量同步异常的处理方法,其特征在于,包括:
获取尚未完成同步的增量数据,并进行在增量目的侧的相应增量数据第一阶段同步;
根据完成增量目的侧数据第一阶段同步的增量数据的CDC_ID值,将连续的一个或者多
个增量数据的CDC_ID值以区间的形式记录,从而得到一个或者多个区间;
在清理增量数据时,根据所述区间值确定位于所述区间值之中的增量数据是已完成第
一阶段同步操作的增量数据并将其删除。
2.根据权利要求1所述的源端并发导致触发器增量同步异常的处理方法,其特征在于,
所述方法还包括:
在清理增量数据时,还包括:根据所述区间值确定位于所述区间值之外的增量数据是
历史上还未在增量目的侧中完成第一阶段同步操作的增量数据;
将所述历史上还未在增量目的侧中完成第一阶段同步操作的增量数据,执行在增量目
的侧的第二阶段的同步操作后,根据相应第二阶段中同步操作的增量数据的CDC_ID值,更
新在第一阶段同步之后生成的一个或者多个区间。
3 .根据权利要求2所述的源端并发导致触发器增量同步异常的处理方法,其特征在于,
所述更新在第一阶段同步之后生成的一个或者多个区间,具体包括:
将在所述第二阶段的同步操作中所完成的第二增量数据的CDC_ID值,与第一阶段已经
生成的一个或者多个区间的边界值进行比较;
若所述第二增量数据的CDC_ID值,与第二区间的一侧边界值相邻,则将所述第二增量
数据的CDC_ID值作为所述第二区间相应侧的新边界值,以此更新所述第二区间;
若所述第二增量数据的CDC_ID值,未与任意一个区间的边界值相邻,则为所述第二增
量数据的CDC_ID值生成一单值区间。
4 .根据权利要求3所述的源端并发导致触发器增量同步异常的处理方法,其特征在于,
所述方法还包括:
若所述第二增量数据的CDC_ID值,分别与第一区间的一侧边界值和第二区间的一侧边
界值相邻,则将所述第一区间和第二区间合并为单一区间。
5 .根据权利要求3所述的源端并发导致触发器增量同步异常的处理方法,其特征在于,
在完成所述第二阶段同步还包括一个或者多个后续阶段同步,所述方法还包括:
在清理增量数据时,若确认一区间所包含的边界值是由1开始,且仅有一区间时;增量
目的向增量源发送同步总量请求消息;
匹配从增量源获取到的同步总量值与所述区间的边界值,若匹配则释放所述区间,完
成本轮从增量源到增量目的的同步过程。
6 .根据权利要求1所述的源端并发导致触发器增量同步异常的处理方法,其特征在于,
所述在清理增量数据时,还包括:
直接删除CDC_ID值已经被归入区间的增量数据;
其中,所述清理增量数据是按照预设时间周期进行,或者,按照预设时间长度未接收到
新的增量数据触发进行,或者,在接收到清理指令后进行。
7 .一种源端并发导致触发器增量同步异常的处理系统,其特征在于,系统中包括增量
源和增量目的,增量源和增量目的之间可以完成数据互通,所述系统包括:
增量源从CDC表中读取数据;
权 利 要 求 书
1/2 页
2
评论