SqlBulkCopyColumnMappingCollection 类

定义

命名空间:

Microsoft.Data.SqlClient

程序集:

Microsoft.Data.SqlClient.dll

包:

Microsoft.Data.SqlClient v5.2.0

从 CollectionBase 继承的 SqlBulkCopyColumnMapping 对象的集合。

public ref class SqlBulkCopyColumnMappingCollection sealed : System::Collections::CollectionBase

public sealed class SqlBulkCopyColumnMappingCollection : System.Collections.CollectionBase

type SqlBulkCopyColumnMappingCollection = class
    inherit CollectionBase

Public NotInheritable Class SqlBulkCopyColumnMappingCollection
Inherits CollectionBase

继承

CollectionBase

SqlBulkCopyColumnMappingCollection

示例

以下示例将数据从“AdventureWorks”示例数据库中的源表大容量复制到同一个数据库中的目标表。 尽管目标中的列数与源中的列数匹配，但列名称和序号位置不匹配。 SqlBulkCopyColumnMapping将 添加到 对象的 中SqlBulkCopyColumnMappingCollectionSqlBulkCopy，以便为大容量复制创建列映射。

重要

除非已按批量复制示例设置中所述创建了工作表，否则此示例不会运行。 提供此代码是为了演示仅使用 SqlBulkCopy 时的语法。 如果源表和目标表位于同一SQL Server实例中，则使用 Transact-SQL INSERT … SELECT 语句复制数据会更轻松、更快。

using System;
using System.Data;
using Microsoft.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = GetConnectionString();
        // Open a sourceConnection to the AdventureWorks database.
        using (SqlConnection sourceConnection =
                   new SqlConnection(connectionString))
        {
            sourceConnection.Open();

            // Perform an initial count on the destination table.
            SqlCommand commandRowCount = new SqlCommand(
                "SELECT COUNT(*) FROM " +
                "dbo.BulkCopyDemoDifferentColumns;",
                sourceConnection);
            long countStart = System.Convert.ToInt32(
                commandRowCount.ExecuteScalar());
            Console.WriteLine("Starting row count = {0}", countStart);

            // Get data from the source table as a SqlDataReader.
            SqlCommand commandSourceData = new SqlCommand(
                "SELECT ProductID, Name, " +
                "ProductNumber " +
                "FROM Production.Product;", sourceConnection);
            SqlDataReader reader =
                commandSourceData.ExecuteReader();

            // Set up the bulk copy object. 
            using (SqlBulkCopy bulkCopy =
                       new SqlBulkCopy(connectionString))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoDifferentColumns";

                // The column order in the source doesn't match the order 
                // in the destination, so ColumnMappings must be defined.
                bulkCopy.ColumnMappings.Add("ProductID", "ProdID");
                bulkCopy.ColumnMappings.Add("Name", "ProdName");
                bulkCopy.ColumnMappings.Add("ProductNumber", "ProdNum");

                // Write from the source to the destination.
                try
                {
                    bulkCopy.WriteToServer(reader);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
                finally
                {
                    // Close the SqlDataReader. The SqlBulkCopy
                    // object is automatically closed at the end
                    // of the using block.
                    reader.Close();
                }
            }

            // Perform a final count on the destination 
            // table to see how many rows were added.
            long countEnd = System.Convert.ToInt32(
                commandRowCount.ExecuteScalar());
            Console.WriteLine("Ending row count = {0}", countEnd);
            Console.WriteLine("{0} rows were added.", countEnd - countStart);
            Console.WriteLine("Press Enter to finish.");
            Console.ReadLine();
        }
    }

    private static string GetConnectionString()
    // To avoid storing the sourceConnection string in your code, 
    // you can retrieve it from a configuration file. 
    {
        return "Data Source=(local); " +
            " Integrated Security=true;" +
            "Initial Catalog=AdventureWorks;";
    }
}

注解

列映射定义数据源和目标表之间的映射。

如果未定义映射（即 ColumnMappings 集合为空），则根据序号位置隐式映射列。 对于这种方式，源架构和目标架构必须匹配。 否则， InvalidOperationException 将引发 。

ColumnMappings如果集合不为空，则不必指定数据源中存在的每一列。 未由集合映射的那些将被忽略。

可以按名称或序号引用源列和目标列。 可以在同一映射集合中混合按名称和按序号列引用。

属性

Item[Int32]

获取位于指定索引位置的 SqlBulkCopyColumnMapping 对象。

方法

Add(Int32, Int32)	通过使用序号指定源列和目标列，创建一个新的 SqlBulkCopyColumnMapping 并将其添加到集合中。
Add(Int32, String)	通过对源列使用序号和对目标列使用字符串，创建一个新的 SqlBulkCopyColumnMapping 并将其添加到集合中。
Add(SqlBulkCopyColumnMapping)	将指定的映射添加到 SqlBulkCopyColumnMappingCollection 中。
Add(String, Int32)	通过使用列名称描述源列，同时使用序号指定目标列，从而创建一个新的 SqlBulkCopyColumnMapping 并将其添加到集合中。
Add(String, String)	通过使用列名称指定源列和目标列，创建一个新的 SqlBulkCopyColumnMapping 并将其添加到集合中。
Clear()	清除集合的内容。
Contains(SqlBulkCopyColumnMapping)	获取一个值，该值指示集合中是否存在指定的 SqlBulkCopyColumnMapping 对象。
CopyTo(SqlBulkCopyColumnMapping[], Int32)	从特定索引处开始，将 SqlBulkCopyColumnMappingCollection 的元素复制到 SqlBulkCopyColumnMapping 项的数组。
IndexOf(SqlBulkCopyColumnMapping)	获取指定 SqlBulkCopyColumnMapping 对象的索引。
Insert(Int32, SqlBulkCopyColumnMapping)	在指定索引处插入一个新 SqlBulkCopyColumnMapping。
Remove(SqlBulkCopyColumnMapping)	从 SqlBulkCopyColumnMapping 中移除指定的 SqlBulkCopyColumnMappingCollection 元素。
RemoveAt(Int32)	从集合中移除指定索引处的映射。