完了時のSQLBulkCopy行数

Question

SQLBulkCopyを使用して大量のデータを移動しています。特定の行数が処理されるたびに通知イベントを実装しましたが、ジョブの完了時にOnSqlRowsCopiedイベントは発生しません。 SQLBulkCopy writetoserverが完了したときにコピーされる行の総数を取得するにはどうすればよいですか？

Answer 1

MSDNの例hereのように、テーブルの終了後にCOUNT（）クエリを実行する必要があると思います。

それ以外は、先を教えていただけませんか？例えばDataTableをWriteToServer（）に渡している場合は、.Rows.Countを実行してレコード数を知ることができます。

Answer 2

（リフレクションを使用して）以下のハックはオプションです。その後、

/// <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); 
     } 
    } 

、次のようにクラスを使用します。

int rowsCopied = SqlBulkCopyHelper.GetRowsCopied(bulkCopyObjectInYourCode); 

・ホープ、このことができます。

Answer 3

私は拡張メソッドとして実装しており、名前空間を含んでいます。高速なソリューションでコピーされたカウントを取得する場合は、このクラスをコピーして貼り付けます。注：このカウントでは、[重複を無視]が[オン]に設定されているときに実際に挿入された行の数は考慮されません。 SqlBulkCopy.SqlRowsCopied Eventを使用することにより

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

（NotifyAfterプロパティで指定した行数が処理されたことをするたびに発生）、我々はときに完全SQLBulkCopy行カウントを達成することができます。ここで

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

は、私がやったことだ - それは、基本的にはそれだけでSqlRowsCopiedイベントをインラインで置く（このスレッドでラーフルモディのソリューションのわずかな変更だ私は新しいイベントハンドラを作成するよりも、このインスタンスのビットクリーンだと思ういます法）：

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