SqlBulkCopy Sınıf

Tanım

Ad Alanı:

Microsoft.Data.SqlClient

Bütünleştirilmiş Kod:

Microsoft.Data.SqlClient.dll

Paket:

Microsoft.Data.SqlClient v5.2.0

Bir SQL Server tablosunu başka bir kaynaktan alınan verilerle verimli bir şekilde toplu olarak yüklemenizi sağlar.

public ref class SqlBulkCopy sealed : IDisposable

public sealed class SqlBulkCopy : IDisposable

type SqlBulkCopy = class
    interface IDisposable

Public NotInheritable Class SqlBulkCopy
Implements IDisposable

Devralma

Object

SqlBulkCopy

Uygulamalar

IDisposable

Örnekler

Aşağıdaki konsol uygulaması, sınıfını kullanarak veri yükleme işlemini SqlBulkCopy gösterir. Bu örnekte, SqlDataReaderSQL Server AdventureWorks veritabanındaki Production.Product tablosundaki verileri aynı veritabanındaki benzer bir tabloya kopyalamak için kullanılır.

Önemli

Bu örnek, Toplu Kopyalama Örneği Kurulumu'nda açıklandığı gibi iş tablolarını oluşturmadığınız sürece çalışmaz. Bu kod, yalnızca SqlBulkCopy kullanımına yönelik söz dizimini göstermek için sağlanır. Kaynak ve hedef tablolar aynı SQL Server örneğindeyse, transact-SQL INSERT … SELECT deyimini kullanarak verileri kopyalamak daha kolay ve daha hızlıdır.

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

Açıklamalar

Microsoft SQL Server, tek bir sunucuda veya sunucular arasında verileri bir tablodan diğerine taşımak için bcp adlı popüler bir komut istemi yardımcı programı içerir. sınıfı, SqlBulkCopy benzer işlevler sağlayan yönetilen kod çözümleri yazmanızı sağlar. Bir SQL Server tablosuna veri yüklemenin başka yolları da vardır (örneğin INSERT deyimleri), ancak SqlBulkCopy bunlara göre önemli bir performans avantajı sunar. SqlBulkCopy sınıfı yalnızca SQL Server tablolara veri yazmak için kullanılabilir. Ancak, veri kaynağı SQL Server ile sınırlı değildir; veriler bir örneğe yüklenebildiği veya bir örnekle okunabildiği sürece herhangi bir DataTableIDataReader veri kaynağı kullanılabilir. SqlBulkCopytürü, SQL Server 2008'de eklenen tarih/saat türlerinden biri olan bir SQL Server sütununa toplu yüklendiğinde DataTableSqlDateTime başarısız olur.

Oluşturucular

SqlBulkCopy(SqlConnection)	belirtilen açık örneğini kullanarak sınıfının yeni bir örneğini SqlBulkCopySqlConnection başlatır.
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	sağlanan mevcut açık örneğini kullanarak sınıfının yeni bir örneğini SqlBulkCopySqlConnection başlatır. Örnek,SqlBulkCopy copyOptions Parametre. Null SqlTransaction olmayan bir değer sağlanırsa kopyalama işlemleri bu işlem içinde gerçekleştirilir.
SqlBulkCopy(String)	Sağlanana göre yeni bir örneğini SqlConnection başlatır ve açar connectionString . Oluşturucu, sınıfının yeni bir örneğini SqlBulkCopy başlatmak için öğesini kullanırSqlConnection.
SqlBulkCopy(String, SqlBulkCopyOptions)	Sağlanana göre yeni bir örneğini SqlConnection başlatır ve açar connectionString . Oluşturucu, sınıfın yeni bir örneğini SqlBulkCopy başlatmak için bunu SqlConnection kullanır. Örnek,SqlConnection copyOptions Parametre.

Özellikler

BatchSize	Her toplu işlemdeki satır sayısı. Her toplu iş sonunda, toplu iş içindeki satırlar sunucuya gönderilir.
BulkCopyTimeout	İşlemin zaman aşımına uğramadan önce tamamlanması için gereken saniye sayısı.
ColumnMappings	Bir öğe koleksiyonu SqlBulkCopyColumnMapping döndürür. Sütun eşlemeleri, veri kaynağındaki sütunlarla hedefteki sütunlar arasındaki ilişkileri tanımlar.
ColumnOrderHints	Bir öğe koleksiyonu SqlBulkCopyColumnOrderHint döndürür. Sütun düzeni ipuçları, hedef tablonun kümelenmiş dizinindeki sütunların sıralama düzenini açıklar.
DestinationTableName	Sunucudaki hedef tablonun adı.
EnableStreaming	Nesneden IDataReader veri akışı yapmak için nesneyi SqlBulkCopy etkinleştirir veya devre dışı bırakır
NotifyAfter	Bildirim olayı oluşturmadan önce işlenecek satır sayısını tanımlar.
RowsCopied	Devam eden toplu kopyalama işleminde işlenen satır sayısı.
RowsCopied64	Devam eden toplu kopyalama işleminde işlenen satır sayısı.

