SqlBulkCopy类数据导入(自己测试例子)

 public static readonly string ConnData = "Data Source=192.168.0.100;Initial Catalog=dbname;User ID=sa;Password=123456";

        protected void Page_Load(object sender,EventArgs e)
        {
            if (!IsPostBack)
            {
                DataTable dt = new DataTable();
                dt.Columns.Add("ScheduleKey",typeof(Guid));
                dt.Columns.Add("AdminUserKey",typeof(Guid));
                dt.Columns.Add("ScheduleRuleKey",typeof(Guid));
                dt.Columns.Add("eBayProfileKey",typeof(Guid));
                dt.Columns.Add("LaunchTimeSite",typeof(DateTime));
                dt.Columns.Add("CreationDate",typeof(DateTime));
                for (int i = 0; i < 7000; i++)
                {
                    DaTarow dr = dt.NewRow();
                    dr["ScheduleKey"] = Guid.NewGuid();
                    dr["AdminUserKey"] = Guid.NewGuid();
                    dr["ScheduleRuleKey"] = Guid.NewGuid();
                    dr["eBayProfileKey"] = Guid.NewGuid();
                    dr["LaunchTimeSite"] = DateTime.Now;
                    dr["CreationDate"] = DateTime.Now;
                    dt.Rows.Add(dr);
                }

                sqlBulkcopy(dt);
            }
        }

        #region   批量插入数据到数据库
        DateTime startTime;
        private bool sqlBulkcopy(DataTable dt)
        {

            try
            {
                startTime = DateTime.Now;
                //数据批量导入sqlserver,创建实例     sqlBulkcopyOptions.UseInternalTransaction采用事务   复制失败自动回滚
                System.Data.sqlClient.sqlBulkcopy sqlbulk = new System.Data.sqlClient.sqlBulkcopy(ConnData,sqlBulkcopyOptions.UseInternalTransaction);
                sqlbulk.sqlRowscopied +=
                new sqlRowscopiedEventHandler(OnRowscopied); //订阅复制完成后的方法,参数是 sqlbulk.NotifyAfter的值
                sqlbulk.NotifyAfter = dt.Rows.Count;

                //目标数据库表名
                sqlbulk.DestinationTableName = "pa_ScheduleShadow";
                //数据集字段索引与数据库字段索引映射
                sqlbulk.columnmappings.Add(0,"ScheduleKey");
                sqlbulk.columnmappings.Add(1,"AdminUserKey");
                sqlbulk.columnmappings.Add(2,"ScheduleRuleKey");
                sqlbulk.columnmappings.Add(3,"eBayProfileKey");
                sqlbulk.columnmappings.Add(4,"LaunchTimeSite");
                sqlbulk.columnmappings.Add(5,"CreationDate");
                //导入
                sqlbulk.WritetoServer(dt);
                sqlbulk.Close();
                return true;
            }
            catch (Exception ex)
            {
                throw new Exception(ex.Message);
            }
            finally
            {
                dt.dispose();
            }
        }

        //复制完成后的处理事件        private void OnRowscopied(object sender,sqlRowscopiedEventArgs args)        {            lblCounter.Text += args.Rowscopied.ToString() + " 条记录已导入";            TimeSpan copyTime = DateTime.Now - startTime;            lblCounter.Text += "&nbsp;&nbsp;花费时间:" + copyTime.Seconds.ToString() + "." +            copyTime.Milliseconds.ToString() + " 秒";        }        #endregion