SqlBulkCopy - WriteToServerAsync

Description

The asynchronous version of WriteToServer. Copy all rows from the source to the destination table. It accepts an array of DataRows or DataTable or IDataReader.

using (var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))
{
    connection.Open();
    var sqlBulk = new SqlBulkCopy(connection);

    CancellationTokenSource cancelationTokenSource = new CancellationTokenSource();
    CancellationToken cancellationToken = cancelationTokenSource.Token;
    sqlBulk.DestinationTableName = "Customers";

    // Write from the source to the destination asynchronously.
    var task = sqlBulk.WriteToServerAsync(dt, cancellationToken);
}

Try it

WriteToServerAsync(DataRow[])

The asynchronous version of WriteToServer(DataRow[]), which copies all rows from the supplied DataRow array to a destination table asynchronously.

using (var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))
{
    connection.Open();
    var sqlBulk = new SqlBulkCopy(connection);

    DataRow[] dataRows = dt.Select();
    sqlBulk.DestinationTableName = "Customers";

    // Write from the source to the destination asynchronously.
    Task.Run(async () => { await sqlBulk.WriteToServerAsync(dataRows); }).Wait();
    sqlBulk.Close();
}

Try it

WriteToServerAsync(DataTable)

The asynchronous version of WriteToServer(DataTable), which copies all rows in the supplied DataTable to a destination table asynchronously.

using(var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))
{
    connection.Open();
    var sqlBulk = new SqlBulkCopy(connection);

    sqlBulk.DestinationTableName = "Customers";
    
    // Write from the source to the destination asynchronously.
    Task.Run(async () => { await sqlBulk.WriteToServerAsync(dt); }).Wait();
    sqlBulk.Close();
}

Try it

WriteToServerAsync(IDataReader)

The asynchronous version of WriteToServer(IDataReader), which copies all rows in the supplied IDataReader to a destination table asynchronously.

using (var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))
{
    connection.Open();

    // Get data from the source table as a SqlDataReader.
    SqlCommand commandSourceData = new SqlCommand(
        "SELECT * FROM Customers_Archive;", connection);

    SqlDataReader reader =
        commandSourceData.ExecuteReader();

    using (var dConnection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))
    {
        dConnection.Open();
        using (var sqlBulk = new SqlBulkCopy(dConnection))
        {
            sqlBulk.DestinationTableName = "Customers";
            try
            {
                // Write from the source to the destination asynchronously.
                Task.Run(async () => { await sqlBulk.WriteToServerAsync(reader); }).Wait();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                sqlBulk.Close();
                reader.Close();
            }
        }
    }
}

Try it