バルクコピーのための非同期

Question

私はデータセットテーブルにバルク挿入するためのかなりのデータテーブルを持っています 大きなサイズのため、1つのテーブルは挿入を完了するのに5分かかりました。 2つのテーブルは、私は今、一括挿入のための非同期操作を行うにしようとしていますが、任意のデータが挿入されていないにも私にエラーを与えてもされていない私に10分

static void Main(string[] args) 
{ 
    DataTableBulkInsert(DataTable1); 
    DataTableBulkInsert(DataTable2); 
} 

public static void DataTableBulkInsert(DataTable Table){ 
    SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(myConnection); 
    sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
    myConnection.Open();      
    sqlBulkCopy.WriteToServer(Table); 
    myConnection.Close(); 
} 

を取りました。例外をキャプチャする方法は？

static void Main(string[] args) 
{ 
    var insert1 = Task.Run(async() => await DataTableBulkInsert(DataTable1); 
    var insert2 = Task.Run(async() => await DataTableBulkInsert(DataTable2); 
    Task.WhenAll(insert1, insert 2); 
} 

public static async Task<Boolean> DataTableBulkInsert(DataTable Table) 
{ 
     try 
     { 
      SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(myConnection); 
      sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
      myConnection.Open();      
      await sqlBulkCopy.WriteToServerAsync(Table); 
      myConnection.Close(); 
     } 
     catch (Exception (e)) 
     { 
     console.write(e); 
     } 
     return true; 
} 

Answer 1

Task.Runは、ここでは何も役立たないものです。また、メソッドの2回の実行の間に、単一の接続オブジェクトを共有しようとしないでください。ような何か：通常

static void Main(string[] args) 
{ 
    var insert1 = DataTableBulkInsert(DataTable1); 
    var insert2 = DataTableBulkInsert(DataTable2); 
    Task.WaitAll(insert1, insert2); 
} 

public static async Task DataTableBulkInsert(DataTable Table) 
{ 
     using(var localConnection = new SqlConnection(/* connection string */)) 
     { 
      SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(localConnection); 
      sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
      localConnection.Open();      
      await sqlBulkCopy.WriteToServerAsync(Table); 
     } 
} 

return awaitはアンチパターンですが、ここであなたはusing文が一括読み込みが完了するまで、あなたの接続を閉じないようにそれを使用したいと思います。

はまた、私はTask.WhenAllを使用するよりも慣用され、その後すぐにWaitを呼び出すTask.WaitAllた実際待機を、使用してに切り替え。

Answer 2

Task.WhenAllを待つする必要があるタスクオブジェクトまたはその通常の実行を継続し、メインメソッドが直ちに終了し、次のコードを返します。

これはコンソールアプリケーションで、メインはasyncとしてマークすることはできませんので、あなたは、この使用することができます。

Task.WhenAll(insert1, insert2).Wait(); // wait for the returned Task object to Complete 

を通常の使用である：await (Task.WhenAll(...))いますが、async方法として主にマークを付けることはできません。