SqlBulkCopyColumnMappingCollection Klasse

Definition

Namespace:

System.Data.SqlClient

Assembly:

System.Data.dll

Eine Auflistung von SqlBulkCopyColumnMapping-Objekten, die von CollectionBase erbt.

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

Vererbung

Object

CollectionBase

SqlBulkCopyColumnMappingCollection

Beispiele

Im folgenden Beispiel werden Daten aus einer Quelltabelle in der Beispieldatenbank AdventureWorks in eine Zieltabelle derselben Datenbank massenkopiert. Obwohl die Anzahl der Spalten im Ziel mit der Anzahl der Spalten in der Quelle übereinstimmt, stimmen die Spaltennamen und Ordnungspositionen nicht überein. SqlBulkCopyColumnMapping werden für SqlBulkCopyColumnMappingCollection das SqlBulkCopy -Objekt hinzugefügt, um eine Spaltenzuordnung für den Massenkopiervorgang zu erstellen.

Wichtig

Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen zuvor wie unter Massenkopierbeispiel-Einrichtung beschrieben erstellt haben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich quell- und zieltabellen im gleichen SQL Server instance befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT ... SELECT zum Kopieren der Daten zu verwenden.

using System.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;";
    }
}

Imports System.Data.SqlClient

Module Module1
    Sub Main()
        Dim connectionString As String = GetConnectionString()

        ' Open a connection to the AdventureWorks database.
        Using sourceConnection As SqlConnection = _
           New SqlConnection(connectionString)
            sourceConnection.Open()

            ' Perform an initial count on the destination table.
            Dim commandRowCount As New SqlCommand( _
            "SELECT COUNT(*) FROM dbo.BulkCopyDemoDifferentColumns;", _
                sourceConnection)
            Dim countStart As Long = _
               System.Convert.ToInt32(commandRowCount.ExecuteScalar())
            Console.WriteLine("Starting row count = {0}", countStart)

            ' Get data from the source table as a SqlDataReader.
            Dim commandSourceData As SqlCommand = New SqlCommand( _
               "SELECT ProductID, Name, ProductNumber " & _
               "FROM Production.Product;", sourceConnection)
            Dim reader As SqlDataReader = commandSourceData.ExecuteReader

            ' Set up the bulk copy object.
            Using bulkCopy As SqlBulkCopy = 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 ex As Exception
                    Console.WriteLine(ex.Message)

                Finally
                    ' Close the SqlDataReader. The SqlBulkCopy
                    ' object is automatically closed at the end
                    ' of the Using block.
                    reader.Close()
                End Try
            End Using

            ' Perform a final count on the destination table
            ' to see how many rows were added.
            Dim countEnd As Long = _
                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()
        End Using
    End Sub

    Private Function GetConnectionString() As String
        ' 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;"
    End Function
End Module

Hinweise

Spaltenzuordnungen definieren die Zuordnung zwischen Datenquelle und Zieltabelle.

Wenn Zuordnungen nicht definiert sind , d. h. die ColumnMappings Auflistung leer ist, werden die Spalten implizit basierend auf der Ordnungsposition zugeordnet. Damit dies funktioniert, müssen Quell- und Zielschema übereinstimmen. Wenn sie dies nicht tun, wird ein InvalidOperationException ausgelöst.

Wenn die ColumnMappings Auflistung nicht leer ist, muss nicht jede Spalte in der Datenquelle angegeben werden. Diejenigen, die nicht von der Auflistung zugeordnet sind, werden ignoriert.

Sie können auf Quell- und Zielspalten über den Namen oder die Ordnungszahl verweisen. Sie können namens- und ordinale Spaltenverweise in derselben Zuordnungsauflistung kombinieren.

Eigenschaften

Capacity	Ruft die Anzahl der Elemente ab, die die CollectionBase enthalten kann, oder legt diese fest. (Geerbt von CollectionBase)
Count	Ruft die Anzahl der in der CollectionBase-Instanz enthaltenen Elemente ab. Diese Eigenschaft kann nicht überschrieben werden. (Geerbt von CollectionBase)
InnerList	Ruft eine ArrayList mit der Liste der Elemente in der CollectionBase-Instanz ab. (Geerbt von CollectionBase)
Item[Int32]	Ruft das SqlBulkCopyColumnMapping-Objekt am angegebenen Index ab.
List	Ruft eine IList mit der Liste der Elemente in der CollectionBase-Instanz ab. (Geerbt von CollectionBase)

Methoden

