SqlBulkCopy Classe

Definição

Namespace:

System.Data.SqlClient

Assembly:

System.Data.dll

Permite um carregamento em massa eficiente de uma tabela do SQL Server com os dados de outra fonte.

public ref class SqlBulkCopy sealed : IDisposable

public sealed class SqlBulkCopy : IDisposable

type SqlBulkCopy = class
    interface IDisposable

Public NotInheritable Class SqlBulkCopy
Implements IDisposable

Herança

Object

SqlBulkCopy

Implementações

IDisposable

Exemplos

O aplicativo de console a seguir demonstra como carregar dados usando a classe SqlBulkCopy. Neste exemplo, um SqlDataReader é usado para copiar dados da tabela Production.Product no banco de dados AdventureWorks do SQL Server em uma tabela semelhante no mesmo banco de dados.

Importante

Essa amostra não será executada, a menos que você tenha criado as tabelas de trabalho conforme descrito em Configuração de exemplo de cópia em massa. Esse código é fornecido para demonstrar a sintaxe para usar somente SqlBulkCopy. Se as tabelas de origem e destino estiverem na mesma instância SQL Server, será mais fácil e rápido usar uma instrução Transact-SQL INSERT ... SELECT para copiar os dados.

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

Comentários

O Microsoft SQL Server inclui um utilitário de prompt de comando popular chamado bcp para mover dados de uma tabela para outra, seja em um único servidor ou entre servidores. A SqlBulkCopy classe permite que você escreva soluções de código gerenciado que fornecem funcionalidade semelhante. Há outras maneiras de carregar dados em uma tabela do SQL Server (instruções INSERT, por exemplo), mas SqlBulkCopy oferece uma vantagem de desempenho significativa sobre elas.

A classe SqlBulkCopy pode ser usada para gravar dados somente em tabelas do SQL Server. No entanto, a fonte de dados não se limita a SQL Server; qualquer fonte de dados pode ser usada, desde que os dados possam ser carregados em uma DataTable instância ou lidos com uma IDataReader instância.

SqlBulkCopyfalhará ao carregar em massa uma DataTable coluna do tipo SqlDateTime em uma coluna SQL Server cujo tipo é um dos tipos de data/hora adicionados no SQL Server 2008.

Construtores

SqlBulkCopy(SqlConnection)	Inicializa uma nova instância da classe SqlBulkCopy usando a instância aberta especificada de SqlConnection.
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inicializa uma nova instância da classe SqlBulkCopy usando a instância aberta existente fornecida do SqlConnection. A instância SqlBulkCopy se comporta de acordo com as opções fornecidas no parâmetro copyOptions. Se um SqlTransaction não nulo for fornecido, as operações de cópia serão executadas nessa transação.
SqlBulkCopy(String)	Inicializa e abre uma nova instância de SqlConnection com base na connectionString fornecida. O construtor usa SqlConnection para inicializar uma nova instância da classe SqlBulkCopy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inicializa e abre uma nova instância de SqlConnection com base na connectionString fornecida. O construtor usa SqlConnection para inicializar uma nova instância da classe SqlBulkCopy. A instância SqlConnection se comporta de acordo com as opções fornecidas no parâmetro copyOptions.

Propriedades

BatchSize	Número de linhas em cada lote. No final de cada lote, as linhas no lote são enviados para o servidor.
BulkCopyTimeout	Número de segundos para que a operação seja concluída antes de atingir o tempo limite.
ColumnMappings	Retorna uma coleção de itens SqlBulkCopyColumnMapping. Mapeamentos de coluna definem as relações entre colunas na fonte de dados e colunas no destino.
DestinationTableName	O nome da tabela de destino no servidor.
EnableStreaming	Habilita ou desabilita um objeto SqlBulkCopy a transmitir dados de um objeto IDataReader.
NotifyAfter	Define o número de linhas a serem processadas antes de gerar um evento de notificação.

Métodos

Close()	Fecha a instância de SqlBulkCopy.
Equals(Object)	Determina se o objeto especificado é igual ao objeto atual. (Herdado de Object)
GetHashCode()	Serve como a função de hash padrão. (Herdado de Object)
GetType()	Obtém o Type da instância atual. (Herdado de Object)
MemberwiseClone()	Cria uma cópia superficial do Object atual. (Herdado de Object)
ToString()	Retorna uma cadeia de caracteres que representa o objeto atual. (Herdado de Object)
WriteToServer(DataRow[])	Copia todas as linhas da matriz DataRow fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServer(DataTable)	Copia todas as linhas da DataTable fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServer(DataTable, DataRowState)	Copia apenas linhas que correspondem ao estado de linha fornecido no DataTable fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServer(DbDataReader)	Copia todas as linhas da matriz DbDataReader fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServer(IDataReader)	Copia todas as linhas da IDataReader fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(DataRow[])	A versão assíncrona do WriteToServer(DataRow[]), que copia todas as linhas da matriz DataRow fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(DataRow[], CancellationToken)	A versão assíncrona do WriteToServer(DataRow[]), que copia todas as linhas da matriz DataRow fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes de expirar o tempo limite do comando. As exceções serão relatadas por meio do objeto de tarefa.
WriteToServerAsync(DataTable)	A versão assíncrona de WriteToServer(DataTable), que copia todas as linhas no DataTable fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(DataTable, CancellationToken)	A versão assíncrona de WriteToServer(DataTable), que copia todas as linhas no DataTable fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes de expirar o tempo limite do comando. As exceções serão relatadas por meio do objeto de tarefa.
WriteToServerAsync(DataTable, DataRowState)	A versão assíncrona de WriteToServer(DataTable, DataRowState), que copia apenas linhas que correspondem ao estado de linha fornecido no DataTable fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	A versão assíncrona de WriteToServer(DataTable, DataRowState), que copia apenas linhas que correspondem ao estado de linha fornecido no DataTable fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes de expirar o tempo limite do comando. As exceções serão relatadas por meio do objeto de tarefa.
WriteToServerAsync(DbDataReader)	A versão assíncrona do WriteToServer(DbDataReader), que copia todas as linhas da matriz DbDataReader fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(DbDataReader, CancellationToken)	A versão assíncrona do WriteToServer(DbDataReader), que copia todas as linhas da matriz DbDataReader fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(IDataReader)	A versão assíncrona de WriteToServer(IDataReader), que copia todas as linhas no IDataReader fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy.
WriteToServerAsync(IDataReader, CancellationToken)	A versão assíncrona de WriteToServer(IDataReader), que copia todas as linhas no IDataReader fornecido para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes de expirar o tempo limite do comando. As exceções serão relatadas por meio do objeto de tarefa.

Eventos

SqlRowsCopied

Ocorre sempre que o número de linhas especificado pela propriedade NotifyAfter foram processadas.

Implantações explícitas de interface

IDisposable.Dispose()

Libera todos os recursos usados pela instância atual da classe SqlBulkCopy.

Confira também

• Operações de cópia em massa no SQL Server
• Visão geral do ADO.NET