SQLBulkCopy详解

1. 引言

在现代的数据管理中，数据的导入和导出是一个非常重要的环节。如果数据库中的数据需要通过批量方式从一个表格或文件导入到另一个表格中，传统的一个个插入操作效率较低。而SQLBulkCopy类则可以提供高效的数据批量导入功能。本文将详细介绍SQLBulkCopy的使用方法和相关技巧。

2. 什么是SQLBulkCopy

SQLBulkCopy是.NET框架中的一个类，它提供了一种高效的方式将数据批量导入到SQL Server数据库中。它可以将数据源中的数据迅速复制到数据库表中，提高了数据导入的效率。SQLBulkCopy减少了频繁的数据库交互操作，通过批量处理一次性导入大量数据，从而提高了系统的性能。

3. SQLBulkCopy的使用方法

3.1 创建SQLBulkCopy对象

在使用SQLBulkCopy之前，需要创建一个SqlConnection对象和SQLBulkCopy对象。

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
    {
        // 设置相关属性
    }
}

3.2 设置相关属性

在创建SQLBulkCopy对象后，可以设置一些相关属性来控制数据的导入行为。常用的属性包括：

DestinationTableName：指定目标表的名称。
BatchSize：设置每次批量写入的行数，默认为0，表示为多少行写入一次。
BulkCopyTimeout：设置超时时间（以秒为单位）。
NotifyAfter：指定当每批次写入的行数达到指定值时，触发SqlRowsCopied事件。

bulkCopy.DestinationTableName = "dbo.MyTable";
bulkCopy.BatchSize = 1000;
bulkCopy.BulkCopyTimeout = 60;
bulkCopy.NotifyAfter = 1000;
bulkCopy.SqlRowsCopied += new SqlRowsCopiedEventHandler(bulkCopy_SqlRowsCopied);

3.3 指定数据源

SQLBulkCopy支持多种数据源，包括DataTable、SqlDataReader、IDataReader和DataView等。通过设置DataSource属性指定数据源。

bulkCopy.DestinationTableName = "dbo.MyTable";
bulkCopy.BatchSize = 1000;
bulkCopy.BulkCopyTimeout = 60;
bulkCopy.NotifyAfter = 1000;
bulkCopy.SqlRowsCopied += new SqlRowsCopiedEventHandler(bulkCopy_SqlRowsCopied);

bulkCopy.WriteToServer(dataTable);

3.4 执行数据导入

设置好以上属性后，可以通过调用WriteToServer方法来执行数据导入操作。可以传入DataTable、SqlDataReader、IDataReader和DataView等数据源。

bulkCopy.WriteToServer(dataTable);

4. 使用示例

下面是一个使用SQLBulkCopy插入大量数据的示例：

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
    {
        bulkCopy.DestinationTableName = "dbo.Employee";
        bulkCopy.BatchSize = 1000;
        bulkCopy.BulkCopyTimeout = 60;
        bulkCopy.NotifyAfter = 1000;
        bulkCopy.SqlRowsCopied += new SqlRowsCopiedEventHandler(bulkCopy_SqlRowsCopied);

        bulkCopy.ColumnMappings.Add("EmployeeID", "EmployeeID");
        bulkCopy.ColumnMappings.Add("FirstName", "FirstName");
        bulkCopy.ColumnMappings.Add("LastName", "LastName");
        bulkCopy.ColumnMappings.Add("Title", "Title");
        bulkCopy.ColumnMappings.Add("BirthDate", "BirthDate");
        bulkCopy.ColumnMappings.Add("HireDate", "HireDate");

        DataTable dataTable = new DataTable();
        dataTable.Columns.Add("EmployeeID", typeof(int));
        dataTable.Columns.Add("FirstName", typeof(string));
        dataTable.Columns.Add("LastName", typeof(string));
        dataTable.Columns.Add("Title", typeof(string));
        dataTable.Columns.Add("BirthDate", typeof(DateTime));
        dataTable.Columns.Add("HireDate", typeof(DateTime));

        for (int i = 0; i < 100000; i++)
        {
            DataRow row = dataTable.NewRow();
            row["EmployeeID"] = i + 1;
            row["FirstName"] = "John" + i;
            row["LastName"] = "Doe" + i;
            row["Title"] = "Developer";
            row["BirthDate"] = new DateTime(1990, 1, 1);
            row["HireDate"] = DateTime.Now;
            dataTable.Rows.Add(row);
        }

        bulkCopy.WriteToServer(dataTable);
    }
}

static void bulkCopy_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
    Console.WriteLine("Copied {0} rows.", e.RowsCopied);
}

运行以上代码后，将会向dbo.Employee表中插入10万条数据，输出每次导入的行数。