SqlBulkCopy Класс

Определение

Пространство имен:: System.Data.SqlClient

Сборка:: System.Data.dll

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Позволяет эффективно загружать таблицу 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 в такую же таблицу в этой же базе данных.

Important

Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования". Этот код предназначен только для демонстрации синтаксиса использования 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.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;";
    }
}

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.BulkCopyDemoMatchingColumns;", _
                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 New SqlCommand( _
               "SELECT ProductID, Name, ProductNumber " & _
               "FROM Production.Product;", sourceConnection)
            Dim reader As SqlDataReader = 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 destinationConnection As SqlConnection = _
                New SqlConnection(connectionString)
                destinationConnection.Open()

                ' Set up the bulk copy object. 
                ' 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 bulkCopy As SqlBulkCopy = _
                  New SqlBulkCopy(destinationConnection)
                    bulkCopy.DestinationTableName = _
                    "dbo.BulkCopyDemoMatchingColumns"

                    Try
                        ' Write from the source to the destination.
                        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 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

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 элементов. Сопоставления столбцов определяют связи между столбцами в источнике данных и столбцами в месте назначения.
DestinationTableName	Имя целевой таблицы на сервере.
EnableStreaming	Включает или отключает SqlBulkCopy объект для потоковой передачи данных из IDataReader объекта.
NotifyAfter	Определяет количество строк, которые необходимо обработать перед созданием события уведомления.

Методы

Имя	Описание
Close()	Закрывает экземпляр SqlBulkCopy.
Equals(Object)	Определяет, равен ли указанный объект текущему объекту. (Унаследовано от Object)
GetHashCode()	Служит хэш-функцией по умолчанию. (Унаследовано от Object)
GetType()	Возвращает Type текущего экземпляра. (Унаследовано от Object)
MemberwiseClone()	Создает неглубокую копию текущей Object. (Унаследовано от Object)
ToString()	Возвращает строку, представляющую текущий объект. (Унаследовано от Object)
WriteToServer(DataRow[])	Копирует все строки из предоставленного DataRow DestinationTableName массива в целевую таблицу, указанную SqlBulkCopy свойством объекта.
WriteToServer(DataTable, DataRowState)	Копирует только строки, соответствующие заданному состоянию строки в указанной DataTable целевой таблице, указанной DestinationTableName SqlBulkCopy свойством объекта.
WriteToServer(DataTable)	Копирует все строки в предоставленном DataTable в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServer(DbDataReader)	Копирует все строки из предоставленного DbDataReader DestinationTableName массива в целевую таблицу, указанную SqlBulkCopy свойством объекта.
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 объекта.
WriteToServerAsync(DbDataReader)	Асинхронная версия WriteToServer(DbDataReader), которая копирует все строки из предоставленного DbDataReader массива в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.
WriteToServerAsync(IDataReader, CancellationToken)	Асинхронная версия WriteToServer(IDataReader), которая копирует все строки в предоставленной IDataReader в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта. Маркер отмены можно использовать для запроса на то, что операция будет прекращена до истечения времени ожидания команды. Исключения будут сообщаться с помощью возвращаемого объекта Task.
WriteToServerAsync(IDataReader)	Асинхронная версия WriteToServer(IDataReader), которая копирует все строки в предоставленной IDataReader в целевую таблицу, указанную DestinationTableName свойством SqlBulkCopy объекта.

События

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

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

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

Применяется к

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

Обратная связь

Были ли сведения на этой странице полезными?