SqlBulkCopy.SqlRowsCopied Evento

Definición

Espacio de nombres:

Microsoft.Data.SqlClient

Ensamblado:

Microsoft.Data.SqlClient.dll

Paquete:

Microsoft.Data.SqlClient v5.2.0

Se produce cada vez que se ha procesado el número de filas especificado por la propiedad NotifyAfter.

public:
 event Microsoft::Data::SqlClient::SqlRowsCopiedEventHandler ^ SqlRowsCopied;

public event Microsoft.Data.SqlClient.SqlRowsCopiedEventHandler SqlRowsCopied;

member this.SqlRowsCopied : Microsoft.Data.SqlClient.SqlRowsCopiedEventHandler 

Public Custom Event SqlRowsCopied As SqlRowsCopiedEventHandler 

Tipo de evento

SqlRowsCopiedEventHandler

Ejemplos

La siguiente aplicación de consola muestra cómo cargar datos de forma masiva mediante una conexión que ya está abierta. La NotifyAfter propiedad se establece para que se llame al controlador de eventos después de cada 50 filas copiadas en la tabla.

En este ejemplo, la conexión se usa primero para leer datos de una tabla de SQL Server a una SqlDataReader instancia de . Tenga en cuenta que los datos de origen no tienen que ubicarse en SQL Server; puede usar cualquier origen de datos que se pueda leer en o IDataReader cargar en .DataTable

Importante

Este ejemplo no se ejecuta a menos que haya creado las tablas de trabajo como se describe en Configuración de ejemplos de copia masiva. Este código se proporciona para mostrar la sintaxis para usar SqlBulkCopy. Si las tablas de origen y destino están en la misma instancia de SQL Server, es más fácil y rápido usar una instrucción Transact-SQL INSERT … SELECT para copiar los datos.

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

Comentarios

Tenga en cuenta que la configuración de NotifyAfter y BatchSize son independientes. La recepción de un SqlRowsCopied evento no implica que se hayan enviado filas al servidor ni se hayan confirmado.

No se puede llamar a SqlBulkCopy.Close (Close()) o SqlConnection.Close (Close()) desde este evento. Si lo hace, se producirá una InvalidOperationException excepción y el estado del SqlBulkCopy objeto no cambiará. Si el usuario quiere cancelar la operación del evento, se puede usar la Abort propiedad de SqlRowsCopiedEventArgs . (Vea Transacciones y Operaciones de copia masiva para obtener ejemplos que usan la Abort propiedad ).

No se admite ninguna acción, como la actividad de transacción, en la conexión durante la ejecución de la operación de copia masiva y se recomienda no usar la misma conexión usada durante el SqlRowsCopied evento. Sin embargo, puede abrir una conexión diferente.