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

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

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

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

            </span><span>string </span><span>line = _Reader.ReadLine();
            
            </span><span>if </span><span>(line != </span><span>null</span><span>)
            {
                _CurrentQueryItem = GetRawData(line);
                _Count&#43;&#43;;

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

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

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

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

        </span><span>public void </span><span>Dispose()
        {
            </span><span>if </span><span>(_Reader != </span><span>null</span><span>)
                _Reader.Close();
        }</span>