1 .一种数据同步方法,其特征在于,所述方法包括:
基于源数据库中的待同步数据表的分片数量,确定分片计数值的初始值,其中,所述待
同步数据表包括一个或多个分片,每个所述分片包括第一数值的待同步子数据;
针对每个所述分片,
将所述待同步子数据写入与所述待同步数据表相对应的同步内存中;
将所述分片计数值减少所述第一数值;
在所述分片计数值为第二数值的情况下,基于所述同步内存中保存的数据,对目标数
据库进行数据同步。
2.根据权利要求1所述的方法,其特征在于,所述方法还包括:
在数据同步开始时,对所述源数据库添加写锁和读锁;
在每个所述分片中的所述待同步子数据写入至所述同步内存中后,释放所述写锁;
将所述同步内存中保存的数据写入所述目标数据库后,释放所述读锁。
3 .根据权利要求1所述的方法,其特征在于,所述基于源数据库中的待同步数据表的分
片数量,确定分片计数值的初始值,包括:
基于所述待同步数据表,从所述源数据库的日志文件中确定所述分片数量;
基于所述分片数量,设置所述分片计数值的初始值。
4 .根据权利要求1所述的方法,其特征在于,所述方法还包括:
响应于用户提交的数据同步暂停指令,利用调度策略脚本和多个二进制同步工具,暂
停数据同步,其中,所述调度策略脚本用于控制所述多个二进制同步工具,所述多个二进制
同步工具用于对所述源数据库中的待同步数据进行解析、同步,所述待同步数据包括多个
所述待同步数据表;
基于所述调度策略脚本,确定已同步数据;
基于所述待同步数据和所述已同步数据,确定未同步数据;
响应于所述用户提交的数据同步继续指令,利用所述调度策略脚本和所述多个二进制
同步工具,将所述未同步数据同步至所述同步内存。
5 .根据权利要求4所述的方法,其特征在于,所述方法还包括:
针对每个所述待同步子数据,在所述待同步子数据同步完成后,在所述同步内存的同
步文件中创建与所述待同步子数据的数据标记相对应的同步记录。
6 .根据权利要求5所述的方法,其特征在于,所述基于所述调度策略脚本,确定已同步
数据,包括:
确定多个所述待同步子数据各自的所述数据标记;
基于所述同步内存的同步文件中保存的一个或多个所述同步记录,确定已同步完成的
一个或多个所述数据标记;
基于已同步完成的一个或多个所述数据标记,确定所述已同步数据。
7 .根据权利要求6所述的方法,其特征在于,所述基于所述待同步数据和所述已同步数
据,确定未同步数据,包括:
将全部所述待同步子数据的数据标记和所述已同步数据包括的所述数据标记进行差
值计算,确定所述同步记录不包括的所述数据标记;
基于所述同步记录不包括的所述数据标记,确定所述未同步数据。
权 利 要 求 书
1/2 页
2
评论