公开(公告)号：CN105955804A

公开(公告)日：2016-09-21

申请号：CN201610254762.3

申请日：2016-04-22

Applicant: 星环信息科技(上海)有限公司

Inventor： 徐飞 ,  刘汪根 ,  代克 ,  康毅

IPC: G06F9/46

CPC classification number: G06F17/30362 ,  G06F11/1438 ,  G06F11/203 ,  G06F17/30377 ,  G06F17/30483 ,  G06F2201/80 ,  G06F2201/805 ,  G06F2201/82 ,  G06F2201/825 ,  G06F9/466 ,  G06F9/465

Abstract: 本申请的目的是提供一种处理分布式事务的方法与设备。与现有技术相比，在分布式系统中，本申请的第一设备是由多个节点组成的一个组，所述第一设备获取SQL编译器发送的关于待处理的事务的目标表的加写锁请求，并基于所述加写锁请求，对所述目标表进行加写锁处理，从而避免多个事务并发时的冲突问题，确保事务的隔离性，若所述加写锁处理成功，向所述SQL编译器发送所述目标表的待处理版本信息，以确保后续SQL编译器对目标表的正确版本进行操作。进一步地，本申请通过重启未响应所述加写锁请求的所述子节点，或将所述子节点的服务迁移到其他物理机器上，而后更新所述子节点的加锁状态信息，从而进行有效的出错恢复并保证组内一致性。

公开(公告)号：CN105955804B

公开(公告)日：2018-06-05

申请号：CN201610254762.3

申请日：2016-04-22

Applicant: 星环信息科技(上海)有限公司

Inventor： 徐飞 ,  刘汪根 ,  代克 ,  康毅

IPC: G06F9/46

CPC classification number: G06F17/30362 ,  G06F11/1438 ,  G06F11/203 ,  G06F17/30377 ,  G06F17/30483 ,  G06F2201/80 ,  G06F2201/805 ,  G06F2201/82 ,  G06F2201/825

Abstract: 本申请的目的是提供一种处理分布式事务的方法与设备。与现有技术相比，在分布式系统中，本申请的第一设备是由多个节点组成的一个组，所述第一设备获取SQL编译器发送的关于待处理的事务的目标表的加写锁请求，并基于所述加写锁请求，对所述目标表进行加写锁处理，从而避免多个事务并发时的冲突问题，确保事务的隔离性，若所述加写锁处理成功，向所述SQL编译器发送所述目标表的待处理版本信息，以确保后续SQL编译器对目标表的正确版本进行操作。进一步地，本申请通过重启未响应所述加写锁请求的所述子节点，或将所述子节点的服务迁移到其他物理机器上，而后更新所述子节点的加锁状态信息，从而进行有效的出错恢复并保证组内一致性。

公开(公告)号：CN106326305A

公开(公告)日：2017-01-11

申请号：CN201510386678.2

申请日：2015-06-30

Applicant: 星环信息科技(上海)有限公司

Inventor： 代克 ,  刘熙 ,  吕侣

IPC: G06F17/30

Abstract: 本申请的目的是提供一种数据文件的存储和查询方法及设备，存储时，创建数据文件的元信息，元信息包含数据文件在数据表中的存储位置；将数据文件与该数据文件对应的元信息分别写入数据表中第一列簇和第二列簇的同一行中；根据第二列簇中的元信息建立指向数据文件在数据表中的存储位置的索引；查询时，获取查询条件，并在第二列簇中查找符合查询条件的元信息；根据索引，确定符合查询条件的元信息所对应的数据文件在数据表的第一列簇中的存储位置；由第一列簇中的存储位置获取数据文件。与现有技术相比，存储时数据一致性好，数据库的复杂度和维护难度较低，查询时处理的数据量较小，查询速度快。