Not
Åtkomst till denna sida kräver auktorisation. Du kan prova att logga in eller byta katalog.
Åtkomst till denna sida kräver auktorisation. Du kan prova att byta katalog.
Den enklaste metoden för att utföra en SQL Server-masskopieringsåtgärd är att utföra en enda åtgärd mot en databas. Som standard utförs en masskopieringsåtgärd som en isolerad åtgärd: kopieringsåtgärden sker på ett icke-transakterat sätt, utan möjlighet att återställa den.
Anmärkning
Om du behöver återställa hela eller delar av masskopian när ett fel inträffar kan du antingen använda en SqlBulkCopy-hanterad transaktion eller utföra masskopieringsåtgärden i en befintlig transaktion. SqlBulkCopy fungerar också med System.Transactions om anslutningen registreras (implicit eller explicit) i en System.Transactions-transaktion .
Mer information finns i Transaktions- och masskopieringsåtgärder.
De allmänna stegen för att utföra en masskopieringsåtgärd är följande:
Anslut till källservern och hämta de data som ska kopieras. Data kan också komma från andra källor, om det kan hämtas från ett IDataReader- eller DataTable-objekt.
Anslut till målservern (om du inte vill att SqlBulkCopy ska upprätta en anslutning åt dig).
Skapa ett SqlBulkCopy objekt och ange nödvändiga egenskaper.
Ange egenskapen DestinationTableName för att ange måltabellen för bulk-insertoperationen.
Anropa någon av WriteToServer-metoderna .
Du kan också uppdatera egenskaper och anropa WriteToServer igen efter behov.
Anropa Close, eller omslut masskopieringsåtgärderna i en
Using-instruktion.
Försiktighet
Vi rekommenderar att käll- och målkolumndatatyperna matchar. Om datatyperna inte matchar försöker SqlBulkCopy konvertera varje källvärde till måldatatypen med hjälp av de regler som används av Value. Konverteringar kan påverka prestanda och kan också resultera i oväntade fel. En datatyp kan till exempel Double konverteras till en Decimal datatyp för det mesta, men inte alltid.
Example
Följande konsolprogram visar hur du läser in data med hjälp av SqlBulkCopy klassen. I det här exemplet används en SqlDataReader för att kopiera data från tabellen Production.Product i SQL Server AdventureWorks-databasen till en liknande tabell i samma databas.
Viktigt!
Detta exempel kommer inte att köras om du inte har skapat arbetstabellerna enligt beskrivningen i exempeluppsättningen för bulk-kopiering. Den här koden tillhandahålls för att demonstrera syntaxen för att endast använda SqlBulkCopy . Om käll- och måltabellerna finns i samma SQL Server-instans är det enklare och snabbare att använda en Transact-SQL-instruktion INSERT ... SELECT för att kopiera data.
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);
// Print the number of rows processed using the
// RowsCopied property.
Console.WriteLine("{0} rows were processed.",
bulkCopy.RowsCopied);
}
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;";
}
}
Utföra en masskopieringsåtgärd med hjälp av Transact-SQL och kommandoklassen
I följande exempel visas hur du använder ExecuteNonQuery metoden för att köra BULK INSERT-instruktionen.
Anmärkning
Filsökvägen för datakällan är relativ till servern. Serverprocessen måste ha åtkomst till den sökvägen för att masskopieringsåtgärden ska lyckas.
using (SqlConnection connection = New SqlConnection(connectionString))
{
string queryString = "BULK INSERT Northwind.dbo.[Order Details] " +
"FROM 'f:\mydata\data.tbl' " +
"WITH ( FORMATFILE='f:\mydata\data.fmt' )";
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
command.ExecuteNonQuery();
}