SqlBulkCopy Класс

  • Ссылка

Определение

Пространство имен:
System.Data.SqlClient
Сборка:
System.Data.SqlClient.dll
Сборка:
System.Data.dll
Пакет:
System.Data.SqlClient v4.8.6

Обеспечивает эффективную массовую загрузку таблицы 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 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

Комментарии

Майкрософт 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. Сопоставления столбцов определяют связи между столбцами в источнике данных и столбцами в месте назначения.
DestinationTableName

Имя целевой таблицы на сервере.
EnableStreaming

Включает или отключает потоковую передачу данных из объекта IDataReader для объекта SqlBulkCopy.
NotifyAfter

Определяет количество строк, обрабатываемых перед созданием события уведомления.

Методы

Close()

Закрывает экземпляр SqlBulkCopy.
Equals(Object)

Определяет, равен ли указанный объект текущему объекту.

(Унаследовано от Object)
GetHashCode()

Служит хэш-функцией по умолчанию.

(Унаследовано от Object)
GetType()

Возвращает объект Type для текущего экземпляра.

(Унаследовано от Object)
MemberwiseClone()

Создает неполную копию текущего объекта Object.

(Унаследовано от Object)
ToString()

Возвращает строку, представляющую текущий объект.

(Унаследовано от Object)
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(DbDataReader), который копирует все строки из предоставленного массива DbDataReader в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServerAsync(DbDataReader, CancellationToken)

Асинхронная версия объекта WriteToServer(DbDataReader), который копирует все строки из предоставленного массива DbDataReader в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServerAsync(IDataReader)

Асинхронная версия метода WriteToServer(IDataReader), который копирует все строки из предоставленного IDataReader в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.
WriteToServerAsync(IDataReader, CancellationToken)

Асинхронная версия метода WriteToServer(IDataReader), который копирует все строки из предоставленного IDataReader в целевую таблицу, заданную свойством DestinationTableName объекта SqlBulkCopy.

Токен отмены можно использовать для запроса отказа от операции до истечения времени ожидания команды. Сведения об исключениях передаются в возвращенном объекте Task.

События

SqlRowsCopied

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

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

IDisposable.Dispose()

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

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

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