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 element SqlDataReader jest używany do kopiowania danych z tabeli Production.Product w bazie danych AdventureWorks SQL Server do podobnej tabeli w tej samej bazie danych.

Ważna

Ten przykład programu się nie uruchomi, chyba że tabele robocze zostaną utworzone zgodnie z opisem w Konfiguracji 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 programu SQL Server, łatwiej i szybciej używać instrukcji Transact-SQL INSERT ... SELECT do kopiowania 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 programu SQL Server (na przykład instrukcje INSERT), ale SqlBulkCopy oferują znaczącą przewagę nad nimi.

Klasa SqlBulkCopy służy do zapisywania danych tylko w tabelach SQL Server. Jednak źródło danych nie jest ograniczone do SQL Server; można użyć dowolnego źródła danych, o ile dane można załadować do wystąpienia DataTable lub odczytywać z wystąpieniem IDataReader.

SqlBulkCopy zakończy się niepowodzeniem, gdy ładowanie zbiorcze kolumny DataTable typu SqlDateTime do kolumny SQL Server, której typ jest jednym z typów daty/godziny dodanych w SQL Server 2008 roku.

Konstruktory

Nazwa	Opis
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	Inicjuje nowe wystąpienie SqlBulkCopy klasy przy użyciu dostarczonego istniejącego otwartego wystąpienia klasy SqlConnection. Wystąpienie SqlBulkCopy działa zgodnie z opcjami podanymi w parametrze copyOptions . Jeśli podano wartość inną niż null SqlTransaction , operacje kopiowania zostaną wykonane w ramach tej transakcji.
SqlBulkCopy(SqlConnection)	Inicjuje nowe wystąpienie SqlBulkCopy klasy przy użyciu określonego otwartego wystąpienia klasy SqlConnection.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inicjuje i otwiera nowe wystąpienie SqlConnection na podstawie podanego obiektu connectionString. Konstruktor używa tego SqlConnection do inicjowania nowego wystąpienia SqlBulkCopy klasy. Wystąpienie SqlConnection działa zgodnie z opcjami podanymi w parametrze copyOptions .
SqlBulkCopy(String)	Inicjuje i otwiera nowe wystąpienie SqlConnection na podstawie podanego obiektu connectionString. Konstruktor używa SqlConnection do zainicjowania nowego wystąpienia klasy SqlBulkCopy.

Właściwości

Nazwa	Opis
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 przesyłania strumieniowego IDataReader danych z obiektu.
NotifyAfter	Definiuje liczbę wierszy do przetworzenia przed wygenerowaniem zdarzenia powiadomienia.

Metody

Nazwa	Opis
Close()	Zamyka wystąpienie SqlBulkCopy.
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()	Pobiera Type bieżącego wystąpienia. (Odziedziczone po Object)
MemberwiseClone()	Tworzy płytkią kopię bieżącego Object. (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, DataRowState)	Kopiuje tylko wiersze zgodne ze stanem podanego wiersza w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServer(DataTable)	Kopiuje wszystkie wiersze z dostarczonego DataTable do tabeli docelowej określonej przez właściwość DestinationTableName obiektu SqlBulkCopy.
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 z dostarczonego IDataReader do tabeli docelowej określonej przez właściwość DestinationTableName obiektu SqlBulkCopy.
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 porzucenia operacji przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Zadania.
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(DataTable, CancellationToken)	Asynchroniczna wersja WriteToServer(DataTable)programu , która kopiuje wszystkie wiersze w dostarczonej DataTable tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania porzucenia operacji przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Zadania.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	Asynchroniczna wersja WriteToServer(DataTable, DataRowState)programu , która kopiuje tylko wiersze zgodne ze stanem podanego wiersza w tabeli DataTable docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania porzucenia operacji przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Zadania.
WriteToServerAsync(DataTable, DataRowState)	Asynchroniczna wersja WriteToServer(DataTable, DataRowState)programu , która kopiuje tylko wiersze zgodne ze stanem podanego wiersza w tabeli DataTable docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.
WriteToServerAsync(DataTable)	Asynchroniczna wersja WriteToServer(DataTable)programu , która kopiuje wszystkie wiersze w dostarczonej DataTable 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(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(IDataReader, CancellationToken)	Asynchroniczna wersja WriteToServer(IDataReader)programu , która kopiuje wszystkie wiersze w dostarczonej IDataReader tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu. Token anulowania może służyć do żądania porzucenia operacji przed upływem limitu czasu polecenia. Wyjątki będą zgłaszane za pośrednictwem zwróconego obiektu Zadania.
WriteToServerAsync(IDataReader)	Asynchroniczna wersja WriteToServer(IDataReader)programu , która kopiuje wszystkie wiersze w dostarczonej IDataReader tabeli docelowej określonej przez DestinationTableName właściwość SqlBulkCopy obiektu.

Zdarzenia

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

Jawne implementacje interfejsu

Nazwa	Opis
IDisposable.Dispose()	Zwalnia wszystkie zasoby używane przez bieżące wystąpienie SqlBulkCopy klasy.

Zobacz też

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