公开(公告)号：CN105760279B

公开(公告)日：2018-09-07

申请号：CN201610133483.1

申请日：2016-03-09

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网浙江省电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司

发明人： 孙乔 ,  张春光 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  刘炜 ,  崔伟

IPC分类号： G06F11/30 ,  G06F17/30

摘要： 本发明公开了一种分布式数据库集群故障预警关联树生成方法及系统，包括：构建M个本地频繁一项集表；构建初始的M个本地关联分支树；将初始的M个本地关联分支树发送至主服务器，并在主服务器中建立初始的主关联树，合并所有重复项；将所有频繁项形成为候选二项集表；将候选二项集表发送到全部M个本地节点，通过剪枝步骤生成频繁二项集表；重复上述步骤，直至不能生成更高维的频繁项集为止，得到最终的预警事件关联树。本发明提出的分布式数据库集群故障预警关联树生成方法及系统，解决了预警关联树建立效率低下的问题。

公开(公告)号：CN106569896B

公开(公告)日：2019-02-05

申请号：CN201610956986.9

申请日：2016-10-25

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网浙江省电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司 ,  国网冀北电力有限公司 ,  国网内蒙古东部电力有限公司 ,  北京万里开源软件有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  陆旭 ,  刘炜 ,  崔伟 ,  高阿朋 ,  裴旭斌 ,  吴舜 ,  聂晓波 ,  吴芃

IPC分类号： G06F9/50

摘要： 本发明公开了一种数据分发及并行处理方法和系统，所述方法包括：对初始查询指令进行解析，得到真实查询指令；将真实查询指令通过工作分配节点分发到不同的数据节点中；在每个数据节点上分别执行接收到的真实查询指令，并将查询结果返回给工作分配节点，同时在每个服务器节点上保持数据信息表的更新；在每个服务器节点上，对所述真实查询指令对应的查询表进行备份，使得每个服务器节点上保存有查询表副本；在每个服务器节点上，当检测到存在并发冲突时，通过调用当前服务器节点上的查询表副本对真实查询指令并发执行。所述数据分发及并行处理方法及系统不仅能够保证数据的一致性而且能够提高数据查询的速度和效率。

公开(公告)号：CN106569896A

公开(公告)日：2017-04-19

申请号：CN201610956986.9

申请日：2016-10-25

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网浙江省电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司 ,  国网冀北电力有限公司 ,  国网内蒙古东部电力有限公司 ,  北京万里开源软件有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  陆旭 ,  刘炜 ,  崔伟 ,  高阿朋 ,  裴旭斌 ,  吴舜 ,  聂晓波 ,  吴芃

IPC分类号： G06F9/50

CPC分类号： G06F9/5027 ,  G06F9/5083 ,  G06F2209/5017

摘要： 本发明公开了一种数据分发及并行处理方法和系统，所述方法包括：对初始查询指令进行解析，得到真实查询指令；将真实查询指令通过工作分配节点分发到不同的数据节点中；在每个数据节点上分别执行接收到的真实查询指令，并将查询结果返回给工作分配节点，同时在每个服务器节点上保持数据信息表的更新；在每个服务器节点上，对所述真实查询指令对应的查询表进行备份，使得每个服务器节点上保存有查询表副本；在每个服务器节点上，当检测到存在并发冲突时，通过调用当前服务器节点上的查询表副本对真实查询指令并发执行。所述数据分发及并行处理方法及系统不仅能够保证数据的一致性而且能够提高数据查询的速度和效率。

公开(公告)号：CN107515899A

公开(公告)日：2017-12-26

申请号：CN201710604810.1

申请日：2017-07-24

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司

发明人： 孙乔 ,  张春光 ,  邓卜侨 ,  孙雷 ,  刘炜 ,  崔伟 ,  裴旭斌 ,  马慧远

IPC分类号： G06F17/30

摘要： 本发明公开了一种数据库联合分片方法、装置以及存储介质，涉及数据仓库技术领域，其中的方法包括：计算连接条件包含的维表的选择谓词字段参与连接查询操作的维表字段查询频率；计算在维表与事实表进行连接查询操作时，事实表符合包含有选择谓词字段的连接条件的平均记录数；根据维表字段查询频率和平均记录数确定需要分片的维表，将需要分片的维表以及事实表进行联合分片。本发明的方法、装置以及存储介质，实现了根据工作负载特点、以及分片数量限制，自动选择部分维表，进行维表和事实表的联合分片；并且采用排序的方法，减少了算法的计算量，同时保证连接操作的代价最小化。

公开(公告)号：CN107451229A

公开(公告)日：2017-12-08

申请号：CN201710605395.1

申请日：2017-07-24

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  王志强 ,  马慧远 ,  刘炜 ,  崔伟

IPC分类号： G06F17/30

摘要： 本发明公开了一种数据库查询方法和装置，包括步骤：根据数据中的实体信息构建实体簇，并将实体簇与存储节点建立映射关系，根据所述映射关系将数据存储至存储节点；根据查询指令，将属于同一实体簇但位于不同存储节点上数据读取到一个存储节点的内存中；根据实体簇中的实体信息将维度数据在存储节点之间进行迁移；执行查询指令。实现了优化的数据库构建和数据库查询方法，提高数据库查询性能。

