Sdílet prostřednictvím


SqlBulkCopyColumnMapping Třída

Definice

Definuje mapování mezi sloupcem ve SqlBulkCopy zdroji dat instance a sloupcem v cílové tabulce instance.

public ref class SqlBulkCopyColumnMapping sealed
public sealed class SqlBulkCopyColumnMapping
type SqlBulkCopyColumnMapping = class
Public NotInheritable Class SqlBulkCopyColumnMapping
Dědičnost
SqlBulkCopyColumnMapping

Příklady

Následující příklad hromadně zkopíruje data ze zdrojové tabulky v ukázkové databázi AdventureWorks do cílové tabulky ve stejné databázi. I když počet sloupců v cíli odpovídá počtu sloupců ve zdroji a každý cílový sloupec je ve stejné řadové pozici jako odpovídající zdrojový sloupec, názvy sloupců se neshodují. SqlBulkCopyColumnMapping objekty se používají k vytvoření mapy sloupců pro hromadné kopírování.

Důležité

Tato ukázka se nespustí, pokud jste nevytvořili pracovní tabulky, jak je popsáno v příkladu hromadného kopírování. Tento kód je k dispozici k předvedení syntaxe pouze pro použití SqlBulkCopy . Pokud jsou zdrojová a cílová tabulka ve stejné SQL Server instanci, je jednodušší a rychlejší zkopírovat data pomocí příkazu Jazyka Transact-SQLINSERT … 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 mapMumber =
                    new SqlBulkCopyColumnMapping("ProductNumber", "ProdNum");
                bulkCopy.ColumnMappings.Add(mapMumber);

                // 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;";
    }
}

Poznámky

Mapování sloupců definují mapování mezi zdrojem dat a cílovou tabulkou.

Pokud mapování nejsou definovaná – to znamená, ColumnMappings že kolekce je prázdná – sloupce se mapují implicitně na základě řadové pozice. Aby to fungovalo, musí se zdrojová a cílová schémata shodovat. Pokud to neudělají, InvalidOperationException bude vyhozena.

ColumnMappings Pokud kolekce není prázdná, není nutné zadat každý sloupec, který je ve zdroji dat. Ty, které kolekce nemapuje, se ignorují.

Na zdrojový a cílový sloupec můžete odkazovat podle názvu nebo pořadové řady. Ve stejné kolekci mapování můžete také kombinovat odkazy na sloupce podle názvu a podle řad.

Konstruktory

SqlBulkCopyColumnMapping()

Konstruktor bez parametrů, který inicializuje nový SqlBulkCopyColumnMapping objekt.

SqlBulkCopyColumnMapping(Int32, Int32)

Vytvoří nové mapování sloupců pomocí řad sloupců, které odkazují na zdrojový a cílový sloupec.

SqlBulkCopyColumnMapping(Int32, String)

Vytvoří nové mapování sloupců pomocí řad sloupců odkazující na zdrojový sloupec a názvu sloupce pro cílový sloupec.

SqlBulkCopyColumnMapping(String, Int32)

Vytvoří nové mapování sloupců s použitím názvu sloupce odkazujícího na zdrojový sloupec a ordinálu sloupce pro cílový sloupec.

SqlBulkCopyColumnMapping(String, String)

Vytvoří nové mapování sloupců pomocí názvů sloupců, které odkazují na zdrojový a cílový sloupec.

Vlastnosti

DestinationColumn

Název sloupce mapovaného v cílové tabulce databáze

DestinationOrdinal

Ordinální hodnota cílového sloupce v cílové tabulce.

SourceColumn

Název sloupce mapovaného ve zdroji dat

SourceOrdinal

Řadová pozice zdrojového sloupce v rámci zdroje dat

Platí pro