利用C#实现数据同步功能
2010-08-17 23:13
615 查看
如下代码摘自
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
using System.Data.SqlServerCe;
using System.IO;
using System.Xml;
namespace LocalTest
{
public partial class Form6 : Form
{
string remoteString;
string localString;
SqlCeConnection conn = new SqlCeConnection("DataSource=Test.sdf");
public Form6()
{
InitializeComponent();
}
private void Form_Load(object sender, EventArgs e)
{
//conn.ConnectionString = "DataSource=mysdf.sdf";
remoteString = "provider=sqloledb;Data Source=172.18.188.31;Initial Catalog=InfoDB;Persist Security Info=True;User ID=Test;Password=sa";
localString = "DataSource=Test.sdf";
}
private void btn_save_Click(object sender, EventArgs e)
{
try
{
string ls_pcno, ls_pcxh, ls_type, ls_date;
ls_pcno = tb_no.Text.ToString().Trim();
ls_pcxh = tb_xh.Text.ToString().Trim();
ls_type = tb_type.Text.ToString().Trim();
ls_date = tb_date.Text.ToString().Trim();
string ls_sql = "insert into pc values ('" + ls_pcno + "', '" + ls_pcxh + "', '" + ls_type + "', '" + ls_date + "')";
MessageBox.Show(ls_sql);
SqlCeCommand cmd = new SqlCeCommand(ls_sql);
conn.Open();
cmd.Connection = conn;
cmd.ExecuteNonQuery();
conn.Close();
MessageBox.Show("插入数据成功!");
}
catch (Exception ex)
{
MessageBox.Show("插入数据失败!" + ex.ToString());
}
}
//从SQL Server 把数据同步过来PULL
private void btn_rec_Click(object sender, EventArgs e)
{
try
{
SqlCeRemoteDataAccess rda = new SqlCeRemoteDataAccess();
rda.LocalConnectionString = localString;
rda.InternetUrl = "http://172.18.188.31/test/sqlcesa30.dll";
rda.Pull("pcinfo", "select * from pc", remoteString,RdaTrackOption.TrackingOn,"ErrorList");
MessageBox.Show("获取数据成功");
}
catch (Exception ex)
{
MessageBox.Show("获取数据失败" + ex.ToString());
}
}
// 将修改过的数据同步到SQL Server 数据库中去PUSH
private void btn_send_Click(object sender, EventArgs e)
{
try
{
SqlCeRemoteDataAccess rda = new SqlCeRemoteDataAccess();
rda.LocalConnectionString = localString;
rda.InternetUrl = "http://172.18.188.31/test/sqlcesa30.dll";
rda.Push("pcinfo", remoteString, RdaBatchOption.BatchingOn);
MessageBox.Show("同步数据成功");
}
catch (Exception ex)
{
MessageBox.Show("同步数据失败" + ex.ToString());
}
}
private void btn_cancel_Click(object sender, EventArgs e)
{
this.Close();
}
}
}
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
using System.Data.SqlServerCe;
using System.IO;
using System.Xml;
namespace LocalTest
{
public partial class Form6 : Form
{
string remoteString;
string localString;
SqlCeConnection conn = new SqlCeConnection("DataSource=Test.sdf");
public Form6()
{
InitializeComponent();
}
private void Form_Load(object sender, EventArgs e)
{
//conn.ConnectionString = "DataSource=mysdf.sdf";
remoteString = "provider=sqloledb;Data Source=172.18.188.31;Initial Catalog=InfoDB;Persist Security Info=True;User ID=Test;Password=sa";
localString = "DataSource=Test.sdf";
}
private void btn_save_Click(object sender, EventArgs e)
{
try
{
string ls_pcno, ls_pcxh, ls_type, ls_date;
ls_pcno = tb_no.Text.ToString().Trim();
ls_pcxh = tb_xh.Text.ToString().Trim();
ls_type = tb_type.Text.ToString().Trim();
ls_date = tb_date.Text.ToString().Trim();
string ls_sql = "insert into pc values ('" + ls_pcno + "', '" + ls_pcxh + "', '" + ls_type + "', '" + ls_date + "')";
MessageBox.Show(ls_sql);
SqlCeCommand cmd = new SqlCeCommand(ls_sql);
conn.Open();
cmd.Connection = conn;
cmd.ExecuteNonQuery();
conn.Close();
MessageBox.Show("插入数据成功!");
}
catch (Exception ex)
{
MessageBox.Show("插入数据失败!" + ex.ToString());
}
}
//从SQL Server 把数据同步过来PULL
private void btn_rec_Click(object sender, EventArgs e)
{
try
{
SqlCeRemoteDataAccess rda = new SqlCeRemoteDataAccess();
rda.LocalConnectionString = localString;
rda.InternetUrl = "http://172.18.188.31/test/sqlcesa30.dll";
rda.Pull("pcinfo", "select * from pc", remoteString,RdaTrackOption.TrackingOn,"ErrorList");
MessageBox.Show("获取数据成功");
}
catch (Exception ex)
{
MessageBox.Show("获取数据失败" + ex.ToString());
}
}
// 将修改过的数据同步到SQL Server 数据库中去PUSH
private void btn_send_Click(object sender, EventArgs e)
{
try
{
SqlCeRemoteDataAccess rda = new SqlCeRemoteDataAccess();
rda.LocalConnectionString = localString;
rda.InternetUrl = "http://172.18.188.31/test/sqlcesa30.dll";
rda.Push("pcinfo", remoteString, RdaBatchOption.BatchingOn);
MessageBox.Show("同步数据成功");
}
catch (Exception ex)
{
MessageBox.Show("同步数据失败" + ex.ToString());
}
}
private void btn_cancel_Click(object sender, EventArgs e)
{
this.Close();
}
}
}
相关文章推荐
- 利用oracle高级复制功能实现数据同步的问题
- 利用oracle高级复制功能实现数据同步
- 利用oracle高级复制功能实现数据同步的问题
- 利用实现数据同步功能, 已经完成测试,可以实现.
- xml学习(三)---利用xml文件实现数据岛功能(网页显示xml文件中的内容免C#代码操作xml文件)
- 【Struts2】利用JQuery与struts2-json-plugin实现Struts2的Ajax功能并利用JSON传递数据
- 利用复制实现数据同步
- C#利用广播实现群发功能
- SSH开发框架中,实现系统启动加载类,读取数据库常用数据进入内存,利用Spring托管,并完成reload功能
- 利用ajax实现前台javascript同c#后台MVC下的controller层传递数据的方法
- 利用数据库复制技术 实现数据同步更新【转】
- C#学习之利用泛型实现列表功能
- C# WinForm 实现增删改查等功能(Access版) 系列之八-导出数据到Excel
- 利用unison+inotify 实现数据双向实时同步
- C# WinForm 实现增删改查等功能(Access版) 系列之八-导出数据到Excel
- MS-Sqlserver2008使用复制功能实现数据同步
- java翻译到mono C#实现系列(4) 利用CountDownTimer类实现倒计时功能 mono版
- C#实现json格式数据解析功能的方法详解
- C#在winform中实现数据增删改查等功能
- C#利用DataGridView实现数据的快速输入