mysql与MongoDB数据同步的方法及其系统

摘要

本发明公开一种mysql与MongoDB数据同步的方法，在开发机上调用OpenReplicator，读取A服务器上日志文件，失败则启动A服务器mysql并联网成功，成功则执行步骤5.2；5.2)、在开发机上定义计数器n；5.3)、开发机读取A服务器上的第n行binlog，将赋值给字符串S1；5.4)、S1为空则同步结束，不为空判断S1是否包含insert/update关键字，包含则执行步骤5.5，否则n＝n+1，执行步骤5.3；MongoDB上执行S2语句，失败则同步结束；成功则n＝n+1并执行步骤5.3。本发明还公开一种采用上述方法的系统。本发明可发挥mysql与MongoDB这两者的优势。

主权项

一种mysql与MongoDB数据同步的方法，其特征在于，通过以下步骤实现：1)、在开发机上搭建开发环境；2)、在A服务器上安装mysql数据库，并将数据库引擎设置为INNODB，启动数据库；3)、在B服务器上安装MongoDB数据库；4)、在开发机上，打开Eclipse，新建一个工程，配置好依赖jar包；5)、在开发机上新建一个类，在类里面编写数据同步代码，步骤如下：5.1)、在开发机上调用OpenReplicator，读取A服务器上mysql的binlog日志文件，如果读取失败，则启动A服务器mysql并联网成功，联网成功之后执行步骤5.2；如果读取binlog日志文件成功，则执行步骤5.2；5.2)、在开发机上定义计数器n，n＝1；5.3)、开发机读取A服务器上的第n行binlog，将赋值给字符串S1；5.4)、如果S1为空，则同步结束，如果不为空，进一步判断S1是否包含insert/update关键字，如果包含则执行步骤5.5，否则n＝n+1,执行步骤5.3；5.5)、开发机将S1转为MongoDB可执行的字符串S2；5.6)、开发机调用MongoDB JDBC驱动，连接MongoDB，如果连接失败，则启动B服务器MongoDB数据库并联网成功，如果联网成功则执行步骤5.7；5.7)、调用MongoDB驱动，在MongoDB上执行S2语句，如果失败，则同步结束；如果成功，则n＝n+1,并执行步骤5.3。