SqlBulkCopy Класс

Определение

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

Microsoft.Data.SqlClient

Сборка:

Microsoft.Data.SqlClient.dll

Пакет:

Microsoft.Data.SqlClient v7.0.1

Позволяет эффективно загружать таблицу SQL Server с данными из другого источника.

public ref class SqlBulkCopy sealed : IDisposable

public sealed class SqlBulkCopy : IDisposable

type SqlBulkCopy = class
    interface IDisposable

Public NotInheritable Class SqlBulkCopy
Implements IDisposable

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

Object

SqlBulkCopy

Реализации

IDisposable

Примеры

Следующее консольное приложение показывает, как загрузить данные с помощью класса SqlBulkCopy. В этом примере объект SqlDataReader используется, чтобы скопировать данные из таблицы Production.Product в базе данных SQL Server AdventureWorks в такую же таблицу в этой же базе данных.

Это важно

Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования".

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

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.BulkCopyDemoMatchingColumns;",
                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();

            // Open the destination connection. In the real world you would 
            // not use SqlBulkCopy to move data from one table to the other 
            // in the same database. This is for demonstration purposes only.
            using (SqlConnection destinationConnection =
                       new SqlConnection(connectionString))
            {
                destinationConnection.Open();

                // Set up the bulk copy object. 
                // Note that the column positions in the source
                // data reader match the column positions in 
                // the destination table so there is no need to
                // map columns.
                using (SqlBulkCopy bulkCopy =
                           new SqlBulkCopy(destinationConnection))
                {
                    bulkCopy.DestinationTableName =
                        "dbo.BulkCopyDemoMatchingColumns";

                    try
                    {
                        // Write from the source to the destination.
                        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;";
    }
}

Комментарии

Microsoft SQL Server включает в себя популярную программу командной строки с именем bcp для перемещения данных из одной таблицы в другую, будь то на одном сервере или между серверами. Класс SqlBulkCopy позволяет создавать решения управляемого кода, обеспечивающие аналогичные функциональные возможности. Существуют другие способы загрузки данных в таблицу SQL Server (например, с помощью инструкции INSERT), но SqlBulkCopy делает это значительно быстрее. Класс SqlBulkCopy можно использовать для записи данных только в таблицы SQL Server. Однако источник данных не ограничен SQL Server; можно использовать любой источник данных, если данные можно загрузить в экземпляр DataTable или считывать с помощью экземпляра IDataReader. SqlBulkCopy завершится ошибкой при массовой загрузке столбца DataTable типа SqlDateTime в столбец SQL Server, тип которого является одним из типов даты и времени, добавленных в SQL Server 2008.

Конструкторы

Имя	Описание
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Инициализирует новый экземпляр класса с помощью предоставленного SqlBulkCopy существующего открытого экземпляра SqlConnection. Экземпляр SqlBulkCopy ведет себя в соответствии с параметрами, указанными в параметре copyOptions . Если задано значение NULL SqlTransaction , операции копирования будут выполняться в рамках этой транзакции.
SqlBulkCopy(SqlConnection)	Инициализирует новый экземпляр класса SqlBulkCopy, используя указанный открытый экземпляр SqlConnection.
SqlBulkCopy(String, SqlBulkCopyOptions)	Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра connectionString. Конструктор использует этот SqlConnection метод для инициализации нового экземпляра SqlBulkCopy класса. Экземпляр SqlConnection ведет себя в соответствии с параметрами, указанными в параметре copyOptions .
SqlBulkCopy(String)	Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра connectionString. Конструктор использует SqlConnection для инициализации нового экземпляра класса SqlBulkCopy.

Свойства

Имя	Описание
BatchSize	Количество строк в каждом пакете. В конце каждого пакета строки из пакета передаются на сервер.
BulkCopyTimeout	Количество секунд для завершения операции до истечения времени ожидания.
ColumnMappings	Возвращает коллекцию SqlBulkCopyColumnMapping элементов. Сопоставления столбцов определяют связи между столбцами в источнике данных и столбцами в месте назначения.
ColumnOrderHints	Возвращает коллекцию SqlBulkCopyColumnOrderHint элементов. Указания порядка столбцов описывают порядок сортировки столбцов в кластеризованном индексе целевой таблицы.
DestinationTableName	Имя целевой таблицы на сервере.
EnableStreaming	Включает или отключает SqlBulkCopy объект для потоковой передачи данных из IDataReader объекта
NotifyAfter	Определяет количество строк, которые необходимо обработать перед созданием события уведомления.
RowsCopied	Количество строк, обработанных в текущей операции массового копирования.
RowsCopied64	Количество строк, обработанных в текущей операции массового копирования.

Методы

Имя	Описание
ClearCachedMetadata()	Очищает метаданные кэшированных целевых таблиц при использовании CacheMetadata параметра.
Close()	Закрывает экземпляр SqlBulkCopy.
WriteToServer(DataRow[])	Копирует все строки из предоставленного DataRowSqlBulkCopy массива в целевую таблицу, указанную DestinationTableName свойством объекта.
WriteToServer(DataTable, DataRowState)	Копирует только строки, соответствующие заданному состоянию строки в указанной DataTable целевой таблице, указанной DestinationTableNameSqlBulkCopy свойством объекта.
WriteToServer(DataTable)	Копирует все строки в предоставленном DataTable в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServer(DbDataReader)	Копирует все строки из предоставленного DbDataReaderSqlBulkCopy массива в целевую таблицу, указанную DestinationTableName свойством объекта.
WriteToServer(IDataReader)	Копирует все строки в предоставленном IDataReader в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServerAsync(DataRow[], CancellationToken)	Асинхронная версия WriteToServer(DataRow[]), которая копирует все строки из предоставленного DataRow массива в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(DataRow[])	Асинхронная версия WriteToServer(DataRow[]), которая копирует все строки из предоставленного DataRow массива в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.
WriteToServerAsync(DataTable, CancellationToken)	Асинхронная версия WriteToServer(DataTable), которая копирует все строки в предоставленной DataTable в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	Асинхронная версия WriteToServer(DataTable, DataRowState), которая копирует только строки, соответствующие заданному состоянию строки в указанной DataTable целевой таблице, указанной DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(DataTable, DataRowState)	Асинхронная версия WriteToServer(DataTable, DataRowState), которая копирует только строки, соответствующие заданному состоянию строки в указанной DataTable целевой таблице, указанной DestinationTableName свойством SqlBulkCopy объекта.
WriteToServerAsync(DataTable)	Асинхронная версия WriteToServer(DataTable), которая копирует все строки в предоставленной DataTable в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.
WriteToServerAsync(DbDataReader, CancellationToken)	Асинхронная версия WriteToServer(DbDataReader), которая копирует все строки из предоставленного DbDataReader массива в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(DbDataReader)	Асинхронная версия WriteToServer(IDataReader), которая копирует все строки в предоставленной IDataReader в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.
WriteToServerAsync(IDataReader, CancellationToken)	Асинхронная версия WriteToServer(IDataReader), которая копирует все строки в предоставленной IDataReader в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(IDataReader)	Асинхронная версия WriteToServer(IDataReader), которая копирует все строки в предоставленной IDataReader в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.

События

Имя	Описание
SqlRowsCopied	Происходит каждый раз, когда количество строк, указанных NotifyAfter свойством, обрабатывается.

Явные реализации интерфейса

Имя	Описание
IDisposable.Dispose()	Освобождает все ресурсы, используемые текущим экземпляром класса SqlBulkCopy.