Åtgärder för enkel masskopiering
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.
Kommentar
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 de kan hämtas från ett objekt eller DataTable ett IDataReader 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 massinfogningsåtgärden.
Anropa någon av WriteToServer-metoderna .
Du kan också uppdatera egenskaper och anropa WriteToServer igen efter behov.
Anropa Closeeller omslut masskopieringsåtgärderna i en
Using-instruktion.
Varning
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.
Exempel
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!
Det här exemplet körs inte om du inte har skapat arbetstabellerna enligt beskrivningen i Masskopieringsexempel. 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.
static void Main()
{
var connectionString = GetConnectionString();
// Open a sourceConnection to the AdventureWorks database.
using (SqlConnection sourceConnection =
new(connectionString))
{
sourceConnection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoMatchingColumns;",
sourceConnection);
long countStart = Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Get data from the source table as a SqlDataReader.
SqlCommand commandSourceData = new(
"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(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(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 = 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();
}
}
}
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
Throw New NotImplementedException()
End Function
End Module
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.
Kommentar
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 connection As SqlConnection = New SqlConnection(connectionString)
Dim queryString As String = _
"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()
End Using
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();
}