SqlBulkCopy Classe

Definizione

Spazio dei nomi:

Microsoft.Data.SqlClient

Assembly:

Microsoft.Data.SqlClient.dll

Pacchetto:

Microsoft.Data.SqlClient v5.2.0

Consente di caricare in blocco in modo efficace una tabella di SQL Server con i dati provenienti da un'altra origine.

public ref class SqlBulkCopy sealed : IDisposable

public sealed class SqlBulkCopy : IDisposable

type SqlBulkCopy = class
    interface IDisposable

Public NotInheritable Class SqlBulkCopy
Implements IDisposable

Ereditarietà

Object

SqlBulkCopy

Implementazioni

IDisposable

Esempio

L'applicazione console riportata di seguito dimostra come caricare i dati usando la classe SqlBulkCopy. In questo esempio, viene usato un oggetto SqlDataReader per copiare i dati dalla tabella Production.Product del database AdventureWorks di SQL Server in una tabella simile dello stesso database.

Importante

Questo esempio non verrà eseguito a meno che non siano state create le tabelle di lavoro, come descritto in Installazione di esempio di copia bulk. Il codice viene fornito solo per illustrare la sintassi relativa all'uso di SqlBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e veloce usare un'istruzione Transact-SQL INSERT … SELECT per copiare i dati.

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

Commenti

Microsoft SQL Server include un'utilità del prompt dei comandi popolare denominata bcp per lo spostamento di dati da una tabella a un'altra, sia in un singolo server che tra server. La SqlBulkCopy classe consente di scrivere soluzioni di codice gestito che forniscono funzionalità simili. Esistono altri modi per caricare dati in una tabella di SQL Server, ad esempio le istruzioni INSERT, ma SqlBulkCopy offre un vantaggio significativo in termini di prestazioni. La classe SqlBulkCopy può essere usata per scrivere dati solo in tabelle di SQL Server. Tuttavia, l'origine dati non è limitata a SQL Server; qualsiasi origine dati può essere usata, purché i dati possano essere caricati in un'istanza DataTable o in lettura con un'istanzaIDataReader. SqlBulkCopynon riuscirà quando si carica in blocco una DataTable colonna di tipo SqlDateTime in una colonna SQL Server il cui tipo è uno dei tipi di data/ora aggiunti in SQL Server 2008.

Costruttori

SqlBulkCopy(SqlConnection)	Inizializza una nuova istanza della classe usando l'istanza SqlBulkCopy aperta specificata di SqlConnection .
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inizializza una nuova istanza della classe usando l'istanza SqlBulkCopy aperta esistente fornita di SqlConnection . L'istanza SqlBulkCopy si comporta in base alle opzioni fornite nell'oggettocopyOptions Parametro. Se viene specificato un oggetto SqlTransaction non Null, le operazioni di copia verranno eseguite all'interno di tale transazione.
SqlBulkCopy(String)	Inizializza e apre una nuova istanza di SqlConnection basata sull'oggetto fornitoconnectionString . Il costruttore usa SqlConnection per inizializzare una nuova istanza della classe SqlBulkCopy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inizializza e apre una nuova istanza di SqlConnection basata sull'oggetto fornitoconnectionString . Il costruttore utilizza l'oggetto SqlConnection per inizializzare una nuova istanza della classe SqlBulkCopy. L'istanza SqlConnection si comporta in base alle opzioni fornite nell'oggettocopyOptions Parametro.

Proprietà

BatchSize	Numero di righe in ogni batch. Al termine di ogni batch, le righe nel batch vengono inviate al server.
BulkCopyTimeout	Numero di secondi che devono trascorrere per il completamento dell'operazione prima del timeout.
ColumnMappings	Restituisce una raccolta di elementi SqlBulkCopyColumnMapping. I mapping delle colonne definiscono le relazioni tra le colonne nell'origine dati e quelle nella destinazione.
ColumnOrderHints	Restituisce una raccolta di elementi SqlBulkCopyColumnOrderHint. Gli hint per l'ordine di colonna descrivono l'ordinamento delle colonne nell'indice cluster della tabella di destinazione.
DestinationTableName	Nome della tabella di destinazione nel server.
EnableStreaming	Abilita o disabilita un oggetto SqlBulkCopy per la trasmissione del flusso di dati da un oggetto IDataReader.
NotifyAfter	Definisce il numero di righe da elaborare prima di generare un evento di notifica.
RowsCopied	Numero di righe elaborate nell'operazione di copia bulk in corso.
RowsCopied64	Numero di righe elaborate nell'operazione di copia bulk in corso.

Metodi

Close()	Chiude l'istanza di SqlBulkCopy.
WriteToServer(DataRow[])	Copia tutte le righe dalla matrice DataRow fornita in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServer(DataTable)	Copia tutte le righe nell'oggetto DataTable indicato in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServer(DataTable, DataRowState)	Copia solo le righe corrispondenti allo stato di riga specificato nell'oggetto DataTable fornito in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServer(DbDataReader)	Copia tutte le righe dalla matrice DbDataReader fornita in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServer(IDataReader)	Copia tutte le righe nell'oggetto IDataReader indicato in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(DataRow[])	Versione asincrona di WriteToServer(DataRow[]), che copia tutte le righe dalla matrice DataRow fornita in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(DataRow[], CancellationToken)	Versione asincrona di WriteToServer(DataRow[]), che copia tutte le righe dalla matrice DataRow fornita in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy. Il token di annullamento può essere utilizzato per richiedere che l'operazione venga abbandonata prima del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto attività restituito.
WriteToServerAsync(DataTable)	Versione asincrona di WriteToServer(DataTable) che copia tutte le righe nella matrice DataTable fornita a una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(DataTable, CancellationToken)	Versione asincrona di WriteToServer(DataTable) che copia tutte le righe nella matrice DataTable fornita a una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy. Il token di annullamento può essere utilizzato per richiedere che l'operazione venga abbandonata prima del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto attività restituito.
WriteToServerAsync(DataTable, DataRowState)	La versione asincrona di WriteToServer(DataTable, DataRowState), che copia solo le righe corrispondenti allo stato di riga fornito nell'oggetto DataTable fornito in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	La versione asincrona di WriteToServer(DataTable, DataRowState), che copia solo le righe corrispondenti allo stato di riga fornito nell'oggetto DataTable fornito in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy. Il token di annullamento può essere utilizzato per richiedere che l'operazione venga abbandonata prima del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto attività restituito.
WriteToServerAsync(DbDataReader)	Versione asincrona di WriteToServer(IDataReader) che copia tutte le righe nella matrice IDataReader fornita a una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(DbDataReader, CancellationToken)	Versione asincrona di WriteToServer(DbDataReader), che copia tutte le righe dalla matrice DbDataReader fornita in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy. Il token di annullamento può essere utilizzato per richiedere che l'operazione venga abbandonata prima del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto attività restituito.
WriteToServerAsync(IDataReader)	Versione asincrona di WriteToServer(IDataReader) che copia tutte le righe nella matrice IDataReader fornita a una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy.
WriteToServerAsync(IDataReader, CancellationToken)	Versione asincrona di WriteToServer(IDataReader) che copia tutte le righe nella matrice IDataReader fornita a una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SqlBulkCopy. Il token di annullamento può essere utilizzato per richiedere che l'operazione venga abbandonata prima del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto attività restituito.

Eventi

SqlRowsCopied

Si verifica ogni volta che il numero di righe specificato dalla proprietà NotifyAfter viene elaborato.

Implementazioni dell'interfaccia esplicita

IDisposable.Dispose()

Rilascia tutte le risorse usate dall'istanza corrente della classe SqlBulkCopy.