CN112612792B - 数据库管理方法和系统 - Google Patents

Abstract

本申请提供一种数据库管理方法和系统。该方法包括：第一数据库将第一订单写入待处理订单表；第一数据库将第一订单的第一信息发送给微服务应用；微服务应用根据第一订单的订单类型确定第一订单的失效时长；微服务应用将第一订单的第二信息写入第二数据库；微服务应用向第一数据库发送迁移指示消息，迁移指示消息中包括第一订单的订单编码；第一数据库根据迁移指示消息，将第一订单从待处理订单表搬迁至失效订单表。本申请的方法解决了现有技术中存在的订单延迟处理造成数据管理库的性能降低的问题。

Description

数据库管理方法和系统

技术领域

本申请涉及通信技术，尤其涉及一种数据库管理方法和系统。

背景技术

集中业务支撑系统在日常运行中，单系统承载超过4亿用户，为了提升集中业务支撑系统中数据管理库的性能，一般是将该数据管理库分为八个域进行数据管理，单域承载超过7000万的用户。在该集中业务支撑系统承载的庞大用户数量的基础上，每天在该集中业务支撑系统中产生的订单的数量超过了1000万以上，这些订单超过30分钟后便会失效。

为了防止该数据管理库的存储空间被大量失效的订单占用，一般需要每隔30分钟同时进行一次所有失效订单的搬迁和删除操作。但是，每条订单转变为失效订单的时间不同，针对每一条订单无法在订单达到30分钟立即失效后就对订单进行搬迁和删除操作，这就会造成失效订单的延迟处理，此时该数据管理库无法继续受理失效未删除的订单的下单用户的新业务，且未搬迁和删除的失效订单依然占用该数据管理库的存储空间，造成该数据管理库存储压力大的问题。除此之外，在处理基于分月转兑和定期执行等业务的订单的时候，也是对这些订单进行定时的搬迁和删除操作，这些非实时订单的延迟处理也会造成该数据管理库存储压力大的问题。

因此，如何及时处理订单，以提高该数据管理库的性能，仍然是需要解决的问题。

发明内容

本申请提供一种数据库管理方法和系统，用以解决如何及时处理订单，以提高该数据管理库的性能的问题。

一方面，本申请提供一种数据库管理方法，应用于数据库管理系统，所述数据库管理系统包括第一数据库、第二数据库和微服务应用，所述第一数据库为关系型数据库，所述第二数据库为非关系型数据库，所述第一数据库中包括待处理订单表和失效订单表，所述方法包括：

所述第一数据库将第一订单写入所述待处理订单表；

所述第一数据库将所述第一订单的第一信息发送给所述微服务应用，所述第一订单的第一信息包括订单编号、订单类型以及订单生成时间；

所述微服务应用根据所述第一订单的订单类型确定所述第一订单的失效时长；

所述微服务应用将所述第一订单的第二信息写入所述第二数据库，所述第二信息包括所述第一订单对应的键空间消息，所述键空间消息由所述微服务应用根据所述第一订单的第一信息编码生成；

若所述微服务应用在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，对所述第一订单的键空间消息进行解码得到所述第一订单的订单编码；

所述微服务应用向所述第一数据库发送迁移指示消息，所述迁移指示消息中包括所述第一订单的订单编码；

所述第一数据库根据所述迁移指示消息，将所述第一订单从所述待处理订单表搬迁至所述失效订单表。

其中一项实施例中，所述方法还包括：

若所述微服务应用在所述第一订单的失效时长内接收到所述第一数据库发送的订单完工信息，则所述微服务应用触发所述第二数据库删除所述第一订单的键空间消息。

其中一项实施例中，所述数据库管理系统还包括信息中间件，所述信息中间件用于实现所述第一数据库和所述微服务应用之间的通信；所述方法还包括：

所述信息中间件从所述第一数据库中获取所述第一订单的订单状态消息；

所述信息中间件将所述第一订单的订单状态消息发送至所述微服务应用。

其中一项实施例中，所述方法还包括：

若所述第二数据库在所述第一订单的失效时长内未接收到所述微服务应用发送的所述第一订单的订单完工消息，则所述第二数据库生成所述第一订单的键空间消息的删除消息；

