多源异构数据库的访问方法、装置、设备和存储介质

摘要

本发明实施例公开了一种多源异构数据库的访问方法、装置、设备及存储介质。该方法包括：通过统一接口层的访问接口获取用户输入的第一数据访问请求；通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。通过本发明实施例的技术方案，能够提高多源异构数据库的通用性，降低数据库访问软件的开发成本和运维成本。

权利要求

1.一种多源异构数据库的访问方法，其特征在于，包括：通过统一接口层的访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性信息，所述表属性信息包括：表名称和字段数组，所述字段数组中存储字段属性信息；

通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；

通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库；

其中，所述访问接口包括：创建接口、删除接口、插入接口、更新接口和查询接口；所述数据驱动层包括：创建驱动器、删除驱动器、插入驱动器、更新驱动器和查询驱动器，所述访问接口与所述数据驱动层中的驱动器一一对应；

通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求，包括：

根据所述根节点名称确定目标数据库；

根据所述访问接口和所述目标数据库，获取所述第一数据访问请求对应的访问接口协议；

基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求。

2.根据权利要求1所述的方法，其特征在于，通过统一接口层的访问接口获取用户输入的第一数据访问请求，包括：

在所述统一接口层中的各访问接口处提供软件开发工具包，所述软件开发工具包中封装所述访问接口对应的数据访问属性；

获取用户在各所述数据访问属性下输入的数据访问参数；

根据所述数据访问属性和所述输入的数据访问参数构建所述第一数据访问请求。

3.根据权利要求1所述的方法，其特征在于，所述访问接口包括：创建接口和删除接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

根据所述第一数据访问请求中的字段属性信息确定第一主键数组；

基于所述访问接口对应的访问接口协议，确定所述第一主键数组对应的第二数据访问请求。

4.根据权利要求1所述的方法，其特征在于，所述访问接口包括：插入接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

若目标数据库为关系型数据库，则基于插入接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据插入请求；

若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的字段属性信息确定第二主键数组和第一列数组，基于所述插入接口对应的第二访问接口协议，确定所述第二主键数组和所述第一列数组对应的第二数据插入请求；

其中，所述第一数据访问请求中的字段数组包括：插入数据字段数组和返回数据字段数组。

5.根据权利要求1所述的方法，其特征在于，所述访问接口包括：更新接口和插入接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

根据所述第一数据访问请求的字段属性信息确定第三主键数组和第二列数组；

若目标数据库为关系型数据库，则判断第一目标数据是否存在；若是，则基于所述更新接口对应的第一访问接口协议，确定所述第三主键数组和所述第二列数组对应的第一数据更新请求；若否，则基于所述插入接口对应的第一访问接口协议，确定所述第三主键数组和所述第二列数组对应的第三数据插入请求；

若目标数据库为非关系型数据库，则基于所述更新接口对应的第二访问接口协议，确定所述第三主键数组和所述第二列数组对应的第三数据更新请求。

6.根据权利要求1所述的方法，其特征在于，所述访问接口包括：查询接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

若目标数据库为关系型数据库，则基于查询接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据查询请求；

若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的表名称确定索引值，基于查询接口对应的第二访问接口协议，确定所述索引值对应的第二数据查询请求；

其中，所述第一数据访问请求中的字段数组包括：查询字段、查询过滤条件、聚合操作、排序操作和行数限制。

7.根据权利要求1所述的方法，其特征在于，通过数据存储层对目标数据库执行所述第二数据访问请求，包括：

通过所述数据存储层，查询目标数据库包含的第二目标数据；

基于所述第二数据访问请求对第二目标数据进行读取，并得到返回数据，或者，基于所述第二数据访问请求对第二目标数据进行写入。

8.一种多源异构数据库的访问装置，其特征在于，包括：统一接口层，用于通过访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性，所述表属性包括：表名称和字段数组，所述字段数组中存储字段属性；

数据驱动层，用于确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；

数据存储层，用于对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库；

其中，所述访问接口包括：创建接口、删除接口、插入接口、更新接口和查询接口；所述数据驱动层包括：创建驱动器、删除驱动器、插入驱动器、更新驱动器和查询驱动器，所述访问接口与所述数据驱动层中的驱动器一一对应；

所述数据驱动层，包括：

确定模块，用于根据所述根节点名称确定目标数据库；

获取模块，用于根据所述访问接口和所述目标数据库，获取所述第一数据访问请求对应的访问接口协议；

转换模块，用于基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求。

9.一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现如权利要求1‑7中任一所述的多源异构数据库的访问方法。

10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如权利要求1‑7中任一所述的多源异构数据库的访问方法。

说明书

多源异构数据库的访问方法、装置、设备和存储介质

技术领域

[0001] 本发明实施例涉及计算机数据处理技术，尤其涉及一种多源异构数据库的访问方法、装置、设备和存储介质。

背景技术

[0002] 在空间数字化的过程中，很多企业根据自身业务需求和技术特点，构建了许多相互隔离的异构存储方案。由于缺乏统一的数据模型抽象，没有自上而下的架构设计，开发平
台不尽相同，各业务系统相互独立。

