SqlBulkCopy Classe

Definição

Namespace:

Microsoft.Data.SqlClient

Assembly:

Microsoft.Data.SqlClient.dll

Pacote:

Microsoft.Data.SqlClient v5.2.0

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 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;";
    }
}

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 SqlBulkCopy classe usando a instância aberta especificada de SqlConnection .
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inicializa uma nova instância da SqlBulkCopy classe usando a instância aberta existente fornecida do SqlConnection . A SqlBulkCopy instância 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 no fornecidoconnectionString . 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 no fornecidoconnectionString . O construtor usa SqlConnection para inicializar uma nova instância da classe SqlBulkCopy. A SqlConnection instância 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.
ColumnOrderHints	Retorna uma coleção de itens SqlBulkCopyColumnOrderHint. As dicas de ordem de coluna descrevem a ordem de classificação de colunas no índice clusterizado da tabela de 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.
RowsCopied	O número de linhas processadas na operação de cópia em massa em andamento.
RowsCopied64	O número de linhas processadas na operação de cópia em massa em andamento.

Métodos

Close()	Fecha a instância de SqlBulkCopy.
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 de WriteToServer(IDataReader), que copia todas as linhas no IDataReader fornecido 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. 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(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.