SqlBulkCopy.NotifyAfter Propriété

Définition

Espace de noms:

Microsoft.Data.SqlClient

Assembly:

Microsoft.Data.SqlClient.dll

Paquet:

Microsoft.Data.SqlClient v5.2.0

Définit le nombre de lignes à traiter avant de générer un événement de notification.

public:
 property int NotifyAfter { int get(); void set(int value); };

public int NotifyAfter { get; set; }

member this.NotifyAfter : int with get, set

Public Property NotifyAfter As Integer

Valeur de propriété

Int32

Valeur entière de la propriété NotifyAfter ou zéro si la propriété n’a pas été définie.

Exemples

L’application console suivante montre comment charger des données en bloc à l’aide d’une connexion déjà ouverte. La NotifyAfter propriété est définie de telle sorte que le gestionnaire d’événements soit appelé après chaque copie de 50 lignes dans la table.

Dans cet exemple, la connexion est d’abord utilisée pour lire les données d’une table SQL Server vers une SqlDataReader instance. Ensuite, une deuxième connexion est ouverte pour copier les données en bloc. Notez que les données sources n’ont pas besoin d’être situées sur SQL Server ; vous pouvez utiliser n’importe quelle source de données qui peut être lue dans un IDataReader ou chargée dans un DataTable.

Important

Cet exemple ne s’exécutera que si vous avez créé les tables de travail comme décrit dans Configuration de l’exemple de copie en bloc. Ce code est fourni uniquement pour illustrer la syntaxe de l’utilisation de SqlBulkCopy. Si les tables source et de destination se trouvent dans la même instance SQL Server, il est plus facile et plus rapide d’utiliser une instruction Transact-SQL INSERT … SELECT pour copier les données.

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("NotifyAfter Sample");
            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();

            // Create the SqlBulkCopy object using a connection string. 
            // In the real world you would not use SqlBulkCopy to move
            // data from one table to the other in the same database.
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionString))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoMatchingColumns";

                // Set up the event handler to notify after 50 rows.
                bulkCopy.SqlRowsCopied +=
                    new SqlRowsCopiedEventHandler(OnSqlRowsCopied);
                bulkCopy.NotifyAfter = 50;

                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 void OnSqlRowsCopied(
        object sender, SqlRowsCopiedEventArgs e)
    {
        Console.WriteLine("Copied {0} so far...", e.RowsCopied);
    }
    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;";
    }
}

Remarques

Cette propriété est conçue pour les composants d’interface utilisateur qui illustrent la progression d’une opération de copie en bloc. Il indique le nombre de lignes à traiter avant de générer un événement de notification. La NotifyAfter propriété peut être définie à tout moment, même lorsqu’une opération de copie en bloc est en cours. Les modifications apportées lors d’une opération de copie en bloc prennent effet après la notification suivante. Le nouveau paramètre s’applique à toutes les opérations suivantes sur la même instance.

Si NotifyAfter est défini sur un nombre inférieur à zéro, un ArgumentOutOfRangeException est levée.