当前位置：网学 > 设计下载 > 其他类别 > 正文

基于XML的数据库同步系统

来源：http://myeducs.cn 联系QQ：

作者：用户投稿来源：网络发布时间： 13/05/06

网学网其他类别编辑为广大网友搜集整理了：基于XML的数据库同步系统绩等信息，祝愿广大网友取得需要的信息，参考学习。

客服咨询，网学网竭诚为您服务，本站永久域名：myeducs.cn

1.1.1 同步部分

1．同步控制模块

源端：

主要包含于Windows服务里，通过Timer的执行函数调用。其关键代码如下：

public static string OpenConn(string IP,string Port)

{

string strResult="-4,-3,-5,-2,-1";

IPAddress HostAddr=IPAddress.Parse(IP);

IPEndPoint host=new IPEndPoint(HostAddr,int.Parse(Port));

Socket s=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

try

{

s.Connect(host);

}

catch{return IP;}//连接失败

string tmpstr="1";

byte[] sendBytes = Encoding.ASCII.GetBytes(tmpstr.ToCharArray());

try

{

s.Send(sendBytes,sendBytes.Length,0);

}

catch{return "-1";}//发送数据失败

int bytes=0;

byte[] recBytes=new byte[256];

string recString ="";

try

{

bytes=s.Receive(recBytes,recBytes.Length,0);

}

catch{return "-2";}//接受数据失败

recString=Encoding.ASCII.GetString(recBytes,0,bytes);

if(recString.Length>0 && strResult.IndexOf(recString) != 0)

{

SqlHelper.myExec ("exec dbo.prReadTempToReadState ''" + IP + "''," + recString);

}

s.Close();

System.Threading.Thread.CurrentThread.Abort();//终止当前线程

return recString;

}

通过Timer的执行函数传入同步的目的IP、端口创建Socket对象、建立连接，然后发送同步信号，等待目的端的返回信号,如果返回的数据不包含错误消息就标识本次已经读取的信息到读取状态表。然后终止当前线程。

目的端：

用控制台应用程序实现了本部分，程序一启动就开始处于监听状态，接收源端发来同步信号，并负责启动数据写入模块。

2．数据导入

本部分负责调用Web Service方法获取数据合并、分解处理后将数据写入Oracle数据库。

3． Web Service

存在于源端的Web Service 项目里其主要方法：

[WebMethod]

public DataSet Provider(string IP，T)

{

DataSet ds=DataOpt.myDataSet("exec dbo.LJReadByIP ''" + IP + "'',’"+T+"''); return ds;

}

在调用此方法时需要添加Web 引用地址如下：

http://localhost/DataSynchronize/DataProvide.asmx

存储过程dbo.LJReadByIP根据传入的参数，先判断是否是系统的“合法用户”，如果是合法的身份就先得到本次读取的编号，此读取编号是”读取缓冲表：tReadTemp”表中的“读取秩序号：ReadNo”的最大值加1得到的。供以后同步控制用。然后根据读取“同步缓冲临时表：tTemp”表中记录的数据表里的主键来读取数据。读取的数据是在“读取状态表: tReadState”表里无本IP记录的记录。将读了的数据保存到” 读取缓冲表：tReadTemp”里,如果在tReadTemp表里存在该信息主键就更新这条记录的读取时间和读取秩序号为当前读取时间和读取秩序号。

2 测试

软件的测试就是为了发现系统中的错误，以及是否达到了需求说明中所定义的需求。下面介绍对功能、以及的测试。

2.1 功能测试

基本同步功能测试：

1．数据项如表8：

表8：输入数据