SqlBulkCopy Classe

Riferimento

Definizione

Spazio dei nomi:: System.Data.SqlClient

Assembly:: System.Data.SqlClient.dll

Assembly:: System.Data.dll

Pacchetto:: System.Data.SqlClient v4.8.6

Importante

Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.

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 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

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 SqlBulkCopy usando l'istanza aperta specificata di SqlConnection.
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inizializza una nuova istanza della classe SqlBulkCopy mediante l'istanza aperta esistente dell'oggetto SqlConnection. Il comportamento dell'istanza SqlBulkCopy è basato sulle opzioni fornite nel parametro `copyOptions`. 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 in base all'oggetto `connectionString` fornito. Il costruttore usa SqlConnection per inizializzare una nuova istanza della classe SqlBulkCopy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inizializza e apre una nuova istanza di SqlConnection sulla base dell'oggetto `connectionString` fornito. Il costruttore utilizza l'oggetto SqlConnection per inizializzare una nuova istanza della classe SqlBulkCopy. Il comportamento dell'istanza SqlConnection è basato sulle opzioni fornite nel parametro `copyOptions`.

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.
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.

Metodi

Close()	Chiude l'istanza di SqlBulkCopy.
Equals(Object)	Determina se l'oggetto specificato è uguale all'oggetto corrente. (Ereditato da Object)
GetHashCode()	Funge da funzione hash predefinita. (Ereditato da Object)
GetType()	Ottiene l'oggetto Type dell'istanza corrente. (Ereditato da Object)
MemberwiseClone()	Crea una copia superficiale dell'oggetto Object corrente. (Ereditato da Object)
ToString()	Restituisce una stringa che rappresenta l'oggetto corrente. (Ereditato da Object)
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(DbDataReader), che copia tutte le righe dalla matrice DbDataReader fornita in 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.
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.

Si applica a