SqlBulkCopy Класс

Определение

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

Microsoft.Data.SqlClient

Сборка:

Microsoft.Data.SqlClient.dll

Пакет:

Microsoft.Data.SqlClient v5.2.0

Обеспечивает эффективную массовую загрузку таблицы 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)	Инициализирует новый экземпляр класса , SqlBulkCopy используя указанный открытый SqlConnection экземпляр класса .
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Инициализирует новый экземпляр класса , SqlBulkCopy используя предоставленный существующий открытый SqlConnection экземпляр . Экземпляр SqlBulkCopy ведет себя в соответствии с параметрами, указанными в параметром copyOptions. Если предоставлено ненулевое значение SqlTransaction, операция копирования будет выполнена в этой транзакции.
SqlBulkCopy(String)	Инициализирует и открывает новый экземпляр на SqlConnection основе предоставленногоconnectionString . Конструктор использует SqlConnection для инициализации нового экземпляра класса SqlBulkCopy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Инициализирует и открывает новый экземпляр на SqlConnection основе предоставленногоconnectionString . Этот конструктор использует SqlConnection для инициализации нового экземпляра класса SqlBulkCopy. Экземпляр SqlConnection ведет себя в соответствии с параметрами, указанными в параметром copyOptions.

Свойства

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

Методы

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

События

SqlRowsCopied

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

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

IDisposable.Dispose()

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