SqlBulkCopy Classe
Definizione
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 : IDisposablepublic sealed class SqlBulkCopy : IDisposabletype SqlBulkCopy = class
interface IDisposablePublic 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 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 |
| SqlBulkCopy(String) |
Inizializza e apre una nuova istanza di SqlConnection in base all'oggetto |
| SqlBulkCopy(String, SqlBulkCopyOptions) |
Inizializza e apre una nuova istanza di SqlConnection sulla base dell'oggetto |
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. |
