同步数据 - 数据库编程

设置每次增长1条数据 listBox1.Items.Add("连接源数据库成功......"); listBox1.Items.Add("连接目标数据库成功......"); listBox1.Items.Add("正在同步... ..."); try { for (int i = 0; i < dttb.Rows.Count; i++)//根据判断条件循环更新数据库中的信息 { /*2015/2/2 调整：不能把菜单全部删除，没有的添加到服务器上去，已存在的过滤掉*/ lastSQL = "select * from " + tbName + " where sCode= '" + dttb.Rows[i][0].ToString().Trim() + "'"; //更新dttb1：一条记录判断是否存在<过滤：新增> /*测试数据库：源库和目标库一致后期调整目标库连接字符串*/ dttb1 = IsOpenDT(lastSQL, strdbPreg); //目标库中存在一条数据取消 if (dttb1 != null && dttb1.Rows.Count > 0) { a = a + 1; listBox1.Items.Add("已过滤" + a.ToString() + "条！"); } else { string valuse = ""; string allcolumName = ""; for (int j = 0; j < dttb1.Columns.Count; j++) { if (j == dttb1.Columns.Count - 1) { allcolumName += dttb1.Columns[j].ColumnName.ToString(); } else { allcolumName += dttb1.Columns[j].ColumnName.ToString() + ","; } } //如果在线库中的时间为空则进行插入操作 for (int j = 0; j < dttb.Columns.Count; j++) { if (j == dttb.Columns.Count - 1) { valuse += "'" + dttb.Rows[i][j].ToString() + "'"; } else { valuse += "'" + dttb.Rows[i][j] + "',"; } } lastSQL = "insert into " + tbName + " (" + allcolumName + ") values (" + valuse + ")"; IsOpen(lastSQL, strdbPreg); b = b + 1; listBox1.Items.Add("已插入" + b.ToString() + "条！"); } /*2015/2/2 调整：新增[进度条]追加显示加载信息*/ progressBar1.Value += progressBar1.Step;//让进度条增加一次 } } catch (Exception ex) { fslog(ex); } if ((a + b) > 0) { listBox1.Items.Add(tbName + "成功过滤" + a + "条数据条数据,成功插入" + b + "条数据！"); listBox1.Items.Add(tbName + "同步数据成功！"); //tureOfalse = false; preg.Abort();//线程执行标识:同步成功关闭线程 //UPINlog(a, b, tbName); } else { listBox1.Items.Add(""); } }

12，此段代码相当于sqlhelper.cs功能【连接数据库】：

/// 
        /// 执行SQL语句
        /// 
        /// SQL语句
        /// bool值，成功返回true，失败返回false
        public static bool ExecuteSql(string SQLString)
        {
            bool isSucc = false;
            using (SqlConnection connection = new SqlConnection("Data Source=192.168.44.161;Initial Catalog=NewHmFrameWork_QHS_SQ_QingHai;Persist Security Info=True;User ID=sa;Password=jqkj123$%^;"))
            {
                connection.Open();

                using (SqlTransaction trans = connection.BeginTransaction())
                {
                    using (SqlCommand cmd = new SqlCommand(SQLString, connection))
                    {

                        cmd.Transaction = trans;
                        int rows = cmd.ExecuteNonQuery();
                        trans.Commit();
                        isSucc = true;


                    }
                }

            }
            return isSucc;
        }

13，初始化托盘图标

/// 
        /// 初始化托盘图标
        /// 
        public void InitTrayIcon()
        {

            // 设置托盘图标的菜单
            trayIcon.Icon = mNetTrayIcon;
            trayIcon.Text = "单击最大化程序";
            trayIcon.Visible = true;
            trayIcon.Click += new EventHandler(trayIcon_Click);
            MenuItem[] mnuItems = new MenuItem[4];
            mnuItems[0] = new MenuItem();
            mnuItems[0].Text = "显示";
            mnuItems[0].Click += new EventHandler(Item0_Click);

            mnuItems[1] = new MenuItem();
            mnuItems[1].Text = "隐藏";
            mnuItems[1].Click += new EventHandler(Item1_Click);

            mnuItems[2] = new MenuItem("-");

            mnuItems[3] = new MenuItem();
            mnuItems[3].Text = "退出程序";
            mnuItems[3].Click += new EventHandler(Item3_Click);
            trayIcon.ContextMenu = new ContextMenu(mnuItems);
        }

14，显示窗体，隐藏窗体，退出事件，点击托盘图标，单击X退出程序，

/// 
        /// 显示窗体
        /// 
        /// 
        /// 
        void Item0_Click(object sender, EventArgs e)
        {
            this.Show();

        }

        /// 
        /// 隐藏窗体
        /// 
        /// 
        /// 
        void Item1_Click(object sender, EventArgs e)
        {
            this.Hide();
            this.trayIcon.ShowBalloonTip(5, "提示", "单击最大化程序", ToolTipIcon.Info);
        }

        /// 
        /// 退出事件
        /// 
        /// 
        /// 
        void Item3_Click(object sender, EventArgs e)
        {

            preg.Abort();
            Application.Exit();
        }

        /// 
        /// 点击托盘图标
        /// 
        /// 
        /// 
        void trayIcon_Click(object sender, EventArgs e)
        {
            this.Visible = true;
            this.WindowState = FormWindowState.Maximized;

        }
        /// 
        /// 单击X退出程序
        /// 
        /// 
        /// 
        private void form_Closing(object sender, FormClosingEventArgs e)
        {
            if (one == false)
            {
                DialogResult dia = MessageBox.Show("是否真的退出程序！", " ", MessageBoxButtons.OKCancel);
                if (dia == DialogResult.Cancel)
                {
                    e.Cancel = true;
                    this.Show();
                    this.trayIcon.Visible = true;
                }
                if (dia == DialogResult.OK)
                {
                    one = true;
                    /*2015/2/2 调整：退出[未同步时，直接退出]*/
                    preg = new Thread(new ThreadStart(PREG));
                    preg.Start();
                    preg.Abort();
                    Application.Exit();
                }
            }
        }

同步数据(四)