Add(Int32, Int32)	Erstellt ein neues SqlBulkCopyColumnMapping und fügt es der Auflistung hinzu, wobei die Quell- und Zielspalten mithilfe von Ordnungszahlen definiert werden.
Add(Int32, String)	Erstellt ein neues SqlBulkCopyColumnMapping und fügt es der Auflistung hinzu, wobei die Quellspalten mithilfe von Ordnungszahlen und die Zielspalten mithilfe von Zeichenfolgen definiert werden.
Add(SqlBulkCopyColumnMapping)	Fügt der SqlBulkCopyColumnMappingCollection die angegebene Zuordnung hinzu.
Add(String, Int32)	Erstellt ein neues SqlBulkCopyColumnMapping und fügt es der Auflistung hinzu, wobei die Quellspalte mithilfe eines Spaltennamens und die Zielspalte mithilfe einer Ordnungszahl definiert werden.
Add(String, String)	Erstellt ein neues SqlBulkCopyColumnMapping und fügt es der Auflistung hinzu, wobei die die Quell- und die Zielspalte mithilfe von Spaltennamen definiert werden.
Clear()	Löscht den Inhalt der Auflistung.
Contains(SqlBulkCopyColumnMapping)	Ruft einen Wert ab, der angibt, ob ein bestimmtes SqlBulkCopyColumnMapping-Objekt in der Auflistung vorhanden ist.
CopyTo(SqlBulkCopyColumnMapping[], Int32)	Kopiert die Elemente aus SqlBulkCopyColumnMappingCollection in ein Array von SqlBulkCopyColumnMapping-Elementen, beginnend bei einem bestimmten Index.
Equals(Object)	Bestimmt, ob das angegebene Objekt gleich dem aktuellen Objekt ist. (Geerbt von Object)
GetEnumerator()	Gibt einen Enumerator zurück, der die CollectionBase durchläuft. (Geerbt von CollectionBase)
GetHashCode()	Fungiert als Standardhashfunktion. (Geerbt von Object)
GetType()	Ruft den Type der aktuellen Instanz ab. (Geerbt von Object)
IndexOf(SqlBulkCopyColumnMapping)	Ruft den Index des angegebenen SqlBulkCopyColumnMapping-Objekts ab.
Insert(Int32, SqlBulkCopyColumnMapping)	Fügen Sie am angegebenen Index eine neue SqlBulkCopyColumnMapping ein.
MemberwiseClone()	Erstellt eine flache Kopie des aktuellen Object. (Geerbt von Object)
OnClear()	Führt beim Löschen des Inhalts der CollectionBase-Instanz zusätzliche benutzerdefinierte Prozesse aus. (Geerbt von CollectionBase)
OnClearComplete()	Führt nach dem Löschen des Inhalts der CollectionBase-Instanz zusätzliche benutzerdefinierte Prozesse aus. (Geerbt von CollectionBase)
OnInsert(Int32, Object)	Führt zusätzliche benutzerdefinierte Prozesse vor dem Einfügen eines neuen Elements in die CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnInsertComplete(Int32, Object)	Führt zusätzliche benutzerdefinierte Prozesse nach dem Einfügen eines neuen Elements in die CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnRemove(Int32, Object)	Führt zusätzliche benutzerdefinierte Prozesse beim Entfernen eines Elements aus der CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnRemoveComplete(Int32, Object)	Führt zusätzliche benutzerdefinierte Prozesse nach dem Entfernen eines Elements aus der CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnSet(Int32, Object, Object)	Führt zusätzliche benutzerdefinierte Prozesse vor dem Festlegen eines Werts in der CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnSetComplete(Int32, Object, Object)	Führt zusätzliche benutzerdefinierte Prozesse nach dem Festlegen eines Werts in der CollectionBase-Instanz aus. (Geerbt von CollectionBase)
OnValidate(Object)	Führt zusätzliche benutzerdefinierte Prozesse beim Validieren eines Werts aus. (Geerbt von CollectionBase)
Remove(SqlBulkCopyColumnMapping)	Entfernt das angegebene SqlBulkCopyColumnMapping aus SqlBulkCopyColumnMappingCollection.
RemoveAt(Int32)	Entfernt am angegebenen Index die Zuordnung aus der Auflistung.
ToString()	Gibt eine Zeichenfolge zurück, die das aktuelle Objekt darstellt. (Geerbt von Object)

Explizite Schnittstellenimplementierungen

ICollection.CopyTo(Array, Int32)	Kopiert die gesamte CollectionBase-Instanz in ein kompatibles eindimensionales Array, beginnend am angegebenen Index des Zielarrays. (Geerbt von CollectionBase)
ICollection.IsSynchronized	Ruft einen Wert ab, der angibt, ob der Zugriff auf die CollectionBase synchronisiert (threadsicher) ist. (Geerbt von CollectionBase)
ICollection.SyncRoot	Ruft ein Objekt ab, mit dem der Zugriff auf CollectionBase synchronisiert werden kann. (Geerbt von CollectionBase)
IList.Add(Object)	Fügt am Ende der CollectionBase ein Objekt hinzu. (Geerbt von CollectionBase)
IList.Contains(Object)	Ermittelt, ob CollectionBase ein bestimmtes Element enthält. (Geerbt von CollectionBase)
IList.IndexOf(Object)	Sucht nach dem angegebenen Object und gibt den nullbasierten Index des ersten Vorkommens innerhalb der gesamten CollectionBase zurück. (Geerbt von CollectionBase)
IList.Insert(Int32, Object)	Fügt am angegebenen Index ein Element in die CollectionBase ein. (Geerbt von CollectionBase)
IList.IsFixedSize	Ruft einen Wert ab, der angibt, ob das CollectionBase eine feste Größe aufweist. (Geerbt von CollectionBase)
IList.IsReadOnly	Ruft einen Wert ab, der angibt, ob das CollectionBase schreibgeschützt ist. (Geerbt von CollectionBase)
IList.Item[Int32]	Ruft das Element am angegebenen Index ab oder legt dieses fest. (Geerbt von CollectionBase)
IList.Remove(Object)	Entfernt das erste Vorkommen eines angegebenen Objekts aus der CollectionBase. (Geerbt von CollectionBase)

Erweiterungsmethoden

Cast<TResult>(IEnumerable)	Wandelt die Elemente eines IEnumerable in den angegebenen Typ um
OfType<TResult>(IEnumerable)	Filtert die Elemente eines IEnumerable anhand eines angegebenen Typs
AsParallel(IEnumerable)	Ermöglicht die Parallelisierung einer Abfrage.
AsQueryable(IEnumerable)	Konvertiert einen IEnumerable in einen IQueryable.

Weitere Informationen

• Massenkopiervorgänge in SQL Server
• Übersicht über ADO.NET