因为要做一个号码归属地查询小功能，因为要导入外部（文本文件）的电话归属地数据，使用的是SqlDataAdapter类，数据不多，只四万有多条，表也只有一个，phoneBook表，使用的是DataTable和SqlDataAdapter，测试了三次导入，平均18秒，但是我觉得太慢了，就百度了下【SQL Server批量导入数据】，发现了SqlBulkCopy这个神器，一秒内导入。

      SqlBulkCopy 这个类用于数据库大批量的数据传递，通常用于新旧数据库之间的更新。关键的一点是，即使表结构不同，也可以通过表字段或者字段位置建立映射关系，将所需的数据导入到目标数据库。

下面代码测试了数据量为一百万条数据，几次测试耗时8秒左右。

/// <summary>
        /// SqlBulkCopy类的使用，批量更新数据
        /// </summary>
        public static void SqlBulkCopyDemo()
        {
            String connStr = ConfigurationManager.ConnectionStrings["connStr"].ToString();
            //从数据库中获得表结构和数据
            DataTable student = new DataTable();
            SqlDataAdapter adapter = new SqlDataAdapter("select * from student", connStr);
            adapter.Fill(student);
            //向表中添加数据
            DataRow dr;
            Random r = new Random();
            Stopwatch st = new Stopwatch();
            for(int i = 0; i<1000000; i++)//一百万条数据
            {//数据表中的列：name，no，age，sex
                dr = student.NewRow();
                dr[0] = "小花" + i;
                dr[1] = 108 + i;
                dr[2] = r.Next(9, 40);//这里是因为数据表中有约束，
                dr[3] = (i % 2 == 0 ? "男" : "女");//这个也是有约束
                student.Rows.Add(dr);
            }
            SqlBulkCopy bulk = new SqlBulkCopy(connStr);
            bulk.DestinationTableName = "student";//设置目标表，这里是数据库中的student表
            bulk.ColumnMappings.Add(0, 0);//建立映射关系
            bulk.ColumnMappings.Add(1, 1);
            bulk.ColumnMappings.Add(2, 2);
            bulk.ColumnMappings.Add(3, 3);
            st.Start();//开始计时
            bulk.WriteToServer(student.GetChanges());
            st.Stop();//结束计时
            Console.WriteLine("数据插入成功，耗时为：" + st.ElapsedMilliseconds + "毫秒");
        }

测试了三次，结果如下：

1、SqlBulkCopy类的构造方法

其中： conn表示一个SqlConnection对象

         connStr表示数据库连接字符串

1. SqlBulkCopy(conn)
2. SqlBulkCopy(connStr)
3. SqlBulkCopy(connStr, SqlBulkCopyOptions copyOptions)
4. SqlBulkCopy(conn, SqlBulkCopyOptions copyOptions, SqlTransaction externalTransaction)

其中还有几个陌生的对象：SqlBulkCopyOptions 和 SqlTransaction

1.1、SqlBulkCopyOptions类

这个类是一个枚举类型：

1.2、SqlTransaction类

这个类是事务类，是个密封类，实现了DbTransaction抽象类

2、SqlBulkCopy类的常用属性

2.1、表中的SqlBulkCopyColumnMappingCollection类型是一个映射集合类，是目标表的列和源表的列的映射关系的集合。

这个类是一个密封类，不能被继承，实现了一个CollectionBase抽象类。

SqlBulkCopyColumnMappingCollection没有提供构造方法，我们也不需要去newat的对象，主要是使用它的几个重载的Add()方法

Add()有五个重载的方法：

• SqlBulkCopyColumnMapping Add(SqlBulkCopyColumnMapping bulkCopyColumnMapping);
• SqlBulkCopyColumnMapping Add(string sourceColumn, string destinationColumn);
• SqlBulkCopyColumnMapping Add(int sourceColumnIndex, string destinationColumn);
• SqlBulkCopyColumnMapping Add(string sourceColumn, int destinationColumnIndex);
• SqlBulkCopyColumnMapping Add(int sourceColumnIndex, int destinationColumnIndex);

其中四个方法是类似的，都是对应的列名或者列的位置。

第一个方法是添加一个已经构建好的SqlBulkCopyColumnMapping对象，

他也有集合常用的方法：

方法名	功能	备注
Clear();	清除集合中的映射关系
Contains(SqlBulkCopyColumnMapping value);	判断是否包含指定映射关系
IndexOf(SqlBulkCopyColumnMapping value);	返回指定映射关系的位置
Remove(SqlBulkCopyColumnMapping value);	移除指定映射关系
RemoveAt(int index);	移除指定位置的映射关系
Insert(int index, SqlBulkCopyColumnMapping value);	在指定位置插入映射关系
CopyTo(SqlBulkCopyColumnMapping[] array, int index);	从指定位置开始将映射关系复制到指定数组中	index指定的集合中的位置， 而不是数组中的角标

3、SqlBulkCopy类的常用方法

• WriteToServer，这个方法重载了四次，功能是将数据写到目的表中。

【上表中的 DataRowState 状态行可以参考这篇博客DataTable的AcceptChanges()方法和DataRow的RowState属性】

这个类还提供了八个异步写的方法，我还没全部理解，就不放上来了。

既然能够有写的操作，那这个类应该类似于流，它还有一个Close()方法，用于关闭 SqlBulkCopy 实例。

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有