一种实现分布式存储的内存数据库系统及应用

具体实施方式

下面结合附图来具体描述本发明的优先实施例，其中，附图构成本申请一部分，并与本发明的实施例一起用于阐释本发明的原理。

首先结合附图对本发明实施例所述内存数据库系统进行详细说明。

如图1所示，图1为本发明实施例所述内存数据库系统的结构示意图，具体可以包括：接口机、控制台、多个内存数据库，下面对各个部分进行详细阐述。

接口机，主要负责sql消息的分发、存储过程的实现和整个内存数据库系统的管理；具体的说就是，所述接口机中预先存储有真实数据库的多个数据库表和内存数据库的对应关系，当所述接口机在接收到访问客户端的sql请求后，根据该sql请求中的涉及到的数据库表，将该sql请求分发到相应的内存数据库。

内存数据库，多个内存数据库对应多个真实数据库，其主要负责真实数据库的多张数据库表的访问，即当内存数据库启动的时候，所述内存数据库通过从接口机存储的真实数据库的多个数据库表和内存数据库的对应关系进行查询，得到自己负责的数据库表的信息，然后从这些数据库表对应的真实数据库中读入这些数据库表的数据内容；并且，当所述内存数据库收到接口机分发的sql请求后，根据该sql请求的信息进行判断：如果是查询操作，则返回查询需要的数据集，如果是非查询操作，则根据sql请求的操作类型对数据作相应的更改，然后将该数据的修改内容以一定格式写入文件。

其中，所述sql消息至少包括如下字段：1、操作类型，如：添加、删除、修改、查询、执行存储过程；2、数据库表名；3、操作的具体信息：添加、删除、修改、查询、执行存储过程的时候所需要的信息，如添加的时候，添加的字段的值，删除的时候删除记录的特征等；4、操作的流水号，即每次操作被赋予的一个ID。

控制台，用户通过所述控制台对整个内存数据库系统进行配置，并通过和接口机交互使配置生效；配置内容包括内存数据库的IP、将真实数据库中的哪些数据库表的信息提取进内存数据库系统进行管理、以及一些其他的相关参数。

下面结合附图对利用本发明实施例所述系统实现数据分布式存储的方法进行详细说明。

如图2所示，图2为所述方法的流程示意图，具体可以包括以下步骤：

步骤201：接口机收到访问客户端的sql请求；

步骤202：接口机根据及时到的sql请求中涉及到的数据库表分发sql请求到内存数据库；

步骤203：收到sql请求的内存数据库判断该sql请求是否是查询操作，如果是查询操作，执行步骤206；如果是非查询操作，执行步骤204；

步骤204：对内存数据库中的数据进行相应的修改、删除、添加等操作，然后将数据进行的删除、修改、添加操作的具体信息写入预定的文件进行记录，然后执行步骤205；

步骤205：内存数据库将进行非查询操作的结果发送给接口机；

步骤206：根据sql请求中查询内容在内存数据库中查询相应的数据，并将查询到的结果返回给接口机；

步骤207：接口机将接收到的查询操作的结果或者非查询操作的结果返回给访问客户端。

本发明实施例所述方法还包括：内存数据库定时将发生修改、删除、添加等非查询操作的数据通过访问真实数据库，同步到真实数据库中，具体如图3所示，可以包括以下步骤：

步骤301：内存数据库根据sql请求的非查询操作，对其中的数据进行了修改、删除或添加等操作；

步骤302：内存数据库将发生修改、删除或添加等操作的数据写入预定的文件中；

步骤303：内存数据库定时扫描步骤302中的文件，并读出文件中的内容，将其中的数据通过访问真实数据库的方式同步到相应的真实数据库中。

综上所述，本发明实施例提供了一种实现分布式存储的内存数据库系统及应用，通过引入接口机，实现了内存数据库的分布式存储，实现起来十分简单，具有以下优点：

由于是和真实数据库中的部分数据库表对应，所以在现场施工的时候不用新增设备，直接在真实数据库的设备上实现就可以了；

由于接口机收到的sql请求已经是由访问客户端将数据的处理逻辑进行了封装，所以不再需要sql语句的解析过程，这样就不会造成内存数据库的性能浪费问题；

由于各个单独的内存数据库，对接收到的非查询操作都是串行处理，且每次操作都只在自己单独负责的数据库表中执行，所以就成功地避免了数据争抢导致死锁、脏读、脏写的发生，内存数据库也不用为自己负责的数据库表建立锁。

对数据修改的记录通过写文件的方式，这样就可以避免系统异常或者宕机以后出现内存数据库和真实数据库数据不同步的现象发生。

以上所述，仅为本发明较佳的具体实施方式，但本发明的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本发明揭露的技术范围内，可轻易想到的变化或替换，都应涵盖在本发明的保护范围之内。因此，本发明的保护范围应该以权利要求书的保护范围为准。