本申请实施例涉及数据库领域,尤其涉及一种数据库的在线数据的处理方法、装置及其程序产品。
背景技术:
1、数据库管理系统(database management system,dms)是一种操纵和管理数据库的大型软件,用于对数据库进行统一的管理和控制,以保证数据库的安全性和完整性。
2、现有技术中,可以使用apache calcite进行数据库管理,apache calcite是一个开源数据管理框架,被广泛应用于各种数据处理项目和工具中,apache calcite提供了标准的结构化查询语言(structured query language,sql)、多种查询优化和连接各种数据源基础框架,可以让用户轻松的接入各种数据,并实现使用sql查询数据。
3、但是,现有的数据管理方法,通常只能对数据库的离线数据进行管理,无法对数据库的在线数据进行高效管理。
技术实现思路
1、本申请实施例提供一种数据库的在线数据的处理方法、装置及其程序产品,能够通过统一方式对数据库的在线数据进行动态处理。
2、第一方面,本申请实施例提供一种数据库的在线数据的处理方法,应用于管理服务器,所述管理服务器用于管理至少一个数据库,每个数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述方法包括:
3、根据客户端发送的数据处理请求,确定所述数据处理请求对应的待处理任务以及所述待处理任务关联的调度节点,所述数据处理请求用于请求对数据库的在线数据进行处理;
4、将所述待处理任务下发给所述调度节点对应的代理服务,所述调度节点对应的代理服务用于根据所述待处理任务与所述调度节点通信,并获取所述待处理任务的执行结果;
5、接收所述调度节点对应的代理服务返回的所述执行结果;
6、根据所述待处理任务对应的所述执行结果,确定所述数据处理请求对应的处理结果,将所述处理结果发送给所述客户端。
7、第二方面,本申请实施例提供一种数据库的在线数据的处理方法,所述数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述方法包括:
8、所述代理服务接收管理服务器发送的待处理任务;
9、所述代理服务根据所述待处理任务与所述代理服务对应的节点通信,并获取所述待处理任务的执行结果;
10、所述代理服务将所述执行结果发送给所述管理服务器。
11、第三方面,本申请实施例提供一种数据库的在线数据的处理装置,所述装置应用于管理服务器,所述管理服务器用于管理至少一个数据库,每个数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述装置包括:
12、确定模块,用于根据客户端发送的数据处理请求,确定所述数据处理请求对应的待处理任务以及所述待处理任务关联的调度节点,所述数据处理请求用于请求对数据库的在线数据进行处理;
13、分发模块,用于将所述待处理任务下发给所述调度节点对应的代理服务,所述调度节点对应的代理服务用于根据所述待处理任务与所述调度节点通信,并获取所述待处理任务的执行结果;
14、接收模块,用于接收所述调度节点对应的代理服务返回的所述执行结果;
15、发送模块,用于根据所述待处理任务对应的所述执行结果,确定所述数据处理请求对应的处理结果,将所述处理结果发送给所述客户端。
16、第四方面,本申请实施例提供一种数据库的在线数据的处理装置,所述数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述装置应用于代理服务,所述装置包括:
17、接收模块,用于接收管理服务器发送的待处理任务;
18、处理模块,用于根据所述待处理任务与所述代理服务对应的节点通信,并获取所述待处理任务的执行结果;
19、发送模块,用于将所述执行结果发送给所述管理服务器。
20、第五方面,本申请实施例提供一种管理服务器,所述管理服务器包括:处理器和存储器,所述存储器用于存储计算机程序,所述处理器用于调用并运行所述存储器中存储的计算机程序,以执行如上述第一方面所述的方法。
21、第六方面,本申请实施例提供一种服务器,所述服务器包括:处理器和存储器,所述存储器用于存储计算机程序,所述处理器用于调用并运行所述存储器中存储的计算机程序,以执行如上述第二方面所述的方法。
22、第七方面,本申请实施例提供一种计算机可读存储介质,所述计算机可读存储介质用于存储计算机程序,所述计算机程序使得计算机执行如上述第一方面或第二方面所述的方法。
23、第八方面,本申请实施例提供一种计算机程序产品,包括计算机程序,所述计算机程序被处理器执行时实现如上述第一方面或第二方面的方法。
24、本申请实施例提供的技术方案,通过为数据库的每个节点设置一个代理服务,由管理服务器对数据处理请求进行处理,将数据处理请求拆分为一个或者多个待处理任务,每个待处理任务对应一个节点,并将待处理任务下发给对应节点的代理服务,各节点的代理服务执行待处理任务以获取数据库在线数据,并返回给管理服务器,从而实现对数据库系统的在线数据的管理。
1.一种数据库的在线数据的处理方法,其特征在于,应用于管理服务器,所述管理服务器用于管理至少一个数据库,每个数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述方法包括:
2.根据权利要求1所述的方法,其特征在于,所述根据所述数据处理请求,确定所述数据处理请求对应的待处理任务以及所述待处理任务关联的调度节点,包括:
3.根据权利要求2所述的方法,其特征在于,所述根据所述查询逻辑表示,确定所述数据处理请求对应的处理操作以及所述处理操作要访问的节点,包括:
4.根据权利要求3所述的方法,其特征在于,所述根据所述数据处理请求对应的操作类型和所述查询逻辑表示,确定所述数据处理请求对应的处理操作以及所述处理操作要访问的节点,包括:
5.根据权利要求1-4任一项所述的方法,其特征在于,所述数据处理请求用于请求对多个数据库的在线数据进行处理,所述待处理任务关联的调度节点包括所述多个数据库的节点。
6.根据权利要求5所述的方法,其特征在于,当所述待处理任务关联的多个调度节点中至少一个目标调度节点使用的第二数据查询语言与所述管理服务器使用的第一数据查询语言不同时;
7.根据权利要求1-4任一项所述的方法,其特征在于,所述管理服务器使用mysql对应的数据查询语言。
8.一种数据库的在线数据的处理方法,其特征在于,所述数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述方法包括:
9.根据权利要求8所述的方法,其特征在于,所述代理服务根据所述待处理任务与所述代理服务对应的节点通信,并获取所述待处理任务的执行结果,包括:
10.根据权利要求9所述的方法,其特征在于,所述根据所述待处理任务与所述代理服务对应的节点通信,并获取所述待处理任务的执行结果,包括:
11.根据权利要求9所述的方法,其特征在于,所述确定所述待处理任务对应的管理用户对所述待处理任务对应的处理操作是否具有权限,包括:
12.一种数据库的在线数据的处理装置,其特征在于,所述装置应用于管理服务器,所述管理服务器用于管理至少一个数据库,每个数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述装置包括:
13.一种数据库的在线数据的处理装置,其特征在于,所述数据库包括至少一个节点,每个节点设置有一个代理服务,所述代理服务用于控制对应的节点,所述装置应用于代理服务,所述装置包括:
14.一种管理服务器,其特征在于,包括:
15.一种服务器,其特征在于,包括:
16.一种计算机可读存储介质,其特征在于,用于存储计算机程序,所述计算机程序使得计算机执行如权利要求1至7中任一项所述的方法,或者执行如权利要求8-11中任一项所述的方法。
17.一种计算机程序产品,包括计算机程序,其特征在于,所述计算机程序被处理器执行时,实现如权利要求1至7中任一项所述的方法,或者执行如权利要求8-11中任一项所述的方法。
