Liczba wierszy SQLBulkCopy po ukończeniu

Question

Używam SQLBulkCopy do przenoszenia dużych ilości danych. Zaimplementowałem powiadomienie, aby powiadomić mnie za każdym razem, gdy przetwarzana jest pewna liczba wierszy, ale zdarzenie OnSqlRowsCopied nie uruchamia się po zakończeniu zadania. Jak uzyskać całkowitą liczbę wierszy skopiowanych po ukończeniu skryptu skryptowego SQLBulkCopy?

Answer 1

Myślę, że po zakończeniu należy uruchomić zapytanie COUNT(), tak jak w przykładzie MSDN here.

Poza tym, nie możesz powiedzieć z przodu? na przykład jeśli przekazujesz DataTable do WriteToServer(), wtedy wiesz ile rekordów wykonujesz na .Rows.Count na tym.

Answer 2

Poniższa Hack (przy użyciu odbicia) jest opcją:

/// <summary> 
    /// Helper class to process the SqlBulkCopy class 
    /// </summary> 
    static class SqlBulkCopyHelper 
    { 
     static FieldInfo rowsCopiedField = null; 

     /// <summary> 
     /// Gets the rows copied from the specified SqlBulkCopy object 
     /// </summary> 
     /// <param name="bulkCopy">The bulk copy.</param> 
     /// <returns></returns> 
     public static int GetRowsCopied(SqlBulkCopy bulkCopy) 
     { 
      if (rowsCopiedField == null) 
      { 
       rowsCopiedField = typeof(SqlBulkCopy).GetField("_rowsCopied", BindingFlags.NonPublic | BindingFlags.GetField | BindingFlags.Instance); 
      } 

      return (int)rowsCopiedField.GetValue(bulkCopy); 
     } 
    } 

A następnie użyć klasy następująco:

int rowsCopied = SqlBulkCopyHelper.GetRowsCopied(bulkCopyObjectInYourCode); 

nadzieję, że to pomaga.

Answer 3

Dla kompletności zaimplementowałem jako metodę rozszerzenia i zawarłem przestrzeń nazw. Skopiuj i wklej tę klasę, jeśli chcesz szybkiego rozwiązania, aby uzyskać skopiowaną liczbę. Uwaga: ta liczba nie uwzględnia liczby wierszy faktycznie wstawionych, gdy opcja Ignore Duplicates jest ustawiona na ON.

namespace System.Data.SqlClient 
{  
    using Reflection; 

    public static class SqlBulkCopyExtension 
    { 
     const String _rowsCopiedFieldName = "_rowsCopied"; 
     static FieldInfo _rowsCopiedField = null; 

     public static int RowsCopiedCount(this SqlBulkCopy bulkCopy) 
     { 
      if (_rowsCopiedField == null) _rowsCopiedField = typeof(SqlBulkCopy).GetField(_rowsCopiedFieldName, BindingFlags.NonPublic | BindingFlags.GetField | BindingFlags.Instance);    
      return (int)_rowsCopiedField.GetValue(bulkCopy); 
     } 
    } 
} 

Answer 4

Korzystając SqlBulkCopy.SqlRowsCopied Event (występują za każdym razem, że liczba wierszy podanych przez obiekt NotifyAfter zostały przetworzone) możemy osiągnąć SQLBulkCopy Row liczyć po zakończeniu.

using (SqlBulkCopy s = new SqlBulkCopy(db.Database.Connection as SqlConnection)) 
{ 
    s.SqlRowsCopied += new SqlRowsCopiedEventHandler(sqlBulk_SqlRowsCopied); 
    s.BatchSize = csvFileData.Rows.Count;//DataTable 
    s.NotifyAfter = csvFileData.Rows.Count; 
    foreach (var column in csvFileData.Columns) 
    s.ColumnMappings.Add(column.ToString(), column.ToString()); 
    // Set the timeout. 
    s.BulkCopyTimeout = 60; 
    s.DestinationTableName = "Employee_Data"; 
    s.WriteToServer(csvFileData); 
} 

private static void sqlBulk_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e) 
{ 
    long Count = e.RowsCopied; 
} 

Answer 5

Oto co zrobiłem - to niewielka modyfikacja rozwiązania Rahul Modi w tym wątku (w zasadzie to właśnie stawia inline zdarzeń SqlRowsCopied, co moim zdaniem jest nieco czystsze w tym przypadku niż tworzenie nowego obsługi zdarzeń metoda):

private long InsetData(DataTable dataTable, SqlConnection connection) 
{ 
    using (SqlBulkCopy copier = new SqlBulkCopy(connection)) 
    { 
     var filesInserted = 0L; 

     connection.Open(); 

     copier.DestinationTableName = "dbo.MyTable"; 
     copier.NotifyAfter = dataTable.Rows.Count; 
     copier.SqlRowsCopied += (s, e) => filesInserted = e.RowsCopied; 
     copier.WriteToServer(dataTable); 

     connection.Close(); 

     return filesInserted; 
    } 
}