1 .一种基于分布式数据库的数据处理方法,其特征在于,应用于当前节点,所述当前节
点为分布式集群中任一节点;所述方法包括:
确定第一操作的当前状态,以及进入所述当前状态的混合时间戳;其中,所述混合时间
戳由包括物理时钟和逻辑时钟的混合时钟确定;
根据所述第一操作确定待处理的目标数据行;其中,每个数据行包括记录提交时间的
提交混合时间戳和记录的数据,所述目标数据行隶属于至少一个节点;
根据进入所述当前状态的混合时间戳和/或所述目标数据行的提交混合时间戳确定对
所述目标数据行的处理方式。
2.根据权利要求1所述的方法,其特征在于,所述当前节点配置有生成物理时间戳的本
机物理时钟,以及生成第一混合时间戳的混合时钟;所述确定进入所述当前状态的混合时
间戳,包括:
获取当前的第一混合时间戳和物理时间戳,并比对所述物理时间戳与所述第一混合时
间戳的物理时钟部分的数值的大小;
若比对结果为相等,以自增方式更新所述第一混合时间戳的逻辑时钟部分的数值;
若比对结果为大于,更新所述第一混合时间戳的物理时钟部分的数值为所述物理时间
戳,以及以赋零值的方式更新所述第一混合时间戳的逻辑时钟部分的数值;
确定进入所述当前状态的混合时间戳为更新的第一混合时间戳。
3 .根据权利要求1所述的方法,其特征在于,所述第一操作为目标提交操作;所述根据
进入所述当前状态的混合时间戳和/或所述目标数据行的提交混合时间戳确定对所述目标
数据行的处理方式,包括:
若所述目标数据行隶属于一个节点,且所述当前状态为提交状态,所述处理方式包括:
针对所述目标数据行进行更新操作,并将进入所述目标提交操作的提交状态的第二混合时
间戳确定为与所述更新操作相应的数据行的提交混合时间戳;
若所述目标数据行隶属于至少两个节点,且所述当前状态为预提交状态,所述处理方
式包括:根据进入所述目标提交操作的预提交状态的第三混合时间戳确定对所述目标数据
行的处理方式。
4 .根据权利要求3所述的方法,其特征在于,所述根据进入所述目标提交操作的预提交
状态的第三混合时间戳确定对所述目标数据行的处理方式,包括:
获取在所述至少两个节点上进入目标提交操作的预提交状态的第三混合时间戳,并从
中筛选出最大的提交时间戳;
将所述最大的提交时间戳作为进入所述目标提交操作的提交状态的第四混合时间戳,
确定所述处理方式包括:针对所述目标数据行进行更新操作,并将所述第四混合时间戳确
定为与所述更新操作相应的数据行的提交混合时间戳。
5 .根据权利要求1所述的方法,其特征在于,若接收到与所述用户终端相连接的节点发
送的携带第五混合时间戳的任一请求,所述方法还包括:
若所述第五混合时间戳大于当前的第一混合时间戳,更新所述当前的第一混合时间戳
为所述第五混合时间戳。
6 .根据权利要求1所述的方法,其特征在于,所述混合时间戳还包括对应的状态标志;
所述第一操作为目标读操作,以及所述当前状态为开始状态;所述根据进入所述当前状态
权 利 要 求 书
1/3 页
2
评论