若所述微服务应用在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，包括：

若所述微服务应用监控到所述第二数据库生成所述第一订单的键空间消息的删除消息，则接收所述第二数据库发送的所述第一订单的键空间消息。

其中一项实施例中，所述方法还包括：

所述微服务应用接收订单查询请求，所述订单查询请求中包括待查询订单编号；

所述微服务应用根据所述待查询订单编号从所述第二数据库中获取所述待查询订单编号对应的订单的状态信息。

其中一项实施例中，所述方法还包括：

所述微服务应用确定所述第一订单的第一信息中的异常数据，并将所述异常数据发送至第三数据库，所述第三数据库用于存储订单的异常数据。

另一方面，本申请还提供一种数据库管理系统，包括：

第一数据库，用于将第一订单写入所述待处理订单表；还用于将所述第一订单的第一信息发送给所述微服务应用，所述第一订单的第一信息包括订单编号、订单类型以及订单生成时间；还用于根据所述迁移指示消息，将所述第一订单从所述待处理订单表搬迁至所述失效订单表

第二数据库，与所述微服务应用信号连接；

微服务应用，与所述第一数据库信号连接，所述微服务应用用于根据所述第一订单的订单类型确定所述第一订单的失效时长；还用于将所述第一订单的第二信息写入所述第二数据库，所述第二信息包括所述第一订单对应的键空间消息，所述键空间消息由所述微服务应用根据所述第一订单的第一信息编码生成；还用于在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，对所述第一订单的键空间消息进行解码得到所述第一订单的订单编码；还用于向所述第一数据库发送迁移指示消息，所述迁移指示消息中包括所述第一订单的订单编码。

其中一项实施例中，若所述微服务器应用在所述第一订单的失效时长内接收到所述第一数据库发送的订单完工信息，则所述微服务应用触发所述第二数据库删除所述第一订单的键空间消息。

另一方面，本申请还提供一种计算机设备，包括存储器，处理器和收发器，所述存储器用于存储指令，所述收发器用于和其他设备通信，所述处理器用于执行所述存储器中存储的指令，以使所述计算机设备执行如第一方面所述的数据库管理方法。

另一方面，本申请还提供一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机执行指令，当所述指令被执行时，使得计算机执行如第一方面所述的数据库管理方法。

本实施例提供一种数据库管理方法，应用于数据库管理系统，该数据库管理系统包括第一数据库、第二数据库和微服务应用，该第一数据库为关系型数据库，该第二数据库为非关系型数据库。因此，在该第二数据库进行多个订单的信息存储时，不会以订单表的形式对多个订单进行存储。该第一数据库中包括待处理订单表和失效订单表。该第一数据库可以把实时写入该待处理订单表的第一订单的第一信息发送给该微服务应用，由该微服务应用进行该第一信息的处理后生成该第一订单的第二信息。该微服务应用再将该第一订单的第二信息写入该第二数据库。当该第一订单转变为失效订单时，该微服务应用再从该第二数据库中获取该第一订单的订单编码，将该第一订单的订单编码发送至该第一数据库，由该第一数据库找到该第一订单在该待处理订单表中的位置，再将该第一订单搬迁至该失效订单表中，并删除该待处理订单表中的该第一订单的第一信息。本实施例提供的数据库管理方法可以在订单转变为失效订单时立即对订单进行搬迁和删除操作，解决了数据管理库存储压力大、已失效未删除订单给用户造成的无法继续下单等问题，进而解决了现有技术中存在的订单延迟处理造成数据管理库的性能降低的问题。特别是针对用户量上亿的大型系统，本实施例提供的该数据库管理方法优化效果更为明显，可以更好的提高系统性能和稳定性。

附图说明

此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本申请的实施例，并与说明书一起用于解释本申请的原理。

图1为本申请的一个实施例提供的数据库管理方法的应用示意图。

图2为本申请的另一个实施例提供的数据库管理方法的应用示意图。

图3为本申请的一个实施例提供的数据库管理方法的流程示意图。

图4为本申请的另一个实施例提供的数据库管理方法的流程示意图。

图5为本申请的又一个实施例提供的数据库管理方法的应用示意图。

