SqlBulkCopy Klasa

Definicja

Przestrzeń nazw:

Microsoft.Data.SqlClient

Zestaw:

Microsoft.Data.SqlClient.dll

Pakiet:

Microsoft.Data.SqlClient v7.0.1

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 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 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.
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 SqlBulkCopy obiekt do strumieniowego IDataReader 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

Nazwa	Opis
ClearCachedMetadata()	Czyści buforowane metadane tabeli docelowej podczas korzystania z CacheMetadata opcji .
Close()	Zamyka wystąpienie SqlBulkCopy.
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. 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(DbDataReader)	Asynchroniczna wersja WriteToServer(IDataReader)programu , która kopiuje wszystkie wiersze w dostarczonej IDataReader 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.