Yöntemler

Close()	SqlBulkCopy Örneği kapatır.
WriteToServer(DataRow[])	Sağlanan DataRow dizideki tüm satırları nesnenin DestinationTableName özelliği tarafından belirtilen hedef tabloya SqlBulkCopy kopyalar.
WriteToServer(DataTable)	Sağlanan DataTable içindeki tüm satırları nesnenin DestinationTableName özelliği tarafından belirtilen hedef tabloya SqlBulkCopy kopyalar.
WriteToServer(DataTable, DataRowState)	Yalnızca sağlanan DataTable içindeki sağlanan satır durumuyla eşleşen satırları nesnenin özelliği tarafından DestinationTableName belirtilen hedef tabloya SqlBulkCopy kopyalar.
WriteToServer(DbDataReader)	Sağlanan DbDataReader dizideki tüm satırları nesnenin DestinationTableName özelliği tarafından belirtilen hedef tabloya SqlBulkCopy kopyalar.
WriteToServer(IDataReader)	Sağlanan IDataReader içindeki tüm satırları nesnenin DestinationTableName özelliği tarafından belirtilen hedef tabloya SqlBulkCopy kopyalar.
WriteToServerAsync(DataRow[])	Sağlanan dizideki DataRow tüm satırları nesnenin WriteToServer(DataRow[])özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü.
WriteToServerAsync(DataRow[], CancellationToken)	Sağlanan dizideki DataRow tüm satırları nesnenin WriteToServer(DataRow[])özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptali belirteci, işlem komut zaman aşımı dolmadan işlemin iptal edilmesini istemek için kullanılabilir. Özel durumlar döndürülen Görev nesnesi ile bildirilir.
WriteToServerAsync(DataTable)	Sağlanan içindeki DataTable tüm satırları nesnenin WriteToServer(DataTable)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü.
WriteToServerAsync(DataTable, CancellationToken)	Sağlanan içindeki DataTable tüm satırları nesnenin WriteToServer(DataTable)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptali belirteci, işlem komut zaman aşımı dolmadan işlemin iptal edilmesini istemek için kullanılabilir. Özel durumlar döndürülen Görev nesnesi ile bildirilir.
WriteToServerAsync(DataTable, DataRowState)	öğesinin zaman uyumsuz sürümüWriteToServer(DataTable, DataRowState), yalnızca sağlanan DataTable içindeki sağlanan satır durumuyla eşleşen satırları nesnenin SqlBulkCopy özelliği tarafından DestinationTableName belirtilen hedef tabloya kopyalar.
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	öğesinin zaman uyumsuz sürümüWriteToServer(DataTable, DataRowState), yalnızca sağlanan DataTable içindeki sağlanan satır durumuyla eşleşen satırları nesnenin SqlBulkCopy özelliği tarafından DestinationTableName belirtilen hedef tabloya kopyalar. İptali belirteci, işlem komut zaman aşımı dolmadan işlemin iptal edilmesini istemek için kullanılabilir. Özel durumlar döndürülen Görev nesnesi ile bildirilir.
WriteToServerAsync(DbDataReader)	Sağlanan içindeki IDataReader tüm satırları nesnenin WriteToServer(IDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü.
WriteToServerAsync(DbDataReader, CancellationToken)	Sağlanan dizideki DbDataReader tüm satırları nesnenin WriteToServer(DbDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptali belirteci, işlem komut zaman aşımı dolmadan işlemin iptal edilmesini istemek için kullanılabilir. Özel durumlar döndürülen Görev nesnesi ile bildirilir.
WriteToServerAsync(IDataReader)	Sağlanan içindeki IDataReader tüm satırları nesnenin WriteToServer(IDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü.
WriteToServerAsync(IDataReader, CancellationToken)	Sağlanan içindeki IDataReader tüm satırları nesnenin WriteToServer(IDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptali belirteci, işlem komut zaman aşımı dolmadan işlemin iptal edilmesini istemek için kullanılabilir. Özel durumlar döndürülen Görev nesnesi ile bildirilir.

Ekinlikler

SqlRowsCopied

özelliği tarafından NotifyAfter belirtilen satır sayısı her işlendiği zaman gerçekleşir.

Belirtik Arabirim Kullanımları

IDisposable.Dispose()

SqlBulkCopy sınıfının geçerli örneği tarafından kullanılan tüm kaynakları serbest bırakır.