图6为本申请的另一个实施例提供的数据库管理方法的流程示意图。

图7为本申请的又一个实施例提供的数据库管理方法的流程示意图。

图8为本申请的另一个实施例提供的数据库管理方法的应用示意图。

图9为本申请的一个实施例提供的数据库管理系统的示意图。

图10为本申请的一个实施例提供的计算机设备的示意图。

通过上述附图，已示出本申请明确的实施例，后文中将有更详细的描述。这些附图和文字描述并不是为了通过任何方式限制本申请构思的范围，而是通过参考特定实施例为本领域技术人员说明本申请的概念。

具体实施方式

这里将详细地对示例性实施例进行说明，其示例表示在附图中。下面的描述涉及附图时，除非另有表示，不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本申请相一致的所有实施方式。相反，它们仅是与如所附权利要求书中所详述的、本申请的一些方面相一致的装置和方法的例子。

集中业务支撑系统实现了业务支撑系统域核心系统的集中，在该集中业务支撑系统的日常运行中，单系统承载4亿用户，因此将该系统中的数据管理库分为八个域进行数据管理，单域承载超过7000万的用户，以此提升该系统中数据管理库的性能。在该集中业务支撑系统承载的庞大用户数量的基础上，每天在该集中业务支撑系统中产生的订单的数量超过了1000万以上，有些订单超过30分钟后便会失效，有些订单超过24小时便会失效，有些订单在超过一个月后便会失效。为了防止该数据管理库的存储空间被大量失效的订单占用，针对超过30分钟会失效的这些订单，一般需要每隔30分钟同时进行一次所有失效订单的搬迁和删除操作，即，该数据管理库将失效订单从待处理订单表中搬迁至失效订单表中，再将该待处理订单表中的失效订单全部删除，减少该待处理订单表中的订单数量，提高待处理订单表对新受理的订单的受理能力。同样的，针对超过24小时或者针对一个月便会失效的这些订单，一般需要每隔24小时或者一个月同时进行所有失效订单的搬迁和删除操作。但是，每条订单转变为失效订单的时间不同，以订单生成起30分钟失效的订单为例，每隔30分钟对失效的订单进行同时搬迁和删除的话，例如在7点进行了一批订单的搬迁和删除操作，7点10生成的订单便只能等到8点进行搬迁和删除，因为7点30进行订单搬迁和删除操作时，该7点10生成的订单还未失效，不满足搬迁和删除的条件。因此，由于每条订单转变为失效订单的时间不同，针对每一条订单无法在订单达到30分钟立即失效后就对订单进行搬迁和删除操作这类情况，就会造成失效订单的延迟处理，此时该数据管理库无法继续受理失效却未删除的订单的下单用户的新业务，即，用户之前下单的订单未删除的情况下用户无法再下单新的订单。除此之外，未搬迁和删除的失效订单也会占用该数据管理库的存储空间，造成该数据管理库存储压力大的问题。依上该，在处理基于分月转兑和定期执行等业务的订单的时候，也是对这些订单进行定时的搬迁很删除操作，这些非实时订单的延迟处理也会造成该数据管理库存储压力大的问题。因此，如何及时处理订单，以提高该数据管理库的性能，仍然是需要解决的问题。

基于此，本申请提供一种数据库管理方法和系统，在原有的数据管理库的基础上增加非关系型数据库，并创建微服务应用。该微服务应用用于将该原有的数据管理库中的订单信息发送至该非关系型数据库，并对该非关系型数据库中订单的失效与否进行监控。若订单在小于或等于失效时长的时间还没有完工，则立即在订单失效的时候将失效订单的信息发送至该原有的数据管理库，由该数据管理库根据失效订单的信息进行失效订单的搬迁和删除操作。本申请提供的数据库管理方法和系统可以在订单失效时立即对失效的订单进行搬迁和删除，提高了订单的处理速度，也提高了该数据管理库的性能。

本申请提供的数据库管理方法，应用于计算机设备，该计算机设备例如可以为计算机、平板电脑、手机、云服务器等。图1为本申请提供的数据库管理方法的应用示意图，该计算机设备接收用户下单的待处理订单，并将该待处理订单存储在待处理订单表中，该待处理订单失效后，再将该待处理订单搬迁至该失效订单表，并从该待处理订单表中删除该待处理订单。该失效订单表用于存储失效订单。