[0003] 现有的关系型数据库（如PostgreSQL数据库）和非关系型数据库（如Aliyun Tablestore）如等存储方案的交互指令各不相同，生态碎片化严重，存储方案隔离，导致开
发人员无法快速利用已有知识和代码基础使用其他存储方案，学习、代码迁移成本巨大，运
维成本高昂。

发明内容

[0004] 本发明实施例提供一种多源异构数据库的访问方法、装置、设备和存储介质，能够提高多源异构数据库的通用性，降低数据库访问软件的开发成本和运维成本。

[0005] 第一方面，本发明实施例提供了一种多源异构数据库的访问方法，包括：

[0006] 通过统一接口层的访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性信息，所述表属性信息包括：表名称和字段数组，
所述字段数组中存储字段属性信息；

[0007] 通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；

[0008] 通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0009] 第二方面，本发明实施例还提供了一种多源异构数据库的访问装置，该装置包括：

[0010] 统一接口层，用于通过访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性，所述表属性包括：表名称和字段数组，所述
字段数组中存储字段属性；

[0011] 数据驱动层，用于确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；

[0012] 数据存储层，用于对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0013] 第三方面，本发明实施例还提供了一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述程序时实现如本发明实
施例中任一所述的多源异构数据库的访问方法。

[0014] 第四方面，本发明实施例还提供了一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行时实现如本发明实施例中任一所述的多源异构数据库的访问方
法。

[0015] 本发明实施例通过统一接口层的访问接口获取用户输入的第一数据访问请求；通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据
访问请求进行转换，以得到第二数据访问请求；通过数据存储层对目标数据库执行所述第
二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库，解决多源异构数据库
的交互指令各不相同，生态碎片化严重，存储方案隔离，导致开发人员无法快速利用已有知
识和代码基础使用其他存储方案，学习和维护成本高的问题，实现提高多源异构数据库的
通用性，降低数据库访问软件的开发成本和运维成本的效果。

附图说明

[0016] 为了更清楚地说明本发明实施例的技术方案，下面将对实施例中所需要使用的附图作简单地介绍，应当理解，以下附图仅示出了本发明的某些实施例，因此不应被看作是对
范围的限定，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这
些附图获得其他相关的附图。

[0017] 图1是本发明实施例一中的一种多源异构数据库的访问方法的流程图；

[0018] 图2是本发明实施例二中的一种多源异构数据库的访问方法的流程图；

[0019] 图3是本发明实施例二中的一种多源异构数据库的结构示意图；

[0020] 图4是本发明实施例三中的一种多源异构数据库的访问装置的结构示意图；

[0021] 图5是本发明实施例四中的一种计算机设备的结构示意图。

具体实施方式

[0022] 下面结合附图和实施例对本发明作进一步的详细说明。可以理解的是，此处所描述的具体实施例仅仅用于解释本发明，而非对本发明的限定。另外还需要说明的是，为了便
于描述，附图中仅示出了与本发明相关的部分而非全部结构。

[0023] 应注意到：相似的标号和字母在下面的附图中表示类似项，因此，一旦某一项在一个附图中被定义，则在随后的附图中不需要对其进行进一步定义和解释。同时，在本发明的
描述中，术语“第一”、“第二”等仅用于区分描述，而不能理解为指示或暗示相对重要性。

[0024] 实施例一

[0025] 图1为本发明实施例一提供的一种多源异构数据的访问方法的流程图，本实施例可适用于访问多源异构数据库，对多源异构数据库中的数据进行增删查改的情况，该方法
可以由本发明实施例中的多源异构数据的访问装置来执行，该装置可采用软件和/或硬件
的方式实现。如图1所示，该方法具体包括如下步骤：

[0026] S110，通过统一接口层的访问接口获取用户输入的第一数据访问请求。

[0027] 其中，所述统一接口层可以为用户界面层，通过可视化技术向用户提供访问异构数据库的接口服务，实现用户对多源异构数据库的访问操作，并将返回结果进行显示。

[0028] 所述统一接口层提供的访问接口可以包括：创建接口、删除接口、插入接口、更新接口和查询接口等各种功能的接口。所述创建接口用于根据用户的访问请求在多源异构数
据库中创建数据；所述删除接口用于根据用户的访问请求在多源异构数据库中删除数据；
所述插入除接口用于根据用户的访问请求在多源异构数据库中插入数据；所述更新接口用
于根据用户的访问请求更新多源异构数据库存储的数据，查询接口用于根据用户的访问请
求查询多源异构数据库存储的数据。

[0029] 本发明实施例中，将对异构数据库的访问抽象为对表数据的访问操作，即第一数据访问请求为对表结构存储数据对象的访问请求。其中，所述第一数据访问请求中至少包
括：根节点名称和表属性信息，所述表属性信息包括：表名称和字段数组，所述字段数组中
存储字段属性信息。

