-
公开(公告)号:CN117785390A
公开(公告)日:2024-03-29
申请号:CN202311845991.9
申请日:2023-12-28
Applicant: 北京人大金仓信息技术股份有限公司
Abstract: 本申请提供一种分布式事务实现方法、装置、设备及存储介质,共享存储集群的第一节点响应协调者发送的准备请求为分布式事务生成全局事务标识符,存储全局事务标识符至共享存储集群以及对分布式事务进行持久化操作,返回准备结果信息至协调者,准备结果信息包括同意信息或中止信息。共享存储集群的第二节点响应协调者发送的提交请求若确定全局事务标识符存在于共享存储集群,读取持久化数据并提交分布式事务,进而返回提交结果信息至协调者,提交结果信息包括完成事务信息或回滚事务信息。基于共享存储集群的结构特点,以将共享存储集群作为参与者用于分布式事务,当出现节点宕机时,也不影响提交操作,实现分布式事务系统的高可用性。
-
公开(公告)号:CN117763046A
公开(公告)日:2024-03-26
申请号:CN202311845109.0
申请日:2023-12-28
Applicant: 北京人大金仓信息技术股份有限公司
Abstract: 本申请提供一种集群间数据同步的方法、装置、设备及存储介质。该方法包括:主集群中的任一节点在检测到主集群的节点发生变更时,可以执行节点检查操作,并生成预写式日志,将预写式日志归档至节点对应的归档目录中;备集群中的预设同步节点在备集群启动后,可以从主集群的每个节点对应的归档目录中读取节点的预写式日志,根据每个节点的预写式日志中的活跃节点列表,更新优先队列中的日志记录,根据优先队列中的日志记录依次对主集群节点的数据进行同步。本申请的方法,可以在预写式日志中获取集群活跃节点列表,实现了主集群中的节点变更时,备集群可以同步读取主集群节点变更信息,进行正确的数据同步。
-
公开(公告)号:CN117762875A
公开(公告)日:2024-03-26
申请号:CN202311843343.X
申请日:2023-12-28
Applicant: 北京人大金仓信息技术股份有限公司
IPC: G06F16/16 , G06F16/182 , G06F16/13 , G06F16/176 , G06F16/27 , G06F16/23
Abstract: 本发明提供了一种数据库集群的数据结构、及其数据写入方法、数据读取方法,包括:索引节点,其包括主基础信息和多个分块地址指针;多个数据块,每个数据块包括多个块数据和一个块元数据,分块地址指针用于指向其对应的数据块,块元数据包括其所处数据块的数据块基础信息;主基础信息、多个数据块的所有数据块基础信息以及所有分块地址指针构成文件的元数据信息;数据块基础信息包括块数据内存储的具体数据的地址空间,地址空间用于数据库集群的输入输出操作,以减少对索引节点的频繁修改。本发明的数据库集群的数据结构可以对不同的数据块分别采用不同的锁,将索引节点从数据块操作中解放出来,降低锁冲突,以提升数据库的性能。
-
公开(公告)号:CN116483846A
公开(公告)日:2023-07-25
申请号:CN202310390103.2
申请日:2023-04-12
Applicant: 北京人大金仓信息技术股份有限公司
Inventor: 杨尚
IPC: G06F16/23 , G06F16/22 , G06F16/2458
Abstract: 本发明提供了一种无效索引项标记的冲突处理方法、存储介质和计算机设备,其中方法包括:获取设定时间段内的统计信息,并判断所述统计信息中的top sql是否满足预设条件,所述预设条件至少包括涉及索引扫描;获取设定时间段内的统计信息,并判断所述统计信息中的top sql是否满足预设条件,所述预设条件至少包括涉及索引扫描;若是,则根据预设规则修改所述top sql涉及的索引对象的尝试标记无效索引项的概率。本发明的技术方案,能够提高对索引对象的尝试标记无效索引项的概率修改的时效性,并降低修改的人工成本。
-
公开(公告)号:CN116483845A
公开(公告)日:2023-07-25
申请号:CN202310389324.8
申请日:2023-04-12
Applicant: 北京人大金仓信息技术股份有限公司
Inventor: 杨尚
Abstract: 本发明提供了一种优化并发冲突的无效索引的标记方法、存储介质和设备。方法包括允许索引页面的访问和禁止索引页面的物理修改;查找索引页面上的无效索引项,并记录索引页面的第一修改序号;当完成对索引页面上无效索引项的查找时,允许对索引页面的物理修改;记录索引页面上查找到的无效索引项,并在记录完成后禁止索引页面的物理修改;记录索引页面的第二修改序号;根据第一修改序号和第二修改序号确定记录的索引页面的无效索引项是否为最终无效索引项;若是,将所述最终无效索引项标记为无效,并允许对索引页面的物理修改。本发明的技术方案能够保证无效索引项标记准确性的情况下,增加数据系统的吞吐量。
-
公开(公告)号:CN114265900A
公开(公告)日:2022-04-01
申请号:CN202111614639.5
申请日:2021-12-27
Applicant: 北京人大金仓信息技术股份有限公司
IPC: G06F16/27 , G06F16/2458 , G06F11/14
Abstract: 本公开涉及一种数据处理方法、装置、电子设备及存储介质,应用于数据存取领域,解决了现有异步刷盘存在的数据丢失量大的问题,该方法包括:从至少一个数据库节点提交的多个事务所对应的多个时间戳中,确定目标同步时间戳;根据目标同步时间戳,从至少一个数据库节点的内存中确定多个事务所对应的多个事务日志;将多个事务日志从至少一个数据库节点的内存中同步至至少一个数据库节点的磁盘;在分布式数据库发生异常时,根据目标同步时间戳从至少一个数据库节点的磁盘中确定同步时间戳之前的多个事务日志;将多个事务日志恢复至至少一个数据库节点的内存,以使分布式数据库恢复至发生异常之前的状态。
-
公开(公告)号:CN114254041A
公开(公告)日:2022-03-29
申请号:CN202111505722.9
申请日:2021-12-10
Applicant: 北京人大金仓信息技术股份有限公司
Abstract: 本公开涉及一种共享存储集群的主备流复制方法、装置、电子设备和介质,其中,方法包括:集群中所有节点划分为主子集群和备子集群,主子集群和备子集群均对客户端提供服务,主子集群接收客户端发送的读写请求,基于读写请求进行内容修改并生成日志,主子集群将日志发送给备子集群,备子集群接收到日志,对日志进行分析处理确定目标修改内容,并基于目标修改内容对备子集群的共享存储中的数据进行与主子集群相同的修改。由此,将集群所有节点划为两个子集群,两个子集群间使用主备流复制的方式进行同步,以使两个集群间保持数据一致性。
-
公开(公告)号:CN114238496A
公开(公告)日:2022-03-25
申请号:CN202111474096.1
申请日:2021-12-02
Applicant: 北京人大金仓信息技术股份有限公司
IPC: G06F16/27 , G06F16/245 , G06F3/06
Abstract: 本公开涉及一种数据恢复方法、装置、设备及计算机可读存储介质,本公开由于将原有存储在易失内存中的修改后的数据块、修改后的数据块的标识信息、以及修改后的数据块所对应的修改日志的标识信息又存储到非易失内存中,即使第一节点出现故障,易失内存中的数据丢失,其它节点仍然可以从非易失内存中获取,相比于现有技术,从外存中进行全量的恢复,本公开实施例不需要进行全量的恢复,只需要从非易失内存中读取所述目标数据块的相关数据并进行恢复,对数据恢复时间较短,从而提高了数据恢复的效率。而且现有技术恢复时间过长,恢复过程中极为影响数据库的正常工作。本公开实施例恢复时间短,对数据库影响较弱。
-
公开(公告)号:CN114238103A
公开(公告)日:2022-03-25
申请号:CN202111512147.5
申请日:2021-12-07
Applicant: 北京人大金仓信息技术股份有限公司
Abstract: 本公开提供了一种TPC‑E测试工具的改进方法,涉及数据库技术领域。所述方法包括:接收事务请求信息;将事务请求信息集合存储至事务缓存队列中;所述事务请求信息集合为多个客户端发送的事务请求信息组成的集合;根据预设启动线程数目读取所述事务缓存队列的事务请求信息,并对所述事务请求信息进行处理,获取事务响应结果;所述预设启动线程数目用于指示读取事务请求信息的数量;将所述事务响应结果发送至客户端。采用本方法能够在用户请求数量增加的情况下,提高数据库测试工具dbt5的并发处理能力,保证测试结果稳定。
-
公开(公告)号:CN114142866A
公开(公告)日:2022-03-04
申请号:CN202111424097.5
申请日:2021-11-26
Applicant: 北京人大金仓信息技术股份有限公司
Abstract: 本申请实施例公开了一种数据压缩方法、装置、电子设备及存储介质,属于数据库技术领域,能够解决对于按列存储的数据源压缩后仍然占有比较大的存储空间,压缩率较高,导致压缩效果差,压缩效率低的问题。该方法包括:获取列存缓存区中的多列待压缩数据源;基于智能化压缩模型,将多列待压缩数据源分为至少一组数据源,并对每组数据源分别进行压缩,得到至少一个压缩数据;其中,每个压缩数据是对一组数据源压缩得到的,智能化压缩模型是根据历史样本数据训练得到。本方案通过将多列待压缩数据源进行分组,灵活选择将至少一列待压缩数据源作为一个数据源进行压缩,使得压缩后的数据源占用的存储空间更小,压缩率降低,进一步提高了压缩效率。
-
-
-
-
-
-
-
-
-