请参见图2和图3，本申请提供一种数据库管理方法，应用于数据库管理系统，该数据库管理系统包括第一数据库、第二数据库和微服务应用，该第一数据库为关系型数据库，该第二数据库为非关系型数据库，该第一数据库中包括待处理订单表和失效订单表，该方法包括：

S301，该第一数据库将第一订单写入该待处理订单表。

用户可以通过前台用户界面(User Interface，简称UI)创建订单，创建的订单信息通过用户接口程序(Umbilical Interface Panel，简称UIP)传输至该计算机设备中的订单模块，该订单模块再将该创建的订单信息发送至该第一数据库的该待处理订单表中。在一个可选的实施例中，该第一数据库可以为Oracle数据库(Oracle Database)。该第一订单指的是任意一个用户创建的订单。

S302，该第一数据库将该第一订单的第一信息发送给该微服务应用，该第一订单的第一信息包括订单编号、订单类型以及订单生成时间。

该微服务应用与该第一数据库通信连接，该第一数据库在接收到该第一订单的第一信息后可以将该第一订单的第一信息实时发送至该微服务应用。该第一订单的第一信息包括订单编号、订单类型以及订单生成时间。该订单编号例如123，该订单类型例如为充话费实时订单，该订单生成时间指的是该订单创建的时间。

S303，该微服务应用根据该第一订单的订单类型确定该第一订单的失效时长。

不同类型的订单的失效时长不同，例如，充话费实时订单的失效时长为30分钟。还有的订单类型对应的失效时长为24小时、一周或者一个月等。不同订单类型对应的失效时长可以由工作人员根据实际需要设置，本申请不做限定。

S304，该微服务应用将该第一订单的第二信息写入该第二数据库，该第二信息包括该第一订单对应的键空间消息，该键空间消息由该微服务应用根据该第一订单的第一信息编码生成。

该微服务应用在接收到该第一订单的第一信息后，立即生成该第一订单的第二信息，该第二信息中包括该键空间消息的监控时间戳，该监控时间戳用于该第二数据库对该第一订单是否失效进行监控。例如，该第一订单的失效时长是30分钟，则该监控时间戳可以设置为30分钟。该键空间消息是根据该第一订单的第一信息编码生成。例如，该订单编号是123，该键空间消息可以是tradeid:123。该键空间消息中还可以加上其他信息，比如省份、城市。例如，将城市为北京定义为11，地市编码是0010，那么该键空间消息可以是tradeid:123:province:11:eparchy:0010。在一个可选的实施例中，该第二数据库可以为远程字典服务数据库(Remote Dictionary Server，简称Redis)。

S305，若该微服务应用在该第一订单的失效时长内未接收到该第一数据库发送的该第一订单的完工信息，则该微服务应用从该第二数据库获取该第一订单的键空间消息，对该第一订单的键空间消息进行解码得到该第一订单的订单编码。

若在小于或等于30分钟的时间内，该微服务应用没有接收到从该消息中间件发送的订单完工消息，则该第二数据库中的该第一订单的第二信息依然存在。该第二数据库可以根据该微服务应用设置的失效时长到期自动删除该键空间消息，并产生一个键空间触发删除的消息。该微服务应用对该第二数据库中的该第一订单的键空间消息进行实时监控，若该微服务应用监控到该键空间消息触发删除的消息生成，则由该微服务应用从该第二数据库获取该第一订单的键空间消息，并对该第一键空间消息进行解码得到该第一订单的订单编码。

S306，该微服务应用向该第一数据库发送迁移指示消息，该迁移指示消息中包括该第一订单的订单编码。

该微服务应用向该第一数据库发送该迁移指示消息，该迁移指示消息中包括该第一订单的订单编码。该迁移指示信息用于指示该第一数据库将该第一订单从该待处理订单表中搬迁至该失效订单表，并从该待处理订单表中删除该第一订单。

S307，该第一数据库根据该迁移指示消息，将该第一订单从该待处理订单表搬迁至该失效订单表。

