本篇文章详细介绍了如何使用SQLBulkCopy类进行大批量数据的高效导入与导出操作，适用于需要快速处理大量数据库记录的场景。
`SqlBulkCopy`提供了一种将大量数据高效复制到SQL Server数据库表中的方法。相比逐条插入的方式，它能显著提高导入速度。其原理是利用了专门用于大批量数据传输的BCP（Bulk Copy Program）协议。
### `SqlBulkCopy`(批量复制)使用说明
#### 概述
`SqlBulkCopy`是一个高效的工具，适用于将大量数据快速地从一个来源复制到SQL Server数据库表中。它特别适合处理大数据集的情况，在这些情况下逐条插入会非常耗时且效率低下。
#### 基本概念
- **`SqlBulkCopy`对象**：用于执行批量复制操作。
- **`WriteToServer`方法**：是主要的接口，用来从数据源将数据写入目标数据库表中。
- **支持的数据类型**：
- `DataRow[]`数组: 对于较小规模的数据集比较适用。
- `DataTable`: 当需要对导入前进行复杂操作（如筛选、排序等）时更为合适。
- `DataReader`: 直接从查询结果读取数据，适合批量插入。
#### 使用场景
根据具体情况选择适当的数据类型作为输入源：
- **`DataRow[]`数组**：适用于处理较小规模的集合。
- **`DataTable`**: 当需要对导入前进行额外操作时使用。
- **`DataReader`: 用于直接从数据库查询结果读取数据，适合批量插入。
#### 示例代码解析
### 示例一
展示如何利用 `SqlBulkCopy` 将一个数据库中的表复制到另一个具有相同结构的表中：
```csharp
using System.Data;
using System.Data.SqlClient;
private void SqlBulkCopyMethod()
{
try
{
SqlConnection connectionPub = new SqlConnection(YourConnectionString);
using (connectionPub)
{
SqlCommand commandPub = connectionPub.CreateCommand();
using (commandPub)
{
commandPub.CommandText = SELECT * FROM stores;
commandPub.CommandType = CommandType.Text;
connectionPub.Open();
SqlConnection connectionBulkCopy = new SqlConnection(AnotherConnectionString);
using (connectionBulkCopy)
{
connectionBulkCopy.Open();
SqlDataReader dataReader = commandPub.ExecuteReader();
SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionBulkCopy);
using (bulkCopy)
{
bulkCopy.DestinationTableName = store;
bulkCopy.WriteToServer(dataReader);
}
}
}
}
}
catch
{
throw;
}
}
```
**解析**
- 获取两个数据库的连接字符串。
- 创建`SqlConnection`对象并打开连接。
- 使用命令执行查询获取数据源。
- 利用 `SqlBulkCopy` 对象设置目标表名，并通过调用 `WriteToServer` 方法完成数据复制。
### 示例二
展示如何使用 `SqlBulkCopy` 将一个DataTable中的内容批量插入到数据库中：
```csharp
private void SqlBulkCopyByDatatable(string connectionString, string TableName, DataTable dt)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(conn, SqlBulkCopyOptions.UseInternalTransaction))
{
try
{
sqlBulkCopy.DestinationTableName = TableName;
for (int i = 0; i < dt.Columns.Count; i++)
{
sqlBulkCopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
}
sqlBulkCopy.WriteToServer(dt);
}
catch
{
// 处理异常情况
}
}
}
}
```
**解析**
- 创建`SqlConnection`对象并打开连接。
- 使用 `SqlBulkCopy` 对象指定目标表名和列映射关系。
- 调用 `WriteToServer` 方法将数据批量插入到数据库中。
#### 总结
使用 `SqlBulkCopy`, 开发者可以高效地处理大数据量的数据导入任务。根据具体情况选择合适的数据类型（如 `DataRow[]`、`DataTable` 或 `DataReader`)，并正确设置参数以实现最佳性能。
5星
