SqlBulkCopy(批量复制)使用方法

SqlBulkCopy提供了一种将数据复制到Sql Server数据库表中高性能的方法。SqlBulkCopy 包含一个方法 WriteToServer，它用来从数据的源复制数据到数据的目的地。 WriteToServer方法可以处理的数据类型有DataRow[]数组，DataTable 和 DataReader。 你可以根据不同的情形使用不同的数据类型。SqlBulkCopy其原理是采用了SQL Server的BCP协议进行数据的批量复制。 ### SqlBulkCopy(批量复制)使用方法 #### 概述 `SqlBulkCopy`是一种用于高效将大量数据复制到SQL Server数据库表中的工具。相比于传统的逐条插入方式，`SqlBulkCopy`能显著提高数据导入的速度。其核心原理是利用了SQL Server内部的BCP（Bulk Copy Program）协议，该协议专门设计用于处理大批量数据的快速传输。 #### 基本概念 - **`SqlBulkCopy`对象**：主要负责数据的批量复制操作。 - **`WriteToServer`方法**：此方法是`SqlBulkCopy`的核心功能之一，用于将数据源中的数据复制到目标数据库表中。 - **支持的数据类型**：`SqlBulkCopy`支持多种数据类型的输入，包括`DataRow[]`数组、`DataTable`和`DataReader`等。 #### 使用场景 根据实际需求选择合适的数据类型作为数据源： 1. **`DataRow[]`数组**：适用于需要处理较小规模数据的情况。 2. **`DataTable`**：当需要对数据进行更多操作（如筛选、排序等）时更为合适。 3. **`DataReader`**：通常用于从数据库查询结果中直接读取数据并进行批量导入。 #### 示例代码解析 ### 示例一：将数据库中的表复制到另一个数据库中的表 此示例展示了如何使用`SqlBulkCopy`将一个数据库中的表复制到另一个数据库中的相同结构的表。 ```csharp using System.Data; using System.Data.SqlClient; using System.Configuration; private void SqlBulkCopyMethod() { try { SqlConnection connectionPub = new SqlConnection(ConfigurationManager.ConnectionStrings["PubsDB"].ConnectionString); using (connectionPub) { SqlCommand commandPub = connectionPub.CreateCommand(); using (commandPub) { commandPub.CommandText = "SELECT * FROM stores"; commandPub.CommandType = System.Data.CommandType.Text; connectionPub.Open(); SqlConnection connectionBulkCopy = new SqlConnection(ConfigurationManager.ConnectionStrings["NorthwindDB"].ConnectionString); using (connectionBulkCopy) { connectionBulkCopy.Open(); SqlDataReader dataReader = commandPub.ExecuteReader(); SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionBulkCopy); using (bulkCopy) { bulkCopy.DestinationTableName = "store"; bulkCopy.WriteToServer(dataReader); } } } } } catch (Exception ex) { throw ex; } } ``` **解析**： - 首先通过配置文件获取两个数据库的连接字符串。 - 创建`SqlConnection`对象并打开连接。 - 使用`SqlCommand`执行查询命令，获取数据源。 - 创建`SqlBulkCopy`对象，并设置目的地表名。 - 调用`WriteToServer`方法完成数据复制。 ### 示例二：将`DataTable`中的数据批量插入到数据库中 该示例演示了如何使用`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`方法将`DataTable`中的数据批量插入数据库。 #### 总结 `SqlBulkCopy`作为一种高效的批量数据复制工具，在处理大数据量的情况下表现优异。通过合理选择数据源类型以及正确设置参数，可以极大地提高数据导入效率。在实际应用中，开发者可以根据具体场景灵活选择使用`DataRow[]`数组、`DataTable`或`DataReader`等数据类型，以实现最优性能。