利用实现数据同步功能, 已经完成测试,可以实现.
2007-06-07 16:56
645 查看
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.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();
}
}
}
相关文章推荐
- 【原创】SSH开发框架中,实现系统启动加载类,读取数据库常用数据进入内存,利用Spring托管,并完成reload功能
- 利用oracle高级复制功能实现数据同步
- 利用C#实现数据同步功能
- 利用oracle高级复制功能实现数据同步的问题
- SSH开发框架中,实现系统启动加载类,读取数据库常用数据进入内存,利用Spring托管,并完成reload功能
- 利用oracle高级复制功能实现数据同步的问题
- xml学习(三)---利用xml文件实现数据岛功能(网页显示xml文件中的内容免C#代码操作xml文件)
- 利用IOS提供的tclsh脚本功能实现快速测试
- 用C#实现实现简单的 Ping 的功能,用于测试网络是否已经联通
- 利用脚本实现mysql主库到备库数据同步(每五分钟同步一次增量)
- 字符串处理是许多程序中非常重要的一部分,它们可以用于文本显示,数据表示,查找键和很多目的.在Unix下,用户可以使用正则表达式的强健功能实现这些 目的,从Java1.4起,Java核心API就引入了java.util.regex程序包,它是一种有价值的基础
- TabLayout+ViewPager自定义view实现图文混排微信选项卡框架和联动切换同步改变数据功能
- 利用数据库复制技术 实现数据同步更新
- 利用JQuery方便实现基于Ajax的数据查询、排序和分页功能
- Oracle利用数据伪列实现分页功能
- ajax方式实现注册功能(提交数据到后台数据库完成交互)
- 完成一个学生管理程序,使用学号作为键添加5个学生对象,并可以将全部信息保存在文件中,可以实现对学生信息的学号查找,输出全部学生信息的功能。
- 利用python测试mongodb副本集数据同步延迟
- 利用数据库复制技术实现数据同步更新_SQL SERVER
- 利用java的反射原理实现数据注入功能