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 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 |
| 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 |
| SqlBulkCopy(String) |
Inizializza e apre una nuova istanza di SqlConnection in base all'oggetto |
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 . |