C# 使用SqlBulkCopy类批量复制大数据

如果你有一个需要在数据库中批量插入大量数据的情况，使用循环插入的方式可能会导致性能问题。为此，.NET Framework提供了SqlBulkCopy类，用于批量复制数据。本文将介绍如何使用C#中的SqlBulkCopy类来批量插入大数据。

什么是SqlBulkCopy类

SqlBulkCopy类是.NET Framework提供的一个用于批量插入数据的类，它可以使用SQL Server提供的快速插入方式。相比于使用标准的INSERT语句，使用SqlBulkCopy类可以显著提高插入大量数据的性能。其内部实现方式是基于ADO.NET连接来完成的，而不是DbCommand。因此，它支持大数据批量复制，速度非常快。

使用SqlBulkCopy类时需要注意的是，数据源必须是MSSQL Server，也就是说，它只能用来复制到MSSQL Server中。此外，MSSQL Server的表结构和数据源必须匹配，如果两者不匹配，将会引发异常。

如何使用SqlBulkCopy类

使用SqlBulkCopy类来进行大数据批量复制有以下几个步骤：

1. 创建SqlBulkCopy对象：在创建SqlBulkCopy对象时，需要指定目标数据库连接和表名。

using (SqlConnection conn = new SqlConnection(connectionString))
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(conn))
{
bulkCopy.DestinationTableName = "TABLE_NAME";
conn.Open();
bulkCopy.WriteToServer(dataTable);
conn.Close();
}
}

SqlBulkCopy类的构造函数接受一个SqlConnection对象作为参数，在这个连接字符串中，你需要指定连接的数据库、用户名和密码。

同时，使用DestinationTableName属性来指定插入的表名。也就是说，SqlBulkCopy要插入的数据必须与这个表的结构一致。

1. 准备数据源： 使用DataTable对象来存储需要插入的数据，可以手动添加行和列，也可以通过从数据库中检索出数据。

DataTable dataTable = new DataTable("TABLE_NAME");
dataTable.Columns.Add("Column1", typeof(int));
dataTable.Columns.Add("Column2", typeof(string));
DataRow row = dataTable.NewRow();
row["Column1"] = 123;
row["Column2"] = "test";
dataTable.Rows.Add(row);

这个DataTable对象的列需要与目标表的列一一对应，DataSet也是可以的，但是不建议使用DataSet操作，因为它在实现上比较复杂。当然，如果你是手动建表并清楚每列的数据类型的话，可以使用纯粹的动态类型。

1. 开启连接，并将数据写入目标数据库：执行WriteToServer方法时，SqlBulkCopy会打开数据库连接，然后将数据源中的数据写入到目标表中。最后，关闭数据库连接。

connection.Open();
bulkCopy.WriteToServer(dataTable);
connection.Close();

注意，SqlBulkCopy对象的WriteToServer方法会将DataTable对象中的每一行数据都插入到目标表格中。如果想要更新同样的表格，请使用SqlDataAdapter对象的更新方法。

总结

通过使用SqlBulkCopy对象，你可以很轻松地实现大数据批量复制。因此，如果你需要将大数据快速复制到目标数据库中，则可以考虑使用此对象。