SqlBulkCopy Sınıf

Tanım

Ad Alanı:

System.Data.SqlClient

Bütünleştirilmiş Kod:

System.Data.dll

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 örnekteyse, verileri kopyalamak için Transact-SQL INSERT ... SELECT deyimi kullanmak daha kolay ve daha hızlıdır.

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

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. Verileri bir SQL Server tablosuna 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 SqlDateTime 2008'de eklenen tarih/saat türlerinden biri olan bir SQL Server sütununa toplu yükleme DataTable sırasında başarısız olur.

Oluşturucular

SqlBulkCopy(SqlConnection)	öğesinin SqlBulkCopy belirtilen açık örneğini kullanarak sınıfının yeni bir örneğini SqlConnectionbaşlatır.
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)	sağlanan mevcut açık örneğini SqlBulkCopy kullanarak sınıfının yeni bir örneğini SqlConnectionbaş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(String)	Sağlanan connectionStringöğesini temel alarak yeni bir örneğini SqlConnection başlatır ve açar. Oluşturucu, sınıfının yeni bir örneğini SqlBulkCopy başlatmak için öğesini kullanırSqlConnection.
SqlBulkCopy(String, SqlBulkCopyOptions)	Sağlanan connectionStringöğesini temel alarak yeni bir örneğini SqlConnection 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.

Ö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 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.
DestinationTableName	Sunucudaki hedef tablonun adı.
EnableStreaming	Bir nesneden IDataReader veri akışı yapmak için bir SqlBulkCopy nesneyi etkinleştirir veya devre dışı bırakır.
NotifyAfter	Bildirim olayı oluşturmadan önce işlenecek satır sayısını tanımlar.

Yöntemler

Close()	SqlBulkCopy Örneği kapatır.
Equals(Object)	Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler. (Devralındığı yer: Object)
GetHashCode()	Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object)
GetType()	Type Geçerli örneğini alır. (Devralındığı yer: Object)
MemberwiseClone()	Geçerli Objectöğesinin sığ bir kopyasını oluşturur. (Devralındığı yer: Object)
ToString()	Geçerli nesneyi temsil eden dizeyi döndürür. (Devralındığı yer: Object)
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 özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DataRow[]).
WriteToServerAsync(DataRow[], CancellationToken)	Sağlanan dizideki DataRow tüm satırları nesnenin özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DataRow[]). İ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 tüm satırları DataTable 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 tüm satırları DataTable 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)	yalnızca sağlanan DataTable satır durumuyla eşleşen satırları nesnenin özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DataTable, DataRowState).
WriteToServerAsync(DataTable, DataRowState, CancellationToken)	yalnızca sağlanan DataTable satır durumuyla eşleşen satırları nesnenin özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DataTable, DataRowState). İ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 dizideki DbDataReader tüm satırları nesnenin özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DbDataReader).
WriteToServerAsync(DbDataReader, CancellationToken)	Sağlanan dizideki DbDataReader tüm satırları nesnenin özelliği SqlBulkCopy tarafından DestinationTableName belirtilen hedef tabloya kopyalayan zaman uyumsuz sürümüWriteToServer(DbDataReader).
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ü.
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ü. İ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.

Ayrıca bkz.

• SQL Server’da Toplu Kopyalama İşlemleri
• ADO.NET’e Genel Bakış