该第一数据库在接收到该迁移指示信息后，将该第一订单从该待处理订单表中搬迁至该失效订单表。而在现有技术中该第一数据库需要进行全表扫描确定失效订单，并进行失效订单的搬迁和删除操作，这个方法需要每隔一段时间去全表扫描所有的数据，并对扫描到的数据进行判断和删除操作，工作量大。相比于现有技术的全表扫描方案，本步骤提供的失效订单的搬迁和删除操作只需要该第一数据库在接收到该迁移指示信息后，将该第一订单从该待处理订单表中搬迁至该失效订单表，不需要进行全表扫描，减少了失效订单变迁和删除操作的步骤和计算量，提高了该第一数据库的性能。

本实施例提供一种数据库管理方法，应用于数据库管理系统，该数据库管理系统包括第一数据库、第二数据库和微服务应用，该第一数据库为关系型数据库，该第二数据库为非关系型数据库。因此，在该第二数据库进行多个订单的信息存储时，不会以订单表的形式对多个订单进行存储。该第一数据库中包括待处理订单表和失效订单表。该第一数据库可以把实时写入该待处理订单表的第一订单的第一信息发送给该微服务应用，由该微服务应用进行该第一信息的处理后生成该第一订单的第二信息。该微服务应用再将该第一订单的第二信息写入该第二数据库。当该第一订单转变为失效订单时，该微服务应用再从该第二数据库中获取该第一订单的订单编码，将该第一订单的订单编码发送至该第一数据库，由该第一数据库找到该第一订单在该待处理订单表中的位置，再将该第一订单搬迁至该失效订单表中，并删除该待处理订单表中的该第一订单的第一信息。本实施例提供的数据库管理方法可以在订单转变为失效订单时立即对订单进行搬迁和删除操作，解决了数据管理库存储压力大、已失效未删除订单给用户造成的无法继续下单等问题，进而解决了现有技术中存在的订单延迟处理造成数据管理库的性能降低的问题。特别是针对用户量上亿的大型系统，本实施例提供的该数据库管理方法优化效果更为明显，可以更好的提高系统性能和稳定性。

在本申请的一个实施例中，该数据库管理方法还包括：

若该微服务应用在该第一订单的失效时长内未接收到该第一数据库发送的订单完工信息，则该微服务应用触发该第二数据库删除该第一订单的键空间消息。该微服务应用在触发该第二数据库删除该第一订单的键空间消息后，该第二数据库删除该第一订单的键空间消息，该微服务应用根据该第一订单的键空间消息解码得到该第一订单的订单编码。该微服务应用在得到该第一订单的订单编码向该第一数据库发送迁移指示消息，并将该第一订单的订单编码发送至该第一数据库，由该第一数据库根据该第一订单的订单编码完成该第一订单的搬迁和删除操作。即，该第一数据库将该第一订单从该待处理订单表中搬迁至该失效订单表，并从该待处理订单表中删除该第一订单。

请参见图4和图5，在本申请的一个实施例中，该数据库管理系统还包括信息中间件，该信息中间件用于实现该第一数据库和该微服务应用之间的通信，该数据库管理方法还包括：

S401，该信息中间件从该第一数据库中获取该第一订单的订单状态消息。

该第一数据库和该消息中间件(Apache Kafka，简称kafka)通信连接，该消息中间件和该微服务应用通信连接。该第一数据库通过数据卸载的方式向该消息中间件发送该第一订单的订单状态信息，该订单状态信息例如订单完工信息，或其他订单状态信息。该第一数据库还可以通过数据卸载的方式将该第一订单的第一信息发送至该消息中间件，再由该微服务应用消费kafka数据，获取该第一订单的第一信息。

S402，该信息中间件将该第一订单的订单状态消息发送至该微服务应用。

该信息中间件在接收到该第一数据库发送的该第一订单的订单状态消息后，该微服务应用消费该消息中间件的数据，从该消息中间件获取该第一订单的订单状态消息。该微服务应用再根据该第一订单的订单状态信息更新该第二数据库中的该第一订单的键空间消息。例如，该第一订单的订单状态信息包括该订单完工的消息，则该微服务应用在接收到该订单完工的消息后，将该第二数据库中的该第一订单的信息删除，此时不会触发该第二数据库删除该第一订单的键空间消息。