[0030] 根节点名称可以用于表征多源异构成数据库的存储方案，例如，根节点名称为“cloud”表示Aliyun Tablestore数据库，根节点名称为“edge”表示PostgreSQL数据库。

[0031] 表属性信息可以用于表征数据库中存储的各数据表的属性信息，包括表名称和字段数组，所述字段数组是数据表中各个字段的各属性信息构成的数组。每个字段都有多个
属性信息。

[0032] 所述字段数组中每个字段的属性信息可以包括：字段名称field.name、字段类型field.type、字段主键属性field.isPrimary、字段空值属性field.isNullabel、字段值
field.value中的至少一个，以及字段属性对应的参数值。其中，字段主键属性
field.isPrimary用于表示字段是否为主键，字段空值属性field.isNullabel用于表示是
否允许字段为空值。可以理解的是根据用户的访问请求不同，字段数组中包括的属性信息
也可以不同。所述字段数组中还可以包括：查询过滤条件字段、排序操作字段和聚合操作字
段等。所述字段数组也可以包括：返回数据字段。

[0033] 示例性的，通过统一接口层的访问接口获取用户输入的第一数据访问请求的方式可以为用户根据访问需求以及访问接口提供的访问属性，在统一访问层的访问接口输入需
要访问的根节点名称、表名称和字段数组等访问参数。或者可以为在访问接口处的软件开
发工具包（SDK）中提供的访问属性下输入数据访问参数，根据所述字段属性和所述数据访
问参数构建所述第一数据访问请求。例如通过SDK设置访问属性为某个字段的名称、字段类
型等，约束用户输入的数值，并根据用户输入的数值和访问属性生成字段数组中的该字段
属性信息。

[0034] 还可以为不同的用户设置访问权限，限制用户访问的数据内容和访问操作。获取用户在统一接口层的访问接口中输入的权限信息和第一数据访问请求，向服务端发送所述
权限信息，若用户具有访问权限，则响应用户的第一数据访问请求，若用户没有访问权限，
则向用户发送提示信息。

[0035] S120，通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求。

[0036] 其中，数据驱动层中包括分别与各访问接口对应的多个驱动器；驱动器中预设该访问接口对应不同数据库的访问接口协议，基于所述访问接口协议，可以将对访问接口获
取的第一数据访问请求转换为适用于访问各异构数据库的第二数据访问请求。

[0037] 所述第一数据访问请求可以是根据用户输入的访问参数所构建的访问请求。所述第二数据访问请求可以是根据驱动器转化得到的目标数据库的访问请求，所述第二数据访
问请求可以为基于目标数据库语言的结构化语句。

[0038] 示例性的，确定所述访问接口对应的目标驱动器的方式可以为建立各访问接口和对应驱动器的之间通信传输协议，将所述通信传输协议封装在软件开发工具包（SDK）中，所
述访问接口和对应驱动器的通信传输协议可以是HTTP或GPRC。GRPC是一个高性能、通用的
开源远程过程调用（Remote Procedure Call，RPC）框架，基于HTTP/2协议标准设计，基于
Protocol Buffers序列化协议开发，支持众多开发语言。超文本传输协议HTTP是用于从万
维网服务器传输超文本到本地浏览器的传送协议。

[0039] S130，通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0040] 其中，所述数据存储层用于存储多源异构数据库，各数据库之间相互独立，分别基于各自的存储方案存储数据。数据存储层中的数据库可以包括关系型数据库和非关系型数
据库，所述关系数据库（Relational Database Management System，RDBMS）利用预定义数
据结构存储数据的数据库，例如可以是PostgreSQL，使用SQL语言作为接口。所述非关系型
数据库（Not Only SQL，NoSQL），例如可以是阿里云的表格存储Aliyun Tablestore，提供
SDK和API供用户使用。

[0041] 示例性的，通过数据存储层，将第二数据访问请求输入目标数据库提供的接口，对目标数据库中的数据访问操作。所述数据访问操作包括创建数据操作、删除数据操作、插入
数据操作、更新数据操作和查询数据操作。

[0042] 本实施例的技术方案，通过统一接口层的访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性，所述表属性包括：表名称
和字段数组，所述字段数组中存储字段属性；通过数据驱动层确定所述访问接口对应的目
标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问
请求；通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型
数据库和非关系型数据库，能够访问关系型数据库和非关系型数据库，提高多源异构数据
库的通用性，降低数据库访问软件的开发成本和运维成本。

[0043] 实施例二

[0044] 图2为本发明实施例二中的一种多源异构数据库的访问方法的流程图，本实施例以上述实施例为基础进行优化，在本实施例中，通过所述目标驱动器对所述第一数据访问
请求进行转换，以得到第二数据访问请求，包括：根据所述根节点名称查询所述目标驱动器
中预先存储的各数据库名称，确定目标数据库；根据所述访问接口和所述目标数据库，确定
所述第一数据访问请求对应的访问接口协议；基于所述访问接口协议，对所述第一数据访
问请求中的数据访问参数进行转换，以得到第二数据访问请求。

