SqlBulkCopy Sınıf

Tanım

Ad Alanı:

Microsoft.Data.SqlClient

Bütünleştirilmiş Kod:

Microsoft.Data.SqlClient.dll

Paket:

Microsoft.Data.SqlClient v7.0.1

Bir SQL Server tablosunu başka bir kaynaktan alınan verilerle verimli bir şekilde toplu 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ı, SqlBulkCopy sınıfını kullanarak verilerin nasıl yükleneceğini gösterir. Bu örnekte, SQL Server SqlDataReader veritabanındaki Production.Product tablosundaki verileri aynı veritabanındaki benzer bir tabloya kopyalamak için kullanılır.

Important

Bu örnek, Toplu Kopyalama Örneği Kurulumubölümünde açıklandığı gibi çalışma tablolarını oluşturmadığınız sürece çalışmaz.

Bu kod, yalnızca SqlBulkCopy'yi kullanmaya yönelik söz dizimini göstermek için sağlanır. Kaynak ve hedef tablolar aynı SQL Server örneğindeyse, verileri kopyalamak için Transact-SQL INSERT … SELECT deyimi kullanmak 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. 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 tablolarına veri yazmak için kullanılabilir. Ancak, veri kaynağı SQL Server ile sınırlı değildir; veriler bir DataTable örneğine yüklenebildiği veya IDataReader örneğiyle okunabildiği sürece herhangi bir veri kaynağı kullanılabilir. SqlBulkCopy, SQL Server 2008'de eklenen tarih/saat türlerinden biri olan SQL Server sütununa SqlDateTime türünde bir DataTable sütununu toplu yüklerken başarısız olur.

Oluşturucular

Name	Description
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	sağlanan mevcut açık örneğini kullanarak sınıfının yeni bir örneğini SqlBulkCopySqlConnectionbaşlatır. Örnek SqlBulkCopy , parametresinde copyOptions sağlanan seçeneklere göre davranır. Null SqlTransaction olmayan bir değer sağlanırsa kopyalama işlemleri bu işlem içinde gerçekleştirilir.
SqlBulkCopy(SqlConnection)	SqlBulkCopy sınıfının yeni bir örneğini, belirtilen açık SqlConnection örneğini kullanarak başlatır.
SqlBulkCopy(String, SqlBulkCopyOptions)	Sağlanan SqlConnection'i temel alarak connectionString'nin yeni bir örneğini başlatır ve açar. Oluşturucu, sınıfın yeni bir örneğini SqlBulkCopy başlatmak için bunu SqlConnection kullanır. Örnek SqlConnection , parametresinde copyOptions sağlanan seçeneklere göre davranır.
SqlBulkCopy(String)	Sağlanan SqlConnection'i temel alarak connectionString'nin yeni bir örneğini başlatır ve açar. Oluşturucu, SqlConnection öğesini kullanarak SqlBulkCopy sınıfının yeni bir öbeğini başlatır.

Özellikler

Name	Description
BatchSize	Her bir veri kümesindeki satır sayısı. Her toplu işlemin sonunda, toplu iş içindeki satırlar sunucuya gönderilir.
BulkCopyTimeout	İşlemin zaman aşımına uğramadan önce tamamlanması için 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 sırası 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

Name	Description
ClearCachedMetadata()	seçeneği kullanılırken CacheMetadata önbelleğe alınan hedef tablo meta verilerini temizler.
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, 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(DataTable)	Sağlanan DataTable içindeki tüm satırları nesnenin DestinationTableName özelliği tarafından belirtilen bir 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 bir hedef tabloya SqlBulkCopy kopyalar.
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ü. İptal belirteci, komut zaman aşımı tamamlanmadan önce işlemin terk edilmesi isteğinde bulunmak için kullanılabilir. Özel durumlar döndürülen Görev nesnesi aracılığıyla bildirilir.
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(DataTable, CancellationToken)	sağlanan içindeki tüm satırları DataTable nesnenin WriteToServer(DataTable)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptal belirteci, komut zaman aşımı tamamlanmadan önce işlemin terk edilmesi isteğinde bulunmak için kullanılabilir. Özel durumlar döndürülen Görev nesnesi aracılığıyla bildirilir.
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. İptal belirteci, komut zaman aşımı tamamlanmadan önce işlemin terk edilmesi isteğinde bulunmak için kullanılabilir. Özel durumlar döndürülen Görev nesnesi aracılığıyla 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)	sağlanan içindeki tüm satırları DataTable nesnenin WriteToServer(DataTable)ö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ü. İptal belirteci, komut zaman aşımı tamamlanmadan önce işlemin terk edilmesi isteğinde bulunmak için kullanılabilir. Özel durumlar döndürülen Görev nesnesi aracılığıyla bildirilir.
WriteToServerAsync(DbDataReader)	sağlanan içindeki tüm satırları IDataReader 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 tüm satırları IDataReader nesnenin WriteToServer(IDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü. İptal belirteci, komut zaman aşımı tamamlanmadan önce işlemin terk edilmesi isteğinde bulunmak için kullanılabilir. Özel durumlar döndürülen Görev nesnesi aracılığıyla bildirilir.
WriteToServerAsync(IDataReader)	sağlanan içindeki tüm satırları IDataReader nesnenin WriteToServer(IDataReader)özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümü.

Ekinlikler

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

Belirtik Arabirim Kullanımları

Name	Description
IDisposable.Dispose()	Sınıfın geçerli örneği SqlBulkCopy tarafından kullanılan tüm kaynakları serbest bırakır.