请参见图6，在本申请的一个实施例中，该数据库管理方法还包括：

S601，若该第二数据库在该第一订单的失效时长内未接受到该微服务应用发送的该第一订单的订单完工消息，则该第二数据库生成该第一订单的键空间消息的删除消息。

若该第一订单在该第一订单的失效时长内未完工，则该微服务应用无法从该消息中间件获取到该第一订单的订单完工消息，或者说无法从该第一数据库获取到该第一订单的订单完工消息。此时，在该第一订单到达该失效时长后，该微服务应用触发该第二数据库删除该第一订单的键空间消息。该第二数据库在被该微服务应用触发后，生成该第一订单的键空间消息的删除消息。即，该第二数据库可以根据该微服务应用根据该第一订单的失效时长设置的监控时间戳对该第一订单进行监控，如果到达该第一订单的失效时长后该第一订单仍处于未完工状态，则该第一订单在到达该失效时长后成为失效订单，此时该第二数据库在该微服务应用的触发下生成该第一订单的键空间消息的删除消息。

S602，若该微服务应用在该第一订单的失效时长内未接收到该第一数据库发送的该第一订单的完工信息，则该微服务应用从该第二数据库获取该第一订单的键空间消息，包括：

若该微服务应用监控到该第二数据库生成该第一订单的键空间消息的删除消息，则接收该第二数据库发送的该第一订单的键空间消息。

该微服务应用在监控到该第一订单的键空间消息的删除消息时，实时获取该第二数据库发送的该第一订单的键空间消息，再解码该第一订单的键空间消息得到该第一订单的订单编号，并生成该迁移指示消息。

请参见图7和图8，在本申请的一个实施例中，该数据库管理方法还包括：

S701，该微服务应用接收订单查询请求，该订单查询请求中包括待查询订单编号。

用户可以通过手厅、网厅或其他外围触点创建该订单查询请求，该微服务应用可以通过能力开放平台获取该订单查询请求。该订单查询请求中包括待查询订单编号，还可以包括其他关于待查询订单的信息，例如订单创建时间、订单类型等。

S702，该微服务应用根据该待查询订单编号从该第二数据库中获取该待查询订单编号对应的订单的状态信息。

如图8，未失效的订单可以理解为在途订单。该微服务应用可以在接收到该待查询请求后进行在途订单查询，即，查询未失效订单的待失效时长，该待失效时长指的是未失效订单距离失效的时长。例如，该第一订单是在7点10创建的，该第一订单的失效时长为30分钟。若该微服务应用在7点20接收到该第一订单的订单查询请求，则可以查询到该第一订单的待失效时长为20分钟，即该第一订单还有20分钟才会失效。用户可以通过该微服务应用获取到该待查询订单变化要对应的订单的状态信息，该状态信息包括是否处于未完工状态，以及待失效时长为多少等。该微服务应用也可以从第一数据库中获取该待查询订单编号对应的订单的状态信息。

在本申请的一个实施例中，该数据库管理方法还包括：

该微服务应用确定该第一订单的第一信息中的异常数据，并将该异常数据发送至该第三数据库，该第三数据库用于存储订单的异常数据。

该异常数据例如乱码的数据。在一个可选的实施例中，该第三数据库为关系型数据库，该第三数据库可以为Mysql数据库。将该异常数据存储于该第三数据库中，可以方便工作人员查询和处理该异常数据。

请一并参见图9，本申请还提供一种数据库管理系统10，包括：

第一数据库11，用于将第一订单写入该待处理订单表；还用于将该第一订单的第一信息发送给该微服务应用，该第一订单的第一信息包括订单编号、订单类型以及订单生成时间；还用于根据该迁移指示消息，将该第一订单从该待处理订单表搬迁至该失效订单表

第二数据库12，与该微服务应用信号连接；

