码迷,mamicode.com
首页 > 其他好文 > 详细

做ETL的时候用到的数据同步更新代码

时间:2017-04-05 16:23:56      阅读:306      评论:0      收藏:0      [点我收藏+]

标签:时间   tab   com   更新   update   变化   adapter   bsp   als   

这里是用的从一个库同步到另一个库,代码如下

 

        private void IncrementalSyncUpdate(string fromConn, string toConn, Dictionary<string, string> sqlList)
        {
            var sw = new Stopwatch();

            using (var conn = new SqlConnection(fromConn))
            {
                if (conn.State != ConnectionState.Open) conn.Open();

                using (var cmd = new SqlCommand())
                {
                    try
                    {
                        foreach (var item in sqlList)
                        {
                            var sql = item.Value;

                            var tableName = item.Key;

                            sw.Restart();

                            cmd.CommandText = sql;
                            cmd.CommandType = CommandType.Text;
                            cmd.Connection = conn;

                            DataTable dt = new DataTable();

                            SqlDataAdapter sda = new SqlDataAdapter(cmd);

                            sda.Fill(dt);

                            if (dt.Rows.Count == 0) continue;//如果没有新增数据,跳过

                            foreach (DataRow row in dt.Rows)
                            {
                                row.SetModified();
                            }

                            int updateCount = 0;

                            using (var TmpConn = new SqlConnection(toConn))
                            {
                                if (TmpConn.State != ConnectionState.Open) TmpConn.Open();

                                using (var tmpCmd = new SqlCommand())
                                {
                                    tmpCmd.CommandText = "select * from Meb_" + tableName;
                                    tmpCmd.CommandType = CommandType.Text;
                                    tmpCmd.Connection = TmpConn;
                                    SqlDataAdapter tmpSda = new SqlDataAdapter(tmpCmd);

                                    SqlCommandBuilder scb = new SqlCommandBuilder(tmpSda);
                                    tmpSda.UpdateCommand = scb.GetUpdateCommand();
                                    updateCount = tmpSda.Update(dt);

                                }
                            }

                            sw.Stop();

                            Console.WriteLine("增量同步数据更新完成,表名:{0},数据{1}条,耗时{2}秒", tableName, updateCount, sw.Elapsed.TotalSeconds);
                        }
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine("增量同步数据同步更新失败," + e.ToString());
                    }
                }
            }
        }

这个sqllist是一个   Key:表名  Value:查询SQL  ,做增量同步查询的,主要根据时间戳来获取时间。

用SqlAdapter的Update方法来做更新,这里有个问题,在更新的DataTable里面的数据要对DataRow的RowState进行一个设置,如果是未设置,那么Update过后,数据库是没有变化的。

做ETL的时候用到的数据同步更新代码

标签:时间   tab   com   更新   update   变化   adapter   bsp   als   

原文地址:http://www.cnblogs.com/xiaoquangege/p/6669002.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!