Rady objednávek pro operace hromadného kopírování

Platí pro: .NET Framework .NET Standard

Stáhnout ADO.NET

Operace hromadného kopírování nabízejí významné výhody výkonu oproti jiným metodám načítání dat do tabulky SQL Serveru. Výkon lze dále vylepšit pomocí nápověd k pořadí. Zadání tipů pro pořadí operací hromadného kopírování může snížit čas vložení seřazených dat do tabulek s clusterovanými indexy.

Ve výchozím nastavení operace hromadného vložení předpokládá, že příchozí data jsou neuspořádaná. SQL Server vynucuje meziřazení těchto dat před jejich hromadným načtením. Pokud víte, že příchozí data jsou už seřazená, můžete pomocí nápovědy k objednávce informovat operaci hromadného kopírování o pořadí řazení všech cílových sloupců, které jsou součástí clusterovaného indexu.

Přidání pořadových hintů do operace hromadného kopírování

Následující příklad hromadně kopíruje data ze zdrojové tabulky v ukázkové databázi AdventureWorks do cílové tabulky ve stejné databázi. Objekt SqlBulkCopyColumnOrderHint je vytvořen k definování pořadí řazení pro sloupec ProductNumber v cílové tabulce. Nápovědu k pořadí pak přidáte do instance SqlBulkCopy, která k výslednému INSERT BULK dotazu připojí příslušný argument nápovědy pořadí.

using System;
using System.Data;
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();

            // Set up the bulk copy object.
            using (SqlBulkCopy bulkCopy =
                       new SqlBulkCopy(connectionString))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoMatchingColumns";

                // Setup an order hint for the ProductNumber column.
                SqlBulkCopyColumnOrderHint hintNumber =
                    new SqlBulkCopyColumnOrderHint("ProductNumber", SortOrder.Ascending);
                bulkCopy.ColumnOrderHints.Add(hintNumber);

                // Write from the source to the destination.
                try
                {
                    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;";
    }
}

Další kroky

• Operace hromadného kopírování na SQL Serveru