微服务应用13，与该第一数据库信号连接，该微服务应用用于根据该第一订单的订单类型确定该第一订单的失效时长；还用于将该第一订单的第二信息写入该第二数据库，该第二信息包括该第一订单对应的键空间消息，该键空间消息由该微服务应用根据该第一订单的第一信息编码生成；还用于在该第一订单的失效时长内未接收到该第一数据库发送的该第一订单的完工信息，则该微服务应用从该第二数据库获取该第一订单的键空间消息，对该第一订单的键空间消息进行解码得到该第一订单的订单编码；还用于向该第一数据库发送迁移指示消息，该迁移指示消息中包括该第一订单的订单编码。该微服务应用13还用于在该第一订单的失效时长内接收到该第一数据库发送的订单完工信息，则该微服务应用触发该第二数据库删除该第一订单的键空间消息；

该数据库管理系统10还包括消息中间件14，该消息中间件14用于实现该第一数据库和该微服务应用之间的通信。该消息中间件14用于从该第一数据库中获取该第一订单的订单状态消息；还用于将该第一订单的订单状态消息发送至该微服务应用。

该第二数据库12用于在该第一订单的失效时长内未接收到该微服务应用发送的该第一订单的订单完工消息，则该第二数据库生成该第一订单的键空间消息的删除消息；

该微服务应用13用于在该第一订单的失效时长内未接收到该第一数据库发送的该第一订单的完工信息，则该微服务应用从该第二数据库获取该第一订单的键空间消息；还用于监控到该第二数据库生成该第一订单的键空间消息的删除消息，则接收该第二数据库发送的该第一订单的键空间消息。

该微服务应用13还用于接收订单查询请求，该订单查询请求中包括待查询订单编号；根据该待查询订单编号从该第二数据库中获取该待查询订单编号对应的订单的状态信息。

该微服务应用13还用于确定该第一订单的第一信息中的异常数据，并将该异常数据发送至第三数据库15，该第三数据库15用于存储订单的异常数据。

请参见图10，本申请还提供一种计算机设备20，包括存储器21，处理器22和收发器23，该存储器31用于存储指令，该收发器33用于和其他设备通信，该处理器32用于执行该存储器31中存储的指令，以使该计算机设备执行如上任一项该的数据库管理方法。

本申请还提供一种计算机可读存储介质，该计算机可读存储介质中存储有计算机执行指令，当该指令被执行时，使得计算机执行指令被处理器执行时用于实现如上任一项实施例提供的该数据库管理方法。

需要说明的是，上述计算机可读存储介质可以是只读存储器(Read Only Memory，ROM)、可编程只读存储器(Programmable Read-Only Memory，PROM)、可擦除可编程只读存储器(Erasable Programmable Read-Only Memory，EPROM)、电可擦除可编程只读存储器(Electrically Erasable Programmable Read-Only Memory，EEPROM)、磁性随机存取存储器(Ferromagnetic Random Access Memory，FRAM)、快闪存储器(Flash Memory)、磁表面存储器、光盘、或只读光盘(Compact Disc Read-Only Memory，CD-ROM)等存储器。也可以是包括上述存储器之一或任意组合的各种电子设备，如移动电话、计算机、平板设备、个人数字助理等。

需要说明的是，在本文中，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者装置不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者装置所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括该要素的过程、方法、物品或者装置中还存在另外的相同要素。

上述本申请实施例序号仅仅为了描述，不代表实施例的优劣。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，空调器，或者网络设备等)执行本申请各个实施例所描述的方法。

本申请是参照根据本申请实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

以上仅为本申请的优选实施例，并非因此限制本申请的专利范围，凡是利用本申请说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本申请的专利保护范围内。

Claims (9)

1.一种数据库管理方法，其特征在于，应用于数据库管理系统，所述数据库管理系统包括第一数据库、第二数据库和微服务应用，所述第一数据库为关系型数据库，所述第二数据库为非关系型数据库，所述第一数据库中包括待处理订单表和失效订单表，所述方法包括：

所述第一数据库将第一订单写入所述待处理订单表；

所述第一数据库将所述第一订单的第一信息发送给所述微服务应用，所述第一订单的第一信息包括订单编码、订单类型以及订单生成时间；

所述微服务应用根据所述第一订单的订单类型确定所述第一订单的失效时长；

所述微服务应用将所述第一订单的第二信息写入所述第二数据库，所述第二信息包括所述第一订单对应的键空间消息，所述键空间消息由所述微服务应用根据所述第一订单的第一信息编码生成；