公开(公告)号：CN106777027A

公开(公告)日：2017-05-31

申请号：CN201611123673.1

申请日：2016-12-08

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司

发明人： 孙乔 ,  邓卜侨 ,  付兰梅 ,  孙雷 ,  马慧远 ,  刘炜 ,  崔伟 ,  聂晓波 ,  吴芃

IPC分类号： G06F17/30 ,  G06F9/46

摘要： 本发明公开了一种大规模并行处理行列混合数据存储装置及存储、查询方法，属于数据库技术领域。本发明装置包含联机事务处理模块、联机分析处理模块、存储模块、跨层查询模块以及跨层交互模块。本发明在一个数据库中同时实现了OLTP和OLAP两种功能，可以根据数据的访问频率将数据以适当的形式存储，既能为用户提供方便的查询服务，又可以为用户提供高效地数据分析服务，相对于现有技术中OLTP和OLAP分别部署的方式来说是一种重要的技术进步。

公开(公告)号：CN105760279A

公开(公告)日：2016-07-13

申请号：CN201610133483.1

申请日：2016-03-09

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网浙江省电力公司 ,  北京中电飞华通信股份有限公司

发明人： 孙乔 ,  张春光 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  刘炜 ,  崔伟

IPC分类号： G06F11/30 ,  G06F17/30

CPC分类号： G06F11/3006 ,  G06F11/3072 ,  G06F16/2246 ,  G06F16/27

摘要： 本发明公开了一种分布式数据库集群故障预警关联树生成方法及系统，包括：构建M个本地频繁一项集表；构建初始的M个本地关联分支树；将初始的M个本地关联分支树发送至主服务器，并在主服务器中建立初始的主关联树，合并所有重复项；将所有频繁项形成为候选二项集表；将候选二项集表发送到全部M个本地节点，通过剪枝步骤生成频繁二项集表；重复上述步骤，直至不能生成更高维的频繁项集为止，得到最终的预警事件关联树。本发明提出的分布式数据库集群故障预警关联树生成方法及系统，解决了预警关联树建立效率低下的问题。

公开(公告)号：CN106250523A

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

申请号：CN201610634581.3

申请日：2016-08-04

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  马慧远 ,  刘炜 ,  崔伟

IPC分类号： G06F17/30

CPC分类号： G06F16/2237 ,  G06F16/221

摘要： 本发明公开了一种分布式列存储系统索引的方法，包括：获取每列数据的分布特征，设定每列数据的域值及划分规则；根据域值及划分规则，得到划分后的连续数据区域；分别对应每个数据区域建立一个区域编码向量；进行统计计算，得到每列数据的统计信息，将统计信息与对应的区域编码向量合并，得到带有统计信息的区域编码向量；将带有统计信息的区域编码向量作为位图索引的位向量进行数据的索引。所述分布式列存储系统索引的方法通过设定每列数据的域值和划分规则，使得分组位图索引的划分方式与查询的过滤条件相符合，通过计算列数据的统计信息，不仅提高了分组位图查询的准确性，而且能够保留列存储系统中数据的统计信息，保证数据信息的完整性。

公开(公告)号：CN106250523B

公开(公告)日：2019-04-16

申请号：CN201610634581.3

申请日：2016-08-04

申请人： 北京国电通网络技术有限公司 ,  国家电网公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  马慧远 ,  刘炜 ,  崔伟

IPC分类号： G06F16/31

摘要： 本发明公开了一种分布式列存储系统索引的方法，包括：获取每列数据的分布特征，设定每列数据的域值及划分规则；根据域值及划分规则，得到划分后的连续数据区域；分别对应每个数据区域建立一个区域编码向量；进行统计计算，得到每列数据的统计信息，将统计信息与对应的区域编码向量合并，得到带有统计信息的区域编码向量；将带有统计信息的区域编码向量作为位图索引的位向量进行数据的索引。所述分布式列存储系统索引的方法通过设定每列数据的域值和划分规则，使得分组位图索引的划分方式与查询的过滤条件相符合，通过计算列数据的统计信息，不仅提高了分组位图查询的准确性，而且能够保留列存储系统中数据的统计信息，保证数据信息的完整性。

公开(公告)号：CN107451229B

公开(公告)日：2020-04-14

申请号：CN201710605395.1

申请日：2017-07-24

申请人： 北京中电普华信息技术有限公司 ,  国家电网有限公司 ,  国网北京市电力公司 ,  北京中电飞华通信股份有限公司 ,  国网信息通信产业集团有限公司

发明人： 孙乔 ,  付兰梅 ,  邓卜侨 ,  孙雷 ,  王志强 ,  马慧远 ,  刘炜 ,  崔伟

IPC分类号： G06F16/36

摘要： 本发明公开了一种数据库查询方法和装置，包括步骤：根据数据中的实体信息构建实体簇，并将实体簇与存储节点建立映射关系，根据所述映射关系将数据存储至存储节点；根据查询指令，将属于同一实体簇但位于不同存储节点上数据读取到一个存储节点的内存中；根据实体簇中的实体信息将维度数据在存储节点之间进行迁移；执行查询指令。实现了优化的数据库构建和数据库查询方法，提高数据库查询性能。