[0045] 如图2所示，本实施例的方法具体包括如下步骤：

[0046] S210，通过统一接口层的访问接口获取用户输入的第一数据访问请求。

[0047] 可选的，通过统一接口层的访问接口获取用户输入的第一数据访问请求，包括：

[0048] 在所述统一接口层中的各访问接口处提供软件开发工具包，所述软件开发工具包中封装所述访问接口对应的数据访问属性；

[0049] 获取用户在各所述数据访问属性下输入的数据访问参数；

[0050] 根据所述数据访问属性和所述输入的数据访问参数构建所述第一数据访问请求。

[0051] 其中，所述数据访问属性可以包括：根节点名称、表名称、字段名称、字段类型、字段主键属性、字段值以及字段空值属性中的至少一个。可以理解的是根据用户的数据访问
请求不同，数据访问属性也可以不同。

[0052] 具体的，用户可以根据访问需求，在对应的访问接口的工具开发包中封装的数据访问属性下输入相应的数据访问参数，根据所述数据访问属性和所述数据访问参数构建所
述第一数据访问请求。其中，用户输入相应数据访问参数的方式可以为直接输入数据访问
参数，也可以为从数据访问属性配置的下拉菜单中选择相应的数据访问参数。

[0053] 示例性的，用户根据创建表需求选择创建接口，创建接口中封装的访问数据属性包括：根节点名称root、表名称tableName和字段数组fieldArray。其中，FieldArray=
[field.name，field.value，field.type，field.isPrimary，field.isNullabel]。若用户在
根节点名称属性下选择“cloud”，在表名称属性下输入“table1”，在字段名称属性
field.name下输入“id”，字段值属性field.value下输入“20200001”，在字段主键属性
field.isPrimary下选择“true”，则根据访问数据属性和用户输入的访问参数构建第一数
据访问请求，所述第一数据访问请求的访问内容可以是root=cloud，tableName=table1，
fieldArray=[id，20020001，true]，请求在table1中创建ID号码为2002001的数据。

[0054] S220，通过数据驱动层确定所述访问接口对应的目标驱动器。

[0055] 具体的，在数据驱动层中，各访问接口与驱动器一一对应，例如创建口对应创建驱动器，查询接口对应查询驱动器，删除接口对应删除驱动器。

[0056] 示例性的，基于访问接口和对应驱动器的之间通信传输协议，确定用户输入第一数据访问请求的访问接口对应的目标驱动器，将所述数据访问请求发送至所述目标驱动器
中。

[0057] S230，根据所述根节点名称确定目标数据库。

[0058] 其中，目标数据库可以为第一数据访问请求中请求访问的数据所存储的数据库。

[0059] 具体的，可以根据用户输入的根节点名称，查询目标数据库中预先存储的根节点名称与数据库之间的映射关系表，确定所述根节点名称对应的目标数据库，本发明实施例
对此不设限制。

[0060] 示例性的，用户输入的第一数据创建请求中根节点名称为root=cloud，则根据预先存储的根节点名称cloud对应Aliyun  Tablestore，确定目标数据库为Aliyun 
Tablestore。

[0061] S240，根据所述访问接口和所述目标数据库，获取所述第一数据访问请求对应的访问接口协议。

[0062] 其中，在各驱动器中预先配置各访问接口对应的访问接口协议，所述访问接口协议可以为各访问接口与目标数据库之间的转化协议，用于将各访问接口接收到的第一数据
访问请求转化为各目标数据库语言对应的第二数据访问请求。

[0063] 示例性的，根据用户输入第一数据访问请求所对应的访问接口，以及所述第一数据访问请求中根节点名称的目标数据库，确定目标驱动器中第一数据访问请求对应的访问
接口协议。例如可以是，用户在创建接口输入第一创建数据请求，所述第一数据创建请求中
根节点名称root=cloud，则在创建驱动器中确定Aliyun Tablestore对应的访问接口协议。

[0064] S250，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求。

[0065] 具体的，对于多源异构数据库，各数据库的交互指令和用户接口各不相同，通过所述访问接口协议将用户输入的数据转化为第二数据访问请求，所述第二数据访问请求能够
符合各目标数据库的交互语言或用户接口对应的预设规则，进而实现访问目标数据库。

[0066] S260，通过数据存储层对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0067] 本实施例的技术方案，通过统一接口层的访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性信息，所述表属性信息包
括：表名称和字段数组，所述字段数组中存储字段属性信息；根据所述根节点名称确定目标
数据库；根据所述访问接口和所述目标数据库，获取所述第一数据访问请求对应的访问接
口协议；基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以
得到第二数据访问请求，通过数据存储层对目标数据库执行所述第二数据访问请求，所述
数据库包括：关系型数据库和非关系型数据库，能访问多源异构数据库，提高数据库的通用
性，降低数据库访问软件的开发成本和运维成本。

[0068] 可选的，通过数据存储层对目标数据库执行所述第二数据访问请求，包括：

[0069] 通过所述数据存储层，查询目标数据库包含的第二目标数据；

