ADO.NET 批量插入

在.Net1.1中无论是对于批量插入整个DataTable中的所有数据到数据库中，还是进行不同数据源之间的迁移，都不是很方便。而 在.Net2.0中，SQLClient命名空间下增加了几个新类帮助我们通过DataTable或DataReader批量迁移数据。数据源可以来自关 系数据库或者XML文件，甚至WebService返回结果。其中最重要的一个类就是SqlBulkCopy类，使用它可以很方便的帮助我们把数据源的数 据迁移到目标数据库中。

 public class Queue
    {
        public Queue(string content, QueueType type, string officeNumber)
        {
            Content = content;
            Type = type;
            OfficeNumber = officeNumber;
        }

        public Queue(DateTime proccessTime, int internalNumber, string content, QueueType type, string officeNumber)
        {
            ProcessTime = proccessTime;
            InternalNumber = internalNumber;
            Content = content;
            Type = type;
            OfficeNumber = officeNumber;
        }

        /// <summary>
        /// 处理时间
        /// </summary>
        public DateTime ProcessTime { get; set; }
        /// <summary>
        /// 内部编号
        /// </summary>
        public int InternalNumber { get; set; }
        /// <summary>
        /// 内容
        /// </summary>
        public string Content { get; set; }
        /// <summary>
        /// 信箱类型
        /// </summary>
        public QueueType Type { get; set; }
        /// <summary>
        /// 代理人编号
        /// </summary>
        public string OfficeNumber { get; set; }

        /// <summary>
        /// 判断给出的内容字串是否是有效的信件内容；
        /// </summary>
        /// <param name="queueContent"></param>
        /// <param name="officNumber"> </param>
        public static bool Validate(string queueContent, string officNumber)
        {
            return queueContent.Contains(officNumber);
        }
    }

        private DataTable GetTableSchema()
        {
            var dataTable = new DataTable();
            dataTable.Columns.AddRange(new[]
                                           {
                                               new DataColumn("ProcessTime"),
                                               new DataColumn("InternalNumber"),
                                               new DataColumn("Content"),
                                               new DataColumn("Type"),
                                               new DataColumn("OfficeNumber"),
                                           });
            return dataTable;
        }

        public int Add(System.Collections.Generic.List<Domain.Queue> queues)
        {
            int rowCount = 0;
            var dataTable = GetTableSchema();

            foreach (var queue in queues)
            {
                DataRow dataRow = dataTable.NewRow();
                dataRow[0] = queue.ProcessTime;
                dataRow[1] = queue.InternalNumber;
                dataRow[2] = queue.Content;
                dataRow[3] = queue.Type;
                dataRow[4] = queue.OfficeNumber;
                dataTable.Rows.Add(dataRow);
            }
            
            using (var sqlConnection = new SqlConnection(ConnectionString))
            {
                sqlConnection.Open();
                using (var sqlBulkCopy = new SqlBulkCopy(sqlConnection))
                {
                    sqlBulkCopy.DestinationTableName = "History.Queues";
                    sqlBulkCopy.BatchSize = dataTable.Rows.Count;
                    if (sqlBulkCopy.BatchSize != 0)
                    {
                        sqlBulkCopy.WriteToServer(dataTable);
                        rowCount = sqlBulkCopy.BatchSize;
                    }
                }
            }

            return rowCount;
        }

代码分析:

　　var sqlBulkCopy = new SqlBulkCopy(sqlConnection)

先生成SqlBulkCopy 实例，构造函数指定了目标数据库，使用sqlConnection链接创建

　　sqlBulkCopy.WriteToServer(dataTable);

      rowCount = sqlBulkCopy.BatchSize;

　　rowCount  属性指定通知通知事件前处理的数据行数

　　WriteToServer方法就是将数据源拷备到目标数据库。在使用WriteToServer方法之前必须先指定 DestinationTableName属性，也就是目标数据库的表名，