SqlBulkCopy Klasa

Definicja

Przestrzeń nazw:

System.Data.SqlClient

Zestaw:

System.Data.dll

Umożliwia wydajne zbiorcze ładowanie tabeli SQL Server z danymi z innego źródła.

public ref class SqlBulkCopy sealed : IDisposable

public sealed class SqlBulkCopy : IDisposable

type SqlBulkCopy = class
    interface IDisposable

Public NotInheritable Class SqlBulkCopy
Implements IDisposable

Dziedziczenie

Object

SqlBulkCopy

Implementuje

IDisposable

Przykłady

Poniższa aplikacja konsolowa pokazuje, jak ładować dane przy użyciu SqlBulkCopy klasy . W tym przykładzie SqlDataReader element jest używany do kopiowania danych z tabeli Production.Product w bazie danych SQL Server AdventureWorks do podobnej tabeli w tej samej bazie danych.

Ważne

Ten przykład nie zostanie uruchomiony, chyba że utworzono tabele robocze zgodnie z opisem w temacie Konfiguracja przykładu kopiowania zbiorczego. Ten kod jest dostarczany w celu zademonstrowania składni tylko przy użyciu narzędzia SqlBulkCopy . Jeśli tabele źródłowe i docelowe znajdują się w tym samym wystąpieniu SQL Server, łatwiej i szybciej jest użyć instrukcji Języka Transact-SQL INSERT ... SELECT do skopiowania danych.

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

Uwagi

Microsoft SQL Server zawiera popularne narzędzie wiersza polecenia o nazwie bcp do przenoszenia danych z jednej tabeli do innej, zarówno na jednym serwerze, jak i między serwerami. Klasa SqlBulkCopy umożliwia pisanie rozwiązań kodu zarządzanego, które zapewniają podobne funkcje. Istnieją inne sposoby ładowania danych do tabeli SQL Server (na przykład instrukcje INSERT), ale SqlBulkCopy oferują znaczącą przewagę nad nimi.

Klasa może służyć do zapisywania SqlBulkCopy danych tylko do SQL Server tabel. Jednak źródło danych nie jest ograniczone do SQL Server; można użyć dowolnego źródła danych, o ile dane mogą być ładowane do DataTable wystąpienia lub odczytywane z wystąpieniemIDataReader.

SqlBulkCopyNie powiedzie się, gdy zbiorcze ładowanie DataTable kolumny typu SqlDateTime do kolumny SQL Server, której typem jest jeden z typów daty/godziny dodanych w SQL Server 2008 r.

Konstruktory

SqlBulkCopy(SqlConnection)	Inicjuje nowe wystąpienie SqlBulkCopy klasy przy użyciu określonego otwartego wystąpienia klasy SqlConnection.
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inicjuje nowe wystąpienie SqlBulkCopy klasy przy użyciu dostarczonego istniejącego otwartego wystąpienia klasy SqlConnection. Wystąpienie SqlBulkCopy zachowuje się zgodnie z opcjami podanymi w parametrze copyOptions . Jeśli podano wartość inną niż null SqlTransaction , operacje kopiowania zostaną wykonane w ramach tej transakcji.
SqlBulkCopy(String)	Inicjuje i otwiera nowe wystąpienie SqlConnection klasy na podstawie podanego connectionStringelementu . Konstruktor używa klasy , SqlConnection aby zainicjować nowe wystąpienie SqlBulkCopy klasy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inicjuje i otwiera nowe wystąpienie SqlConnection klasy na podstawie podanego connectionStringelementu . Konstruktor używa go SqlConnection do zainicjowania nowego wystąpienia SqlBulkCopy klasy. Wystąpienie SqlConnection zachowuje się zgodnie z opcjami podanymi w parametrze copyOptions .

Właściwości

