批量复制的异步

Question

我有很多数据表要批量插入到数据库表中 由于尺寸较大，一张表需要 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.Runs 在这里没有添加任何有用的内容。此外，不要尝试在您的方法的两次运行之间共享单个连接object。比如：

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.WaitAll，它实际上 等待，这比使用 Task.WhenAll 然后立即调用 Wait 更惯用。

Answer 2

Task.WhenAll返回一个Task对象，需要等待或者后面的代码继续正常执行，main方法立即退出。

由于这是一个控制台应用程序，main不能标记为async，你可以使用这个：

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

正常用法是：await (Task.WhenAll(...))，但不能将 Main 标记为 async 方法。