SqlBulkCopyColumnMapping 類別

定義

命名空間:

Microsoft.Data.SqlClient

組件:

Microsoft.Data.SqlClient.dll

套件:

Microsoft.Data.SqlClient v5.2.0

定義 SqlBulkCopy 執行個體 (instance) 之資料來源中資料行，與執行個體之目的資料表中資料行間的對應。

public ref class SqlBulkCopyColumnMapping sealed

public sealed class SqlBulkCopyColumnMapping

type SqlBulkCopyColumnMapping = class

Public NotInheritable Class SqlBulkCopyColumnMapping

繼承

Object

SqlBulkCopyColumnMapping

範例

下列範例會從 AdventureWorks 範例資料庫中的來源資料表，將資料大量複製到相同資料庫中的目的地資料表。 雖然目的地中的資料行數目符合來源中的資料行數目，但每個目的地資料行位於與其對應來源資料行相同的序數位置中，但資料行名稱不相符。 SqlBulkCopyColumnMapping 物件可用來建立大量複製的資料行對應。

重要

除非您已建立如 大量複製範例安裝程式中所述的工作資料表，否則不會執行此範例。 這個程式碼僅是為了示範使用 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";

                // Set up the column mappings by name.
                SqlBulkCopyColumnMapping mapID =
                    new SqlBulkCopyColumnMapping("ProductID", "ProdID");
                bulkCopy.ColumnMappings.Add(mapID);

                SqlBulkCopyColumnMapping mapName =
                    new SqlBulkCopyColumnMapping("Name", "ProdName");
                bulkCopy.ColumnMappings.Add(mapName);

                SqlBulkCopyColumnMapping mapNumber =
                    new SqlBulkCopyColumnMapping("ProductNumber", "ProdNum");
                bulkCopy.ColumnMappings.Add(mapNumber);

                // 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 ，則不需要指定資料來源中的每個資料行。 集合未對應的專案會被忽略。

您可以依名稱或序數找到來源和目標資料行。 您也可以在相同的對應集合中混用依名稱與序數資料行參考。

建構函式

SqlBulkCopyColumnMapping()	初始化新 SqlBulkCopyColumnMapping 物件的無參數建構函式。
SqlBulkCopyColumnMapping(Int32, Int32)	建立新的資料行對應，使用資料行序數參考來源和目的資料行。
SqlBulkCopyColumnMapping(Int32, String)	建立新的資料行對應，使用資料行序數參考來源資料行和目標資料行的資料行名稱。
SqlBulkCopyColumnMapping(String, Int32)	建立新的資料行對應，使用資料行名稱參考來源資料行和目標資料行的資料行序數。
SqlBulkCopyColumnMapping(String, String)	建立新的資料行對應，使用資料行名稱參考來源和目的資料行。

屬性

DestinationColumn	目的資料庫資料表中正在對應的資料行名稱。
DestinationOrdinal	目的資料表中目的資料行的序數值。
SourceColumn	資料來源中正在對應的資料行名稱。
SourceOrdinal	資料來源內來源資料行的序數位置。