BatchSize	Liczba wierszy w każdej partii. Na końcu każdej partii wiersze w partii są wysyłane do serwera.
BulkCopyTimeout	Liczba sekund ukończenia operacji przed upływem limitu czasu.
ColumnMappings	Zwraca kolekcję SqlBulkCopyColumnMapping elementów. Mapowania kolumn definiują relacje między kolumnami w źródle danych i kolumnami w miejscu docelowym.
DestinationTableName	Nazwa tabeli docelowej na serwerze.
EnableStreaming	Włącza lub wyłącza SqlBulkCopy obiekt do strumieniowego IDataReader przesyłania danych z obiektu.
NotifyAfter	Definiuje liczbę wierszy do przetworzenia przed wygenerowaniem zdarzenia powiadomienia.

Metody

Close()	SqlBulkCopy Zamyka wystąpienie.
Equals(Object)	Określa, czy dany obiekt jest taki sam, jak bieżący obiekt. (Odziedziczone po Object)
GetHashCode()	Służy jako domyślna funkcja skrótu. (Odziedziczone po Object)
GetType()	Type Pobiera wartość bieżącego wystąpienia. (Odziedziczone po Object)
MemberwiseClone()	Tworzy płytkią kopię bieżącego Objectelementu . (Odziedziczone po Object)
ToString()	Zwraca ciąg reprezentujący bieżący obiekt. (Odziedziczone po Object)
WriteToServer(DataRow[])	Kopiuje wszystkie wiersze z podanej DataRow tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServer(DataTable)	Kopiuje wszystkie wiersze w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServer(DataTable, DataRowState)	Kopiuje tylko wiersze zgodne z podanym stanem wiersza w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServer(DbDataReader)	Kopiuje wszystkie wiersze z podanej DbDataReader tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServer(IDataReader)	Kopiuje wszystkie wiersze w dostarczonej IDataReader tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DataRow[])	Asynchroniczna wersja WriteToServer(DataRow[])elementu , która kopiuje wszystkie wiersze z dostarczonej DataRow tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DataRow[], CancellationToken)	Asynchroniczna wersja WriteToServer(DataRow[])elementu , która kopiuje wszystkie wiersze z dostarczonej DataRow tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania, aby operacja została porzucona przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Task.
WriteToServerAsync(DataTable)	Asynchroniczna wersja WriteToServer(DataTable)programu , która kopiuje wszystkie wiersze w tabeli docelowej DataTable określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DataTable, CancellationToken)	Asynchroniczna wersja WriteToServer(DataTable)programu , która kopiuje wszystkie wiersze w tabeli docelowej DataTable określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania, aby operacja została porzucona przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Task.
WriteToServerAsync(DataTable, DataRowState)	Wersja WriteToServer(DataTable, DataRowState)asynchroniczna programu , która kopiuje tylko wiersze zgodne z podanym stanem wiersza w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	Wersja WriteToServer(DataTable, DataRowState)asynchroniczna programu , która kopiuje tylko wiersze zgodne z podanym stanem wiersza w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania, aby operacja została porzucona przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Task.
WriteToServerAsync(DbDataReader)	Asynchroniczna wersja WriteToServer(DbDataReader)elementu , która kopiuje wszystkie wiersze z dostarczonej DbDataReader tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DbDataReader, CancellationToken)	Asynchroniczna wersja WriteToServer(DbDataReader)elementu , która kopiuje wszystkie wiersze z dostarczonej DbDataReader tablicy do tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(IDataReader)	Asynchroniczna wersja WriteToServer(IDataReader)programu , która kopiuje wszystkie wiersze w tabeli docelowej IDataReader określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(IDataReader, CancellationToken)	Asynchroniczna wersja WriteToServer(IDataReader)programu , która kopiuje wszystkie wiersze w tabeli docelowej IDataReader określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania, aby operacja została porzucona przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Task.

Zdarzenia

SqlRowsCopied

Występuje za każdym razem, gdy liczba wierszy określonych przez NotifyAfter właściwość została przetworzona.

Jawne implementacje interfejsu

IDisposable.Dispose()

Zwalnia wszystkie zasoby używane przez bieżące wystąpienie klasy SqlBulkCopy.

Zobacz też

• Operacje kopiowania masowego w programie SQL Server
• Omówienie ADO.NET