[0070] 基于所述第二数据访问请求对第二目标数据进行读取，并得到返回数据，或者，基于所述第二数据访问请求对第二目标数据进行写入。

[0071] 其中，第二目标数据为目标数据库中存储的可查询数据。

[0072] 具体的，在数据存储层中基于所述第二数据访问请求对目标数据库中包含的第二目标数据进行创建、删除、更新、查询等访问请求。

[0073] 在目标数据库发生变更时，只需修改数据驱动方式和数据访问参数，而无需要重新修改访问目标数据库的访问请求指令，因而，提高数据库的通用性，降低数据库访问软件
的开发成本和运维成本。

[0074] 可选的，所述访问接口包括：创建接口和删除接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

[0075] 根据所述第一数据访问请求中的字段属性信息确定第一主键数组；

[0076] 基于所述访问接口对应的访问接口协议，确定所述第一主键数组对应的第二数据访问请求。

[0077] 具体的，若在创建接口或删除接口获取到用户输入的第一数据访问请求，则根据所述第一数据访问请求的字段数组中各字段对应的第一主键属性确定第一主键数组。将所
述第一主键数组输入所述访问接口对应的访问接口协议中，根据所述接口协议，确定第一
主键数组对应的第二数据访问请求。

[0078] 在一个具体的例子中，在创建接口获取到用户输入的第一数据访问请求中字段pk是主键，则确定第一主键数组{pk}={pk1.name,pk.2.name,……}，根节点名称edge对应目
标数据库为PostgreSQL，则第二访问请求可以为：

[0079]

[0080] 在另一个具体的例子中，在创建接口获取到用户输入的第一数据访问请求中某字段pk的主键属性为是主键，则确定第一主键数组{pk}={pk1.name, pk2.name,……}，根节
点名称cloud对应目标数据库为Aliyun Tablestore，则第二访问请求可以为：

[0081]

[0082]

[0083] 可选的，所述访问接口包括：插入接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

[0084] 若目标数据库为关系型数据库，则基于插入接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据插入请求；

[0085] 若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的字段属性信息确定第二主键数组和第一列数组，基于所述插入接口对应的第二访问接口协议，确定所
述第二主键数组和所述第一列数组对应的第二数据插入请求。

[0086] 其中，所述第一数据访问请求中的字段数组包括：插入数据字段数组和返回数据字段数组，所述插入数据字段数组用于存储用户需要插入的数据字段，所述返回数据字段
数组用于存储访问请求后得到的数据字段。

[0087] 具体的，若在插入接口获取到用户输入的第一数据访问请求，则确定所述第一数据访问请求的根节点名称对应的目标数据库所述的类型，根据字段主键属性
field.isPrimary确定主键数组和列数组，isPrimary为true表示为主键列；isPrimary为
false表示为一般列。

[0088] 在一个具体例子中，在插入接口获取到用户输入的第一数据访问请求，根节点名称cloud对应的目标数据库为PostgreSQL，属于关系性数据库，则基于插入接口对应的第一
访问接口协议，确定所述数据访问参数对应的数据插入请求可以为：

[0089]

[0090] 在另一个具体例子中，在插入接口获取到用户输入的第一数据访问请求，根节点名称cloud对应的目标数据库为Aliyun Tablestore，属于非关系性数据库，则根据所述字
段数组存储的第二主键属性确定第二主键数组{pk}，并根据字段数组存储的字段值属性确
定第一列数组{column}，并确定所述第二主键数组和第一列数组对应的数据插入请求可以
为：

[0091]

[0092]

[0093] 可选的，所述访问接口包括：更新接口和插入接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

[0094] 根据所述第一数据访问请求的字段属性信息确定第三主键数组和第二列数组；

[0095] 若目标数据库为关系型数据库，则判断第一目标数据是否存在；若是，则基于所述更新接口对应的第一访问接口协议，确定所述第三主键数组和所述第二列数组对应的第一
数据更新请求；若否，则基于所述插入接口对应的第一访问接口协议，确定所述第三主键数
组和所述第二列数组对应的第三数据插入请求；

[0096] 若目标数据库为非关系型数据库，则基于所述更新接口对应的第二访问接口协议，确定所述第三主键数组和所述第二列数组对应的第三数据更新请求。

[0097] 其中，第一目标数据可以是第一数据访问请求对应的操作数据，若第一目标数据存在，则执行数据更新请求；若第一目标数据不存在，则执行数据插入请求。所述第一目标
数据可以通过字段主键属性field.isPrimary为true的主键数组进行约束。

[0098] 具体的，根据所述第一数据访问请求中字段数组存储的第三主键属性确定第三主键数组和列数组；将所述第三主键数组和第二列数组输入所述访问接口对应的访问接口协
议中，确定第三主键数组和列数组对应的数据更新请求。

