1 .一种数据库日志的同步系统,其特征在于,包括:
源数据库,用于执行从业务端接收的SQL请求并生成日志数据;
所述源数据库包括第一复制组件,所述第一复制组件用于根据目标数据库的复制规
则,判断所述日志数据是否需要复制,并在确定所述日志数据需要复制的情况下,将所述日
志数据发送给所述目标数据库的第二复制组件,其中,一个目标数据库对应一个复制规则,
所述复制规则包括需要复制的表和库;
所述目标数据库,用于在通过所述第二复制组件接收到所述日志数据的情况下,对所
述日志数据进行解析回放,以进行数据复制,并根据所述日志数据中的事务标识,记录同步
日志点位,其中,所述同步日志点位用于连续性校验。
2 .根据权利要求1所述的系统,其特征在于,所述第一复制组件具体用于:
确定所述SQL请求对应的库或表;
在所述SQL请求对应的库或表存在于所述复制规则的情况下,确定所述日志数据需要
复制;
在所述SQL请求对应的库或表不存在于所述复制规则的情况下,确定所述日志数据不
需要复制。
3 .根据权利要求1所述的系统,其特征在于,所述第一复制组件还用于:
在确定所述日志数据不需要复制的情况下,对所述日志数据进行过滤,以使过滤后的
日志数据只包含所述SQL请求的事务标识;
将所述过滤后的日志数据发送至所述第二复制组件,以使所述目标数据库通过所述第
二复制组件接收所述过滤后的日志数据,并根据所述过滤后的日志数据中的事务标识,记
录所述同步日志点位。
4 .根据权利要求3所述的系统,其特征在于,所述第一复制组件还用于:
在连续多个SQL请求的日志数据都被确定为不需要复制的情况下,将所述多个SQL请求
的过滤后的日志数据合并,得到合并后的日志数据;
将所述合并后的日志数据发送至所述第二复制组件,以使所述目标数据库通过所述第
二复制组件接收所述合并后的日志数据,并根据所述合并后的日志数据中的最后一个事务
标识,记录所述同步日志点位。
5 .根据权利要求1所述的系统,其特征在于,所述第二复制组件还用于在所述第一复制
组件或第二复制组件出现异常并恢复后,根据所述同步日志点位继续从所述第一复制组件
获取日志数据。
6 .根据权利要求1所述的系统,其特征在于,所述第一复制组件还用于将所述日志数据
发送至所述源数据库的备用数据库,以使所述备用数据库通过对所述日志数据的解析回放
进行数据复制。
7 .一种数据库日志的同步方法,其特征在于,应用于数据库日志的同步系统,包括:
通过源数据库执行从业务端接收的SQL请求并生成日志数据;
通过所述源数据库的第一复制组件根据目标数据库的复制规则,判断所述日志数据是
否需要复制,其中,一个目标数据库对应一个复制规则,所述复制规则包括需要复制的表和
库;
在确定所述日志数据需要复制的情况下,将所述日志数据发送给所述目标数据库的第
权 利 要 求 书
1/2 页
2
评论