若所述微服务应用在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，对所述第一订单的键空间消息进行解码得到所述第一订单的订单编码；

所述微服务应用向所述第一数据库发送迁移指示消息，所述迁移指示消息中包括所述第一订单的订单编码；

所述第一数据库根据所述迁移指示消息，将所述第一订单从所述待处理订单表搬迁至所述失效订单表；

若所述第二数据库在所述第一订单的失效时长内未接收到所述微服务应用发送的所述第一订单的订单完工消息，则所述第二数据库生成所述第一订单的键空间消息的删除消息；

若所述微服务应用在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，包括：

若所述微服务应用监控到所述第二数据库生成所述第一订单的键空间消息的删除消息，则接收所述第二数据库发送的所述第一订单的键空间消息。

2.根据权利要求1所述的方法，其特征在于，所述方法还包括：

若所述微服务应用在所述第一订单的失效时长内接收到所述第一数据库发送的订单完工信息，则所述微服务应用触发所述第二数据库删除所述第一订单的键空间消息。

3.根据权利要求1所述的方法，其特征在于，所述数据库管理系统还包括信息中间件，所述信息中间件用于实现所述第一数据库和所述微服务应用之间的通信；所述方法还包括：

所述信息中间件从所述第一数据库中获取所述第一订单的订单状态消息；

所述信息中间件将所述第一订单的订单状态消息发送至所述微服务应用。

4.根据权利要求1-3任一项所述的方法，其特征在于，所述方法还包括：

所述微服务应用接收订单查询请求，所述订单查询请求中包括待查询订单编码；

所述微服务应用根据所述待查询订单编码从所述第二数据库中获取所述待查询订单编码对应的订单的状态信息。

5.根据权利要求1-3任一项所述的方法，其特征在于，所述方法还包括：

所述微服务应用确定所述第一订单的第一信息中的异常数据，并将所述异常数据发送至第三数据库，所述第三数据库用于存储订单的异常数据。

6.一种数据库管理系统，其特征在于，包括：

第一数据库，用于将第一订单写入待处理订单表；还用于将所述第一订单的第一信息发送给微服务应用，所述第一订单的第一信息包括订单编码、订单类型以及订单生成时间；还用于根据迁移指示消息，将所述第一订单从所述待处理订单表搬迁至失效订单表；

第二数据库，与所述微服务应用信号连接；

微服务应用，与所述第一数据库信号连接，所述微服务应用用于根据所述第一订单的订单类型确定所述第一订单的失效时长；还用于将所述第一订单的第二信息写入所述第二数据库，所述第二信息包括所述第一订单对应的键空间消息，所述键空间消息由所述微服务应用根据所述第一订单的第一信息编码生成；还用于在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息，对所述第一订单的键空间消息进行解码得到所述第一订单的订单编码；还用于向所述第一数据库发送迁移指示消息，所述迁移指示消息中包括所述第一订单的订单编码；

所述第二数据库，用于在所述第一订单的失效时长内未接收到所述微服务应用发送的所述第一订单的订单完工消息，则生成所述第一订单的键空间消息的删除消息；

所述微服务应用，用于在所述第一订单的失效时长内未接收到所述第一数据库发送的所述第一订单的完工信息，则所述微服务应用从所述第二数据库获取所述第一订单的键空间消息；还用于，监控到所述第二数据库生成所述第一订单的键空间消息的删除消息，则接收所述第二数据库发送的所述第一订单的键空间消息。

7.根据权利要求6所述的系统，其特征在于，若所述微服务应用在所述第一订单的失效时长内接收到所述第一数据库发送的订单完工信息，则所述微服务应用触发所述第二数据库删除所述第一订单的键空间消息。

8.一种计算机设备，其特征在于，包括存储器，处理器和收发器，所述存储器用于存储指令，所述收发器用于和其他设备通信，所述处理器用于执行所述存储器中存储的指令，以使所述计算机设备执行如权利要求1-5任一项所述的数据库管理方法。

9.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机执行指令，当所述指令被执行时，使得计算机执行如权利要求1-5中任一项所述的数据库管理方法。

Images