SqlBulkCopy Konstruktoren
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Überlädt
| SqlBulkCopy(SqlConnection) |
Initialisiert eine neue Instanz der SqlBulkCopy -Klasse unter Verwendung der angegebenen offenen Instanz von SqlConnection . |
| SqlBulkCopy(String) |
Initialisiert und öffnet eine neue Instanz von SqlConnection basierend auf der angegebenen |
| SqlBulkCopy(String, SqlBulkCopyOptions) |
Initialisiert und öffnet eine neue Instanz von SqlConnection basierend auf der angegebenen |
| SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) |
Initialisiert eine neue Instanz der SqlBulkCopy -Klasse unter Verwendung der angegebenen offenen Instanz von SqlConnection . Die SqlBulkCopy -Instanz verhält sich entsprechend den optionen, die im |
SqlBulkCopy(SqlConnection)
Initialisiert eine neue Instanz der SqlBulkCopy -Klasse unter Verwendung der angegebenen offenen Instanz von SqlConnection .
public:
SqlBulkCopy(Microsoft::Data::SqlClient::SqlConnection ^ connection);public SqlBulkCopy (Microsoft.Data.SqlClient.SqlConnection connection);new Microsoft.Data.SqlClient.SqlBulkCopy : Microsoft.Data.SqlClient.SqlConnection -> Microsoft.Data.SqlClient.SqlBulkCopyPublic Sub New (connection As SqlConnection)Parameter
- connection
- SqlConnection
Die bereits geöffnete SqlConnection-Instanz, mit der Massenkopiervorgänge ausgeführt werden. Wenn Ihre Verbindungszeichenfolge nicht verwendetIntegrated Security = true können Sie verwenden SqlCredential , um die Benutzer-ID und das Kennwort sicherer zu übergeben, als indem Sie die Benutzer-ID und das Kennwort als Text in der Verbindungszeichenfolge angeben.
Beispiele
Die folgende Konsolenanwendung veranschaulicht das Massenladen von Daten mithilfe einer bereits geöffneten Verbindung. In diesem Beispiel werden in der SQL Server-Datenbank AdventureWorks unter Verwendung von SqlDataReader Daten aus der Tabelle Production.Product in eine ähnliche Tabelle derselben Datenbank kopiert. Dieses Beispiel dient ausschließlich Demonstrationszwecken. Sie würden nicht verwenden SqlBulkCopy , um Daten aus einer Tabelle in eine andere in derselben Datenbank in einer Produktionsanwendung zu verschieben.
Beachten Sie, dass sich die Quelldaten nicht auf SQL Server befinden müssen. Sie können eine beliebige Datenquelle verwenden, die in eine IDataReader gelesen oder in geladen DataTablewerden kann.
Wichtig
Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben.
Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich quell- und zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.
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;";
}
}
Hinweise
Da die Verbindung beim Initialisieren der SqlBulkCopy Instanz bereits geöffnet ist, bleibt die Verbindung nach dem Schließen der SqlBulkCopy Instanz geöffnet.
Wenn das connection Argument NULL ist, wird ein ArgumentNullException ausgelöst.
Gilt für:
SqlBulkCopy(String)
Initialisiert und öffnet eine neue Instanz von SqlConnection basierend auf der angegebenenconnectionString . Im Konstruktor wird die SqlConnection verwendet, um eine neue Instanz der SqlBulkCopy-Klasse zu initialisieren.
public:
SqlBulkCopy(System::String ^ connectionString);public SqlBulkCopy (string connectionString);new Microsoft.Data.SqlClient.SqlBulkCopy : string -> Microsoft.Data.SqlClient.SqlBulkCopyPublic Sub New (connectionString As String)Parameter
- connectionString
- String
Die Zeichenfolge zur Definition der Verbindung, die für die SqlBulkCopy-Instanz geöffnet wird.
Wenn Ihre Verbindungszeichenfolge nicht verwendetIntegrated Security = truekönnen Sie oder SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) und SqlCredential verwendenSqlBulkCopy(SqlConnection), um die Benutzer-ID und das Kennwort sicherer zu übergeben, als indem Sie die Benutzer-ID und das Kennwort als Text in der Verbindungszeichenfolge angeben.
Ausnahmen
Wenn connectionString eine leere Zeichenfolge ist, wird eine ArgumentException ausgelöst.
Beispiele
Die folgende Konsolenanwendung veranschaulicht das Massenladen von Daten mithilfe einer als Zeichenfolge angegebenen Verbindung. Die Verbindung wird automatisch geschlossen, wenn die SqlBulkCopy Instanz geschlossen wird. In diesem Beispiel werden die Quelldaten zuerst aus einer SQL Server Tabelle in eine SqlDataReader -Instanz gelesen. Die Quelldaten müssen sich nicht auf SQL Server befinden. Sie können eine beliebige Datenquelle verwenden, die in eine IDataReader gelesen oder in eine DataTablegeladen werden kann.
Wichtig
Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben.
Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich quell- und zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.
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();
// Set up the bulk copy object using a connection string.
// In the real world you would not use SqlBulkCopy to move
// data from one table to the other in the same database.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString))
{
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;";
}
}
Hinweise
Die Verbindung wird am Ende des Massenkopiervorgangs automatisch geschlossen.
Wenn connectionString NULL ist, wird ein ArgumentNullException ausgelöst. Wenn connectionString eine leere Zeichenfolge ist, wird eine ArgumentException ausgelöst.
Gilt für:
SqlBulkCopy(String, SqlBulkCopyOptions)
Initialisiert und öffnet eine neue Instanz von SqlConnection basierend auf der angegebenenconnectionString . Der Konstruktor initialisiert mithilfe von SqlConnection eine neue Instanz der SqlBulkCopy-Klasse. Die SqlConnection -Instanz verhält sich entsprechend den optionen, die imcopyOptions-Parameter verwendet werden sollen.
public:
SqlBulkCopy(System::String ^ connectionString, Microsoft::Data::SqlClient::SqlBulkCopyOptions copyOptions);public SqlBulkCopy (string connectionString, Microsoft.Data.SqlClient.SqlBulkCopyOptions copyOptions);new Microsoft.Data.SqlClient.SqlBulkCopy : string * Microsoft.Data.SqlClient.SqlBulkCopyOptions -> Microsoft.Data.SqlClient.SqlBulkCopyPublic Sub New (connectionString As String, copyOptions As SqlBulkCopyOptions)Parameter
- connectionString
- String
Die Zeichenfolge zur Definition der Verbindung, die für die SqlBulkCopy-Instanz geöffnet wird. Wenn Ihre Verbindungszeichenfolge nicht verwendetIntegrated Security = truekönnen Sie oder SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) und SqlCredential verwendenSqlBulkCopy(SqlConnection), um die Benutzer-ID und das Kennwort sicherer zu übergeben, als indem Sie die Benutzer-ID und das Kennwort als Text in der Verbindungszeichenfolge angeben.
- copyOptions
- SqlBulkCopyOptions
Eine Kombination von Werten aus der SqlBulkCopyOptions-Enumeration, die festlegt, welche Zeilen der Datenquelle in die Zieltabelle kopiert werden.
Beispiele
Die folgende Konsolenanwendung veranschaulicht, wie ein Massenladen mithilfe einer als Zeichenfolge angegebenen Verbindung ausgeführt wird. Es wird eine Option für die Verwendung des Werts in der Identitätsspalte der Quelltabelle festgelegt, wenn Sie die Zieltabelle laden. In diesem Beispiel werden die Quelldaten zuerst aus einer SQL Server Tabelle in eine SqlDataReader -Instanz gelesen. Die Quelltabelle und die Zieltabelle enthalten jeweils eine Identitätsspalte. Standardmäßig wird in der Zieltabelle für jede hinzugefügte Zeile ein neuer Wert für die Spalte Identity generiert. In diesem Beispiel wird beim Öffnen der Verbindung eine Option festgelegt, die erzwingt, dass der Massenladeprozess stattdessen die Identity-Werte aus der Quelltabelle verwendet. Um zu sehen, wie die Option die Funktionsweise des Massenladens ändert, führen Sie das Beispiel mit dem dbo aus. BulkCopyDemoMatchingColumns-Tabelle leer. Alle Zeilen werden aus der Quelle geladen. Führen Sie dann das Beispiel erneut aus, ohne die Tabelle zu leeren. Es wird eine Ausnahme ausgelöst, und der Code schreibt eine Meldung in die Konsole, die Sie darüber informiert, dass aufgrund von Verletzungen der Primärschlüsseleinschränkung keine Zeilen hinzugefügt wurden.
Wichtig
Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich quell- und zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.
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();
// Create the SqlBulkCopy object using a connection string
// and the KeepIdentity option.
// In the real world you would not use SqlBulkCopy to move
// data from one table to the other in the same database.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString, SqlBulkCopyOptions.KeepIdentity))
{
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;";
}
}
Hinweise
Sie können ausführliche Informationen zu allen Massenkopieroptionen im SqlBulkCopyOptions Thema erhalten.
Gilt für:
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)
Initialisiert eine neue Instanz der SqlBulkCopy -Klasse unter Verwendung der angegebenen offenen Instanz von SqlConnection . Die SqlBulkCopy -Instanz verhält sich entsprechend den optionen, die imcopyOptions-Parameter verwendet werden sollen. Wenn eine SqlTransaction ungleich Null angegeben wird, erfolgen die Kopiervorgänge innerhalb dieser Transaktion.
public:
SqlBulkCopy(Microsoft::Data::SqlClient::SqlConnection ^ connection, Microsoft::Data::SqlClient::SqlBulkCopyOptions copyOptions, Microsoft::Data::SqlClient::SqlTransaction ^ externalTransaction);public SqlBulkCopy (Microsoft.Data.SqlClient.SqlConnection connection, Microsoft.Data.SqlClient.SqlBulkCopyOptions copyOptions, Microsoft.Data.SqlClient.SqlTransaction externalTransaction);new Microsoft.Data.SqlClient.SqlBulkCopy : Microsoft.Data.SqlClient.SqlConnection * Microsoft.Data.SqlClient.SqlBulkCopyOptions * Microsoft.Data.SqlClient.SqlTransaction -> Microsoft.Data.SqlClient.SqlBulkCopyPublic Sub New (connection As SqlConnection, copyOptions As SqlBulkCopyOptions, externalTransaction As SqlTransaction)Parameter
- connection
- SqlConnection
Die bereits geöffnete SqlConnection-Instanz, mit der der Massenkopiervorgang ausgeführt wird. Wenn Ihre Verbindungszeichenfolge nicht verwendetIntegrated Security = true können Sie verwenden SqlCredential , um die Benutzer-ID und das Kennwort sicherer zu übergeben, als indem Sie die Benutzer-ID und das Kennwort als Text in der Verbindungszeichenfolge angeben.
- copyOptions
- SqlBulkCopyOptions
Eine Kombination von Werten aus der SqlBulkCopyOptions-Enumeration, die festlegt, welche Zeilen der Datenquelle in die Zieltabelle kopiert werden.
- externalTransaction
- SqlTransaction
Eine vorhandene SqlTransaction-Instanz, unter der der Massenkopiervorgang ausgeführt wird.
Hinweise
Wenn Optionen enthalten UseInternalTransaction sind und das externalTransaction Argument nicht NULL ist, wird eine InvalidArgumentException ausgelöst.
Beispiele für die Verwendung SqlBulkCopy in einer Transaktion finden Sie unter Transaktions- und Massenkopiervorgänge.