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)	移除集合指定索引處的對應。