文件名称:
my sql与sql server实时同步源码，自定义设置同步时间
开发工具:
文件大小: 358kb
下载次数: 0
上传时间: 2014-04-01
详细说明： using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Windows.Forms; using System.Data.SqlClient; using System.Text; using MySql.Data; using MySql.Data.MySqlClient; //本程序的功能是实时从mysql中读取一条记录中的一个字段，插入到sqlserver 中，经过长时间的运行，基本无错了， 而这数据同步，目前没有实时性强的软件，至少1分钟，太久了，自己写了一个， //可以自己设置同步时间，字符连接串等，给了源码，而且对程序进行了很多优化 容错性很强，懂点程序的 就可以直接修改源码 就可以用了。由于没有时间按做界面，只能自己修改了，不过已经很稳定了，为了给大家提供点方便，免得还去查大量的资料。 namespace tool { public partial class Form1 : Form { public string mysql_Conn = "Database='cmccbbs';Data Source='211.139.22.124';UserId='cmcc';Password='CMCC2014cmcc2014';charset='utf8';pooling=true"; public string mysql_sql = "select max(id) from pre_sms_tempsend"; // public string sql_server_Conn = "Data Source=lei; DataBase=test; User=sa;PWD=123456"; 211.222.229.124 public string id, phone, verify, last_id; SqlConnection my_sql_con; MySqlConnection con; MySqlCommand cmd; DataSet ds; public string sql_server_Conn = "Data Source=222.85.144.112,14444; DataBase=DB_CustomSMS; User=sms;PWD=sms2014"; // public string sql_sql = "select max(id) from pre_sms_tempsend"; MySqlDataAdapter md; public int ii = 0; public Form1() { InitializeComponent(); timer1.Interval = 1000; //连接mysql con = new MySql.Data.MySqlClient.MySqlConnection(mysql_Conn); con.Open(); cmd = new MySqlCommand("select * from pre_sms_tempsend order by id desc limit 1", con); cmd.Connection = con; md = new MySqlDataAdapter(); ds = new DataSet(); //这样做避免一直new，导致内存泄露 } private void button1_Click(object sender, EventArgs e) { if (button1.Text == "start") { timer1.Enabled = true; button1.Text = "stop"; } else { timer1.Enabled = false; button1.Text = "start"; } } private void timer1_Tick(object sender, EventArgs e) { try { // //设置一个判断，当此次和上次产生的严重 if (con.State != ConnectionState.Open) { con.Open(); } md.SelectCommand = cmd; md.Fill(ds, "pre_sms_tempsend"); foreach (DataRow testRow in ds.Tables["pre_sms_tempsend"].Rows) { id = testRow["id"].ToString(); phone = testRow["mobile"].ToString(); verify = testRow["content"].ToString(); } if (con.State != ConnectionState.Closed) { con.Close(); } if (id != last_id) { //初始化sql 连接 my_sql_con = new SqlConnection(sql_server_Conn); my_sql_con.Open(); SqlCommand sqlcom = new SqlCommand("insert into oa_smsend( Mobile,Content) values('" + phone + "','" + verify + "') ", this.my_sql_con); sqlcom.ExecuteNonQuery(); last_id = id; my_sql_con.Close(); } } catch (Exception ex) { throw ex ; } } } } ...展开收缩
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