[0099] 在一个具体例子中，在更新接口获取到用户输入的第一数据访问请求，根据所述第一数据访问请求的字段属性信息确定第三主键数组和第二列数组；所述第一数据访问请
求中根节点名称cloud对应的目标数据库为PostgreSQL，属于关系性数据库，则根据预先设
定的expectExist函数判断第一目标数据是否存在，若expectExist函数的执行结果为
true，表示第一目标数据存在，则所述第三主键数组和所述第二列数组对应的第一数据更
新请求可以为：

[0100]

[0101] 若expectExist函数的执行结果为false，表示第一目标数据不存在，则所述第三主键数组和所述第二列数组对应的第三数据插入请求可以为：

[0102]

[0103]

[0104] 这样设置的好处在于可以判断更新请求对应的操作数据是都存在，若不存在，则基于更新接口对第一数据访问请求中的数据访问参数进行转换的操作失败后，自动基于插
入接口对第一数据访问请求中的数据访问参数进行转换，得到第二数据访问请求。

[0105] 在另一个具体的例子中，在更新接口获取到用户输入的第一数据访问请求，根节点名称cloud对应的目标数据库为Aliyun Tablestore，属于非关系性数据库，则根据所述
第一数据访问请求中字段数组存储的第三主键属性确定第三主键数组{pk}和第二列数组
{column}，并确定所述第二主键数组和第二列数组对应的第三数据更新请求可以为：

[0106]

[0107] 可选的，所述访问接口包括：查询接口，相应的，基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

[0108] 若目标数据库为关系型数据库，则基于查询接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据查询请求；

[0109] 若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的表名称确定索引值，基于查询接口对应的第二访问接口协议，确定所述索引值对应的第二数据查询请
求。

[0110] 其中，所述第一数据访问请求中的字段数组包括：查询字段、查询过滤条件、聚合操作、排序操作和行数限制。

[0111] 所述查询过滤条件filter可以主语subject、谓语predicate和宾语object三个部分构成。主语subject可以是字段名称，或者一个由主语谓语和宾语组合的过滤条件，宾语
object可以是字段值或一个由主语谓语和宾语组合的过滤条件，谓语predicate提供数学
操作和逻辑操作，数学操作例如可以是“=、!=、>、>=、<、<=”逻辑操作例如可以是and和or。

[0112] 示例性的，查询过滤条件可以用逻辑表达式表示，例如((((enclosure_id=encl_v)AND(start_time>=1619269622))AND(start_time<1619273222))AND((entity_id =eid_
v_1)OR(entity_id=eid_v_2)))。查询过滤条件还可以为接口表示，例如：

[0113]

[0114] 在一个具体的例子中，在查询接口获取到用户输入的第一数据访问请求，所述第一数据访问请求中根节点名称cloud对应的目标数据库为PostgreSQL，属于关系性数据库，
则根据查询字段selection、查询过滤条件filter、聚合操作aggregation、排序操作sorter
和行数限制limit等数据访问参数确定的第一数据查询请求可以为：

[0115]

[0116]

[0117] 在另一个具体的例子中，在查询接口获取到用户输入的第一数据访问请求，所述第一数据访问请求中根节点名称cloud对应的目标数据库为Aliyun Tablestore，属于非关
系性数据库，则根据第一数据访问请求中的表名称确定索引值searchIndex。所述索引值
searchIndex对应的第二数据查询请求可以为：

[0118]

[0119]

[0120] 如图3所示，本发明实施例中，通过多源异构数据库访问系统实现对多源异构数据库的访问，所述多源异构数据库访问系统包括统一接口层、数据驱动层和数据存储层，在统
一接口层包括：创建接口、删除接口、插入接口、更新接口和查询接口，在数据驱动层包括：
创建驱动器、删除驱动器、插入驱动器、更新驱动器和驱动器接口，各驱动器与所述统一接
口层中各访问接口一一对应，在数据存储层中包括各数据库，所属数据库包括：关系型数据
库和非关系型数据库，通过所述数据驱动层中的各目标驱动器对所述第一数据访问请求进
行转换，以得到第二数据访问请求，进而实现访问访问关系型数据库和非关系型数据库，提
高了多源异构数据库的通用性，降低了数据库访问软件的开发成本和运维成本。

[0121] 实施例三

[0122] 图4为本发明实施例三提供的一种多源异构数据库的访问装置的结构示意图。本实施例可适用于访问多源异构数据库，对多源异构数据库中的数据进行增删查改的情况，
该装置可采用软件和/或硬件的方式实现，该装置可集成在任何提供多源异构数据库的访
问功能的设备中，如图4所示，所述多源异构数据库的访问的装置具体包括：统一接口层
310、数据驱动层320和数据存储层330。

[0123] 其中，统一接口层310，用于通过访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点名称和表属性，所述表属性包括：表名称和字段数
组，所述字段数组中存储字段属性；

[0124] 数据驱动层320，用于确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；

[0125] 数据存储层330，用于对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0126] 可选的，所述统一接口层310，具体用于：

[0127] 在所述统一接口层中的各访问接口处提供软件开发工具包，所述软件开发工具包中封装所述访问接口对应的数据访问属性；

