SqlBulkCopy Classe
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Permite carregar com eficiência uma tabela SQL Server com 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
-
SqlBulkCopy
- Implementações
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.
Important
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 do 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
Microsoft SQL Server inclui um utilitário popular de prompt de comando 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 instância de DataTable ou lidos com uma instância IDataReader. SqlBulkCopy falhará ao carregar em massa uma coluna DataTable do tipo SqlDateTime em uma coluna SQL Server cujo tipo é um dos tipos de data/hora adicionados no SQL Server 2008.
Construtores
| Nome | Description |
|---|---|
| SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) |
Inicializa uma nova instância da SqlBulkCopy classe usando a instância aberta existente fornecida de SqlConnection. A SqlBulkCopy instância se comporta de acordo com as opções fornecidas no |
| SqlBulkCopy(SqlConnection) |
Inicializa uma nova instância da classe SqlBulkCopy usando a instância aberta especificada de SqlConnection. |
| SqlBulkCopy(String, SqlBulkCopyOptions) |
Inicializa e abre uma nova instância de SqlConnection com base na |
| SqlBulkCopy(String) |
Inicializa e abre uma nova instância de SqlConnection com base na |
Propriedades
| Nome | Description |
|---|---|
| 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 a operação ser concluída antes de atingir o tempo limite. |
| ColumnMappings |
Retorna uma coleção de SqlBulkCopyColumnMapping itens. Mapeamentos de coluna definem as relações entre colunas na fonte de dados e colunas no destino. |
| ColumnOrderHints |
Retorna uma coleção de SqlBulkCopyColumnOrderHint itens. 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 SqlBulkCopy objeto para transmitir dados de um IDataReader objeto |
| 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
| Nome | Description |
|---|---|
| ClearCachedMetadata() |
Limpa os metadados da tabela de destino armazenada em cache ao usar a opção CacheMetadata . |
| Close() |
Fecha a instância de SqlBulkCopy. |
| WriteToServer(DataRow[]) |
Copia todas as linhas da matriz fornecida DataRow para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServer(DataTable, DataRowState) |
Copia apenas as linhas que correspondem ao estado da linha fornecida no fornecido DataTable para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServer(DataTable) |
Copia todas as linhas da DataTable fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. |
| WriteToServer(DbDataReader) |
Copia todas as linhas da matriz fornecida DbDataReader para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServer(IDataReader) |
Copia todas as linhas da IDataReader fornecida para uma tabela de destino especificada pela propriedade DestinationTableName do objeto SqlBulkCopy. |
| WriteToServerAsync(DataRow[], CancellationToken) |
A versão assíncrona de WriteToServer(DataRow[]), que copia todas as linhas da matriz fornecida DataRow para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes que o tempo limite do comando seja decorrido. As exceções serão relatadas por meio do objeto Task retornado. |
| WriteToServerAsync(DataRow[]) |
A versão assíncrona de WriteToServer(DataRow[]), que copia todas as linhas da matriz fornecida DataRow para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServerAsync(DataTable, CancellationToken) |
A versão assíncrona de WriteToServer(DataTable), que copia todas as linhas na tabela de DataTable destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes que o tempo limite do comando seja decorrido. As exceções serão relatadas por meio do objeto Task retornado. |
| 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 fornecido DataTable para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes que o tempo limite do comando seja decorrido. As exceções serão relatadas por meio do objeto Task retornado. |
| WriteToServerAsync(DataTable, DataRowState) |
A versão assíncrona de WriteToServer(DataTable, DataRowState), que copia apenas linhas que correspondem ao estado de linha fornecido no fornecido DataTable para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServerAsync(DataTable) |
A versão assíncrona de WriteToServer(DataTable), que copia todas as linhas na tabela de DataTable destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServerAsync(DbDataReader, CancellationToken) |
A versão assíncrona de WriteToServer(DbDataReader), que copia todas as linhas da matriz fornecida DbDataReader para uma tabela de destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes que o tempo limite do comando seja decorrido. As exceções serão relatadas por meio do objeto Task retornado. |
| WriteToServerAsync(DbDataReader) |
A versão assíncrona de WriteToServer(IDataReader), que copia todas as linhas na tabela de IDataReader destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
| WriteToServerAsync(IDataReader, CancellationToken) |
A versão assíncrona de WriteToServer(IDataReader), que copia todas as linhas na tabela de IDataReader destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. O token de cancelamento pode ser usado para solicitar que a operação seja abandonada antes que o tempo limite do comando seja decorrido. As exceções serão relatadas por meio do objeto Task retornado. |
| WriteToServerAsync(IDataReader) |
A versão assíncrona de WriteToServer(IDataReader), que copia todas as linhas na tabela de IDataReader destino especificada pela DestinationTableName propriedade do SqlBulkCopy objeto. |
Eventos
| Nome | Description |
|---|---|
| SqlRowsCopied |
Ocorre sempre que o número de linhas especificadas pela NotifyAfter propriedade é processado. |
Implantações explícitas de interface
| Nome | Description |
|---|---|
| IDisposable.Dispose() |
Libera todos os recursos usados pela instância atual da SqlBulkCopy classe. |