SqlBulkCopy快速插入数据到SqlServer数据库

using (SqlBulkCopy bc = new SqlBulkCopy(sqlConn, SqlBulkCopyOptions.TableLock | SqlBulkCopyOptions.UseInternalTransaction, null))
{
 bc.BulkCopyTimeout = 10 * 60;
 bc.BatchSize = 10000;
 bc.DestinationTableName = "dbo.Destination";
 bc.WriteToServer(reader); //reader 是一个继承自IDataReader的类的实例
}

//返回记录的列数
 public int FieldCount 
 {
 get { return 3; }
 }

 //读记录，此方法会被自动调用
 public bool Read()
 {
 if (_Reader == null)
 _Reader = new StreamReader(_FilePath);

 string line = _Reader.ReadLine();
 
 if (line != null)
 {
 _CurrentQueryItem = GetRawData(line);
 _Count++;

 while (_CurrentQueryItem == null)//如果读出的是不满足条件的记录，则读下一条记录
 {
 Read();
 }
 return true;
 } 
 return false;
 }

 //返回一条记录中第i 列（项）的值，此方法会被自动调用
 //SqlBulkCopy内部应该有一个循环，从0到FieldCount -1 ，再调用GetValue(int i)这个方法。我猜的。。
 public object GetValue(int i)
 {
 if (_CurrentQueryItem == null)
 return null;

 switch (i)
 {
 //如果数据库中表的第一列是自增字段，则会忽略第一列，也就是说此方法被调用时，i只会从1开始，所以不需要case 0的情况。估计.net内部去取目的表的schema，自动判断哪些列是需要从外部导入的。有空再研究这个问题
 case 0:
 return _CurrentQueryItem.Item1;
 case 1:
 return _CurrentQueryItem.Item2;
 case 2:
 return _CurrentQueryItem.Item3;
 default:
 throw new IndexOutOfRangeException();
 }
 }

 //释放资源
 public void Close()
 {
 Dispose();
 }

 public void Dispose()
 {
 if (_Reader != null)
 _Reader.Close();
 }