SqlBulkCopyColumnMappingCollection Класс

Определение

Пространство имен:

System.Data.SqlClient

Сборка:

System.Data.SqlClient.dll

Пакет:

System.Data.SqlClient v4.8.6

Коллекция объектов SqlBulkCopyColumnMapping, наследующих от CollectionBase.

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

Наследование

Object

CollectionBase

SqlBulkCopyColumnMappingCollection

Примеры

В следующем примере выполняется массовое копирование данных из исходной таблицы в примере базы данных AdventureWorks в целевую таблицу в той же базе данных. Хотя число столбцов в назначении совпадает с количеством столбцов в источнике, имена столбцов и порядковые позиции не совпадают. SqlBulkCopyColumnMapping добавляются в SqlBulkCopyColumnMappingCollection для объекта , SqlBulkCopy чтобы создать карту столбцов для массового копирования.

Важно!

Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе Пример установки массового копирования. Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходная и целевая таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT ... SELECT для копирования данных.

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

Комментарии

Сопоставления столбцов определяют сопоставление между источником данных и целевой таблицей.

Если сопоставления не определены ( то есть коллекция пуста), ColumnMappings столбцы сопоставляются неявно на основе порядкового положения. При этом исходная и целевая схемы должны совпадать. В противном случае InvalidOperationException создается исключение .

ColumnMappings Если коллекция не пуста, необходимо указывать не все столбцы, присутствующие в источнике данных. Элементы, не сопоставленные с коллекцией, игнорируются.

Обращаться к исходным и целевым столбцам можно по имени или порядковому номеру. В одной коллекции сопоставлений можно сочетать ссылки на столбцы по имени и порядковый номер.

Свойства

Capacity	Возвращает или задает число элементов, которое может содержать список CollectionBase. (Унаследовано от CollectionBase)
Count	Возвращает количество элементов, содержащихся в экземпляре CollectionBase. Это свойство нельзя переопределить. (Унаследовано от CollectionBase)
InnerList	Возвращает объект ArrayList, в котором хранится список элементов экземпляра класса CollectionBase. (Унаследовано от CollectionBase)
Item[Int32]	Возвращает объект SqlBulkCopyColumnMapping по указанному индексу.
List	Возвращает объект IList, в котором хранится список элементов экземпляра класса CollectionBase. (Унаследовано от CollectionBase)

Методы

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 начиная с определенного индекса.
Equals(Object)	Определяет, равен ли указанный объект текущему объекту. (Унаследовано от Object)
GetEnumerator()	Возвращает перечислитель, перебирающий элементы экземпляра класса CollectionBase. (Унаследовано от CollectionBase)
GetHashCode()	Служит хэш-функцией по умолчанию. (Унаследовано от Object)
GetType()	Возвращает объект Type для текущего экземпляра. (Унаследовано от Object)
IndexOf(SqlBulkCopyColumnMapping)	Возвращает индекс указанного объекта SqlBulkCopyColumnMapping.
Insert(Int32, SqlBulkCopyColumnMapping)	Вставляет новый объект SqlBulkCopyColumnMapping по указанному индексу.
MemberwiseClone()	Создает неполную копию текущего объекта Object. (Унаследовано от Object)
OnClear()	Выполняет дополнительные пользовательские действия при очистке содержимого экземпляра CollectionBase. (Унаследовано от CollectionBase)
OnClearComplete()	Осуществляет дополнительные пользовательские действия после удаления содержимого экземпляра класса CollectionBase. (Унаследовано от CollectionBase)
OnInsert(Int32, Object)	Выполняет дополнительные пользовательские действия перед вставкой нового элемента в экземпляр класса CollectionBase. (Унаследовано от CollectionBase)
OnInsertComplete(Int32, Object)	Выполняет дополнительные пользовательские действия после вставки нового элемента в экземпляр класса CollectionBase. (Унаследовано от CollectionBase)
OnRemove(Int32, Object)	Осуществляет дополнительные пользовательские действия при удалении элемента из экземпляра класса CollectionBase. (Унаследовано от CollectionBase)
OnRemoveComplete(Int32, Object)	Осуществляет дополнительные пользовательские действия после удаления элемента из экземпляра класса CollectionBase. (Унаследовано от CollectionBase)
OnSet(Int32, Object, Object)	Выполняет дополнительные пользовательские действия перед заданием значения в экземпляре класса CollectionBase. (Унаследовано от CollectionBase)
OnSetComplete(Int32, Object, Object)	Выполняет дополнительные пользовательские действия после задания значения в экземпляре класса CollectionBase. (Унаследовано от CollectionBase)
OnValidate(Object)	Выполняет дополнительные пользовательские операции при проверке значения. (Унаследовано от CollectionBase)
Remove(SqlBulkCopyColumnMapping)	Удаляет заданный элемент SqlBulkCopyColumnMapping из SqlBulkCopyColumnMappingCollection.
RemoveAt(Int32)	Удаляет из коллекции сопоставление с заданным индексом.
ToString()	Возвращает строку, представляющую текущий объект. (Унаследовано от Object)

Методы расширения

См. также раздел

• Операции массового копирования в SQL Server
• Общие сведения об ADO.NET