[0128] 获取用户在各所述数据访问属性下输入的数据访问参数；

[0129] 根据所述数据访问属性和所述输入的数据访问参数构建所述第一数据访问请求。

[0130] 可选的，所述数据驱动层320，包括：

[0131] 确定模块，用于根据所述根节点名称确定目标数据库；

[0132] 获取模块，用于根据所述访问接口和所述目标数据库，获取所述第一数据访问请求对应的访问接口协议；

[0133] 转换模块，用于基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求。

[0134] 可选的，所述访问接口包括：创建接口和删除接口，相应的，所述转换模块具体用于：

[0135] 基于所述访问接口协议，对所述第一数据访问请求中的数据访问参数进行转换，以得到第二数据访问请求包括：

[0136] 根据所述第一数据访问请求中的字段属性信息确定第一主键数组；

[0137] 基于所述访问接口对应的访问接口协议，确定所述第一主键数组对应的第二数据访问请求。

[0138] 可选的，所述访问接口包括：插入接口，相应的，所述转换模块具体用于：

[0139] 若目标数据库为关系型数据库，则基于插入接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据插入请求；

[0140] 若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的字段属性信息确定第二主键数组和第一列数组，基于所述插入接口对应的第二访问接口协议，确定所
述第二主键数组和所述第一列数组对应的第二数据插入请求；

[0141] 其中，所述第一数据访问请求中的字段数组包括：插入数据字段数组和返回数据字段数组。

[0142] 可选的，所述访问接口包括：更新接口和插入接口，相应的，所述转换模块具体用于：

[0143] 根据所述第一数据访问请求的字段属性信息确定第三主键数组和第二列数组；

[0144] 若目标数据库为关系型数据库，则判断第一目标数据是否存在，若是，则基于所述更新接口对应的第一访问接口协议，确定所述第三主键数组和所述第二列数组对应的第一
数据更新请求；若否，则基于所述插入接口对应的第一访问接口协议，确定所述第三主键数
组和所述第二列数组对应的第三数据插入请求；

[0145] 若目标数据库为非关系型数据库，则基于所述更新接口对应的第二访问接口协议，确定所述第三主键数组和所述第二列数组对应的第三数据更新请求。

[0146] 可选的，所述访问接口包括：查询接口，相应的，所述转换模块具体用于：

[0147] 若目标数据库为关系型数据库，则基于查询接口对应的第一访问接口协议，确定所述数据访问参数对应的第一数据查询请求；

[0148] 若目标数据库为非关系型数据库，则根据所述第一数据访问请求中的表名称确定索引值，基于查询接口对应的第二访问接口协议，确定所述索引值对应的第二数据查询请
求；

[0149] 其中，所述第一数据访问请求中的字段数组包括：查询字段、查询过滤条件、聚合操作、排序操作和行数限制。

[0150] 可选的，所述数据存储层330，具体用于：

[0151] 通过所述数据存储层，查询目标数据库包含的第二目标数据；

[0152] 基于所述第二数据访问请求对第二目标数据进行读取，并得到返回数据，或者，基于所述第二数据访问请求对第二目标数据进行写入。

[0153] 上述产品可执行本发明任意实施例所提供的多源异构数据库的访问方法，具备执行方法相应的功能模块和有益效果。

[0154] 实施例四

[0155] 图5为本发明实施例四中的一种计算机设备的结构示意图。图5示出了适于用来实现本发明实施方式的示例性计算机设备12的框图。图5显示的计算机设备12仅仅是一个示
例，不应对本发明实施例的功能和使用范围带来任何限制。

[0156] 如图5所示，计算机设备12以通用计算设备的形式表现。计算机设备12的组件可以包括但不限于：一个或者多个处理器或者处理器16，系统存储器28，连接不同系统组件（包
括系统存储器28和处理器16）的总线18。

[0157] 总线18表示几类总线结构中的一种或多种，包括存储器总线或者存储器控制器，外围总线，图形加速端口，处理器或者使用多种总线结构中的任意总线结构的局域总线。举
例来说，这些体系结构包括但不限于工业标准体系结构（ISA）总线，微通道体系结构（MAC）
总线，增强型ISA总线、视频电子标准协会（VESA）局域总线以及外围组件互连（PCI）总线。

[0158] 计算机设备12典型地包括多种计算机系统可读介质。这些介质可以是任何能够被计算机设备12访问的可用介质，包括易失性和非易失性介质，可移动的和不可移动的介质。

[0159] 系统存储器28可以包括易失性存储器形式的计算机系统可读介质，例如随机存取存储器（RAM）30和/或高速缓存存储器32。计算机设备12可以进一步包括其它可移动/不可
移动的、易失性/非易失性计算机系统存储介质。仅作为举例，存储系统34可以用于读写不
可移动的、非易失性磁介质（图5未显示，通常称为“硬盘驱动器”）。尽管图5中未示出，可以
提供用于对可移动非易失性磁盘（例如“软盘”）读写的磁盘驱动器，以及对可移动非易失性
光盘（例如CD‑ROM, DVD‑ROM或者其它光介质）读写的光盘驱动器。在这些情况下，每个驱动
器可以通过一个或者多个数据介质接口与总线18相连。存储器28可以包括至少一个程序产
品，该程序产品具有一组（例如至少一个）程序模块，这些程序模块被配置以执行本发明各
实施例的功能。

