SqlBulkCopy Classe

Definizione

Consente di caricare in blocco in modo efficiente una tabella SQL Server con 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à
SqlBulkCopy
Implementazioni

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 funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Creazione di esempi di copia di massa.

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 comune 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 di DataTable o letti con un'istanza /IDataReader. SqlBulkCopy avrà esito negativo durante il caricamento bulk di una colonna DataTable di tipo SqlDateTime in una colonna SQL Server il cui tipo è uno dei tipi di data/ora aggiunti in SQL Server 2008.

Costruttori

Nome Descrizione
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)

Inizializza una nuova istanza della SqlBulkCopy classe utilizzando l'istanza aperta esistente fornita di SqlConnection. L'istanza SqlBulkCopy si comporta in base alle opzioni fornite nel copyOptions parametro . Se viene specificato un valore diverso da Null SqlTransaction , le operazioni di copia verranno eseguite all'interno di tale transazione.

SqlBulkCopy(SqlConnection)

Inizializza una nuova istanza della classe SqlBulkCopy usando l'istanza aperta specificata di SqlConnection.

SqlBulkCopy(String, SqlBulkCopyOptions)

Inizializza e apre una nuova istanza di SqlConnection in base all'oggetto connectionString fornito. Il costruttore usa tale oggetto SqlConnection per inizializzare una nuova istanza della SqlBulkCopy classe . L'istanza SqlConnection si comporta in base alle opzioni fornite nel copyOptions parametro .

SqlBulkCopy(String)

Inizializza e apre una nuova istanza di SqlConnection in base all'oggetto connectionString fornito. Il costruttore usa SqlConnection per inizializzare una nuova istanza della classe SqlBulkCopy.

Proprietà

Nome Descrizione
BatchSize

Numero di righe in ogni batch. Al termine di ogni batch, le righe nel batch vengono inviate al server.

BulkCopyTimeout

Numero di secondi per il completamento dell'operazione prima del timeout.

ColumnMappings

Restituisce una raccolta di SqlBulkCopyColumnMapping elementi. I mapping delle colonne definiscono le relazioni tra le colonne nell'origine dati e le colonne nella destinazione.

ColumnOrderHints

Restituisce una raccolta di SqlBulkCopyColumnOrderHint elementi. 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 SqlBulkCopy oggetto per trasmettere dati da un IDataReader oggetto

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

Nome Descrizione
ClearCachedMetadata()

Cancella i metadati della tabella di destinazione memorizzati nella cache quando si usa l'opzione CacheMetadata .

Close()

Chiude l'istanza di SqlBulkCopy.

WriteToServer(DataRow[])

Copia tutte le righe dalla matrice fornita DataRow in una tabella di destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

WriteToServer(DataTable, DataRowState)

Copia solo le righe che corrispondono allo stato della riga fornito nell'oggetto fornito DataTable in una tabella di destinazione specificata dalla DestinationTableName proprietà 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(DbDataReader)

Copia tutte le righe dalla matrice fornita DbDataReader in una tabella di destinazione specificata dalla DestinationTableName proprietà 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[], CancellationToken)

Versione asincrona di , che copia tutte le righe dalla matrice fornita DataRow in una tabella di WriteToServer(DataRow[])destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy . Il token di annullamento può essere usato per richiedere che l'operazione venga abbandonata prima della scadenza del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto Task restituito.

WriteToServerAsync(DataRow[])

Versione asincrona di , che copia tutte le righe dalla matrice fornita DataRow in una tabella di WriteToServer(DataRow[])destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

WriteToServerAsync(DataTable, CancellationToken)

Versione asincrona di , che copia tutte le righe nell'oggetto fornito DataTable in una tabella di WriteToServer(DataTable)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy . Il token di annullamento può essere usato per richiedere che l'operazione venga abbandonata prima della scadenza del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto Task restituito.

WriteToServerAsync(DataTable, DataRowState, CancellationToken)

Versione asincrona di , che copia solo le righe che corrispondono allo stato di riga fornito nell'oggetto fornito DataTable a una tabella di WriteToServer(DataTable, DataRowState)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy . Il token di annullamento può essere usato per richiedere che l'operazione venga abbandonata prima della scadenza del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto Task restituito.

WriteToServerAsync(DataTable, DataRowState)

Versione asincrona di , che copia solo le righe che corrispondono allo stato di riga fornito nell'oggetto fornito DataTable a una tabella di WriteToServer(DataTable, DataRowState)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

WriteToServerAsync(DataTable)

Versione asincrona di , che copia tutte le righe nell'oggetto fornito DataTable in una tabella di WriteToServer(DataTable)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

WriteToServerAsync(DbDataReader, CancellationToken)

Versione asincrona di , che copia tutte le righe dalla matrice fornita DbDataReader in una tabella di WriteToServer(DbDataReader)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy . Il token di annullamento può essere usato per richiedere che l'operazione venga abbandonata prima della scadenza del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto Task restituito.

WriteToServerAsync(DbDataReader)

Versione asincrona di , che copia tutte le righe nell'oggetto fornito IDataReader in una tabella di WriteToServer(IDataReader)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

WriteToServerAsync(IDataReader, CancellationToken)

Versione asincrona di , che copia tutte le righe nell'oggetto fornito IDataReader in una tabella di WriteToServer(IDataReader)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy . Il token di annullamento può essere usato per richiedere che l'operazione venga abbandonata prima della scadenza del timeout del comando. Le eccezioni verranno segnalate tramite l'oggetto Task restituito.

WriteToServerAsync(IDataReader)

Versione asincrona di , che copia tutte le righe nell'oggetto fornito IDataReader in una tabella di WriteToServer(IDataReader)destinazione specificata dalla DestinationTableName proprietà dell'oggetto SqlBulkCopy .

Eventi

Nome Descrizione
SqlRowsCopied

Si verifica ogni volta che il numero di righe specificate dalla NotifyAfter proprietà è stato elaborato.

Implementazioni dell'interfaccia esplicita

Nome Descrizione
IDisposable.Dispose()

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

Si applica a