SqlBulkCopy Klasa

Definicja

Przestrzeń nazw:

Microsoft.Data.SqlClient

Zestaw:

Microsoft.Data.SqlClient.dll

Pakiet:

Microsoft.Data.SqlClient v5.2.0

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 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;";
    }
}

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 wcopyOptions Parametr. 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 oparte na podanymconnectionString . Konstruktor używa klasy , SqlConnection aby zainicjować nowe wystąpienie SqlBulkCopy klasy.
SqlBulkCopy(String, SqlBulkCopyOptions)	Inicjuje i otwiera nowe wystąpienie SqlConnection oparte na podanymconnectionString . Konstruktor używa go SqlConnection do zainicjowania nowego wystąpienia SqlBulkCopy klasy. Wystąpienie SqlConnection zachowuje się zgodnie z opcjami podanymi wcopyOptions Parametr.

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.
ColumnOrderHints	Zwraca kolekcję SqlBulkCopyColumnOrderHint elementów. Wskazówki dotyczące kolejności kolumn opisują kolejność sortowania kolumn w indeksie klastrowanym tabeli docelowej.
DestinationTableName	Nazwa tabeli docelowej na serwerze.
EnableStreaming	Włącza lub wyłącza obiekt do strumieniowego SqlBulkCopyIDataReader przesyłania danych z obiektu
NotifyAfter	Definiuje liczbę wierszy do przetworzenia przed wygenerowaniem zdarzenia powiadomienia.
RowsCopied	Liczba wierszy przetworzonych w trwającej operacji kopiowania zbiorczego.
RowsCopied64	Liczba wierszy przetworzonych w trwającej operacji kopiowania zbiorczego.

Metody

Close()	SqlBulkCopy Zamyka wystąpienie.
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(IDataReader)programu , która kopiuje wszystkie wiersze w tabeli docelowej IDataReader 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. 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(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.