SqlBulkCopy Класс

Ссылка

Определение

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

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

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

Сборки:: netstandard.dll, System.Data.SqlClient.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

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

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

Бөлісу құралы: