数据同步服务程--设计及实现.doc

数据库同步工具（服务） 设计思想： 1.由于两个数据库中只有一个数据库所在的服务器为固定IP，我们可以通过在固定IP服务器上开启Socket网络服务端监听自身IP和指定端口号的网络连接，而另一个具有不固定IP的服务器开启Socket客户端连接到指定的IP和端口，建立起网络连接来传输文件； 2.双方数据库中都在每个表中增加两列，分别用于检测数据是否是自身数据（_InsertType 0: 自身数据;1:非自身数据）和记录数据的实际插入时间（AddDate）； 3.同步时间设置，按指定时间或者循环间隔时间来进行同步操作； 4.每次启动同步时，都将每个表中自身的新增数据读取出来转换成一个以表明为名称的xml文件，然后通过建立起的Socket连接进行文件传输给对方，并更新最后同步时间以便下次更新时使用；对方接收到数据xml文件后，读取接收到的所有文件然后插入到指定的表中，其中_InsertType的值都设置为1； 这样完成一次同步。 程序实现： 网络连接建立： 双方服务器通过设置自身的服务器端/客户端来确定网络通信中的角色。 确定好的后将信息存入config.ini文件中。 数据库修改及连接设置： 1）数据库修改： 数据库所有用户表添加AddDate来存储数据的插入时间，用来进行更新。 数据库所有用户表添加_InsertType来存储数据是否是自身数据。 declare @Tname varchar(50) declare CurT cursor for Select [name] From SysObjects Where XType=U order By Name open CurT fetch next from CurT into @Tname while @@fetch_status=0 BEGIN --为每个表添加AddDate列默认值为当前时间 exec (ALTER Table +@Tname+ ADD AddDate datetime DEFAULT GETDATE() Not NULL) --为每个表添加列默认值为exec (ALTER Table +@Tname+ ADD _InsertType int DEFAULT 0 Not NULL) fetch next from CurT into @Tname end close CurT deallocate CurT 2）数据库连接设置： 点击高级，指定需要同步数据的表， 确定好的后将信息存入config.ini文件中。 3.同步时间设定： 按指定时间或者循环间隔时间来进行同步操作， 确定好的后将信息存入config.ini文件中。 4.数据同步文件生成、传输及插入： 1）数据同步文件生成 首先根据当前的时间的yyyyMMddHHmmss格式生成一个文件夹， 其次读取LastDate.xml文件，获取每个需要更新的表（从config.ini中获取）中最后更新的时间，然后从表中读取_InsertType为0且Adddate时间大于最后同步时间的数据，在时间文件夹下的Data文件夹中生成以表名为名称的xml文件。 2）Socket网络文件传输，在建立连接下的客户端与服务器端通过当前的有效连接进行文件传输，当前连接不存在时，重新进行网络连接；而文件传输失败时应该可以进行断点续传或重新传输。传输目标位整个Data文件夹下的所有xml文件。 数据记录传输格式： TableName Row Columm id=col1value /Columm Columm id=col2value /Columm ... /Row /TableName 3）接收到xml文件后，读取所有本次接收到的文件，根据文件名找到指定的数据库中的表名，读取表中的所有列的属性，自增列不进行数据插入，没有值的列也不进行插入，并且再插入时，指定_InsertType的值为1，即标示为接收到的数据。数据插入时，错误信息将保存到ZPAEDataService.Runlog文件中。 config.ini说明： #数据库同步配置 [SocketSetting] ConStr=1|4242|60.216.11.37|4242 其中1为Client/0为Server，后面第一个的4242分别为服务器开启端口号, 60.216.11.37|4242分别是客户端请求连接的IP和端口号。 [DataSetting] ConStr=jnzp-liuhongbo|sa|111111|ZPSCGLDBALL 其中jnzp-liuhongbo为数据库服务名称，sa|111111分别是数据库登录的用户名和密码，ZPSCGLDBALL是数据库名称。