[0160] 具有一组（至少一个）程序模块42的程序/实用工具40，可以存储在例如存储器28中，这样的程序模块42包括但不限于操作系统、一个或者多个应用程序、其它程序模块以及
程序数据，这些示例中的每一个或某种组合中可能包括网络环境的实现。程序模块42通常
执行本发明所描述的实施例中的功能和/或方法。

[0161] 计算机设备12也可以与一个或多个外部设备14（例如键盘、指向设备、显示器24等）通信，还可与一个或者多个使得用户能与该计算机设备12交互的设备通信，和/或与使
得该计算机设备12能与一个或多个其它计算设备进行通信的任何设备（例如网卡，调制解
调器等等）通信。这种通信可以通过输入/输出（I/O）接口22进行。另外，本实施例中的计算
机设备12，显示器24不是作为独立个体存在，而是嵌入镜面中，在显示器24的显示面不予显
示时，显示器24的显示面与镜面从视觉上融为一体。并且，计算机设备12还可以通过网络适
配器20与一个或者多个网络（例如局域网（LAN），广域网（WAN）和/或公共网络，例如因特网）
通信。如图所示，网络适配器20通过总线18与计算机设备12的其它模块通信。应当明白，尽
管图中未示出，可以结合计算机设备12使用其它硬件和/或软件模块，包括但不限于：微代
码、设备驱动器、冗余处理单元、外部磁盘驱动阵列、RAID系统、磁带驱动器以及数据备份存
储系统等。

[0162] 处理器16通过运行存储在系统存储器28中的程序，从而执行各种功能应用以及数据处理，例如实现本发明实施例所提供的多源异构数据库的访问方法：通过统一接口层的
访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少包括：根节点
名称和表属性信息，所述表属性信息包括：表名称和字段数组，所述字段数组中存储字段属
性信息；通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目标驱动器对所
述第一数据访问请求进行转换，以得到第二数据访问请求；通过数据存储层对目标数据库
执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数据库。

[0163] 实施例五

[0164] 本发明实施例五提供了一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行时实现如本申请所有发明实施例提供的多源异构数据库的访问方法：通过
统一接口层的访问接口获取用户输入的第一数据访问请求，所述第一数据访问请求中至少
包括：根节点名称和表属性信息，所述表属性信息包括：表名称和字段数组，所述字段数组
中存储字段属性信息；通过数据驱动层确定所述访问接口对应的目标驱动器，通过所述目
标驱动器对所述第一数据访问请求进行转换，以得到第二数据访问请求；通过数据存储层
对目标数据库执行所述第二数据访问请求，所述数据库包括：关系型数据库和非关系型数
据库。

[0165] 可以采用一个或多个计算机可读的介质的任意组合。计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质。计算机可读存储介质例如可以是但不限于电、
磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储
介质的更具体的例子（非穷举的列表）包括：具有一个或多个导线的电连接、便携式计算机
磁盘、硬盘、随机存取存储器（RAM）、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或
闪存)、光纤、便携式紧凑磁盘只读存储器(CD‑ROM)、光存储器件、磁存储器件、或者上述的
任意合适的组合。在本文件中，计算机可读存储介质可以是任何包含或存储程序的有形介
质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。

[0166] 计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括但不限
于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可
读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于
由指令执行系统、装置或者器件使用或者与其结合使用的程序。

[0167] 计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括但不限于无线、电线、光缆、RF等等，或者上述的任意合适的组合。

[0168] 可以以一种或多种程序设计语言或其组合来编写用于执行本发明操作的计算机程序代码，所述程序设计语言包括面向对象的程序设计语言，诸如Java、Smalltalk、C++，还
包括常规的过程式程序设计语言，诸如“C”语言或类似的程序设计语言。程序代码可以完全
地在用户计算机上执行、部分地在用户计算机上执行、作为一个独立的软件包执行、部分在
用户计算机上部分在远程计算机上执行、或者完全在远程计算机或服务器上执行。在涉及
远程计算机的情形中，远程计算机可以通过任意种类的网络包括局域网(LAN)或广域网
(WAN)连接到用户计算机，或者，可以连接到外部计算机（例如利用因特网服务提供商来通
过因特网连接）。

[0169] 注意，上述仅为本发明的较佳实施例及所运用技术原理。本领域技术人员会理解，本发明不限于这里所述的特定实施例，对本领域技术人员来说能够进行各种明显的变化、
重新调整和替代而不会脱离本发明的保护范围。因此，虽然通过以上实施例对本发明进行
了较为详细的说明，但是本发明不仅仅限于以上实施例，在不脱离本发明构思的情况下，还
可以包括更多其他等效实施例，而本发明的范围由所附的权利要求范围决定。