我有相当多的数据表要批量插入到数据库表中 由于其尺寸较大,一张表需要 5 分钟才能完成插入。 2 table 花了我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, insert2);
}
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;
}
最佳答案
Task.Run 在这里没有添加任何有用的内容。另外,不要尝试在方法的两次运行之间共享单个连接对象。像这样的东西:
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 wait
是一种反模式,但在这里您希望使用它,以便 using
语句在批量加载完成之前不会关闭您的连接完成。
此外,我改用 Task.WaitAll
实际上等待,这比使用Task.WhenAll
然后立即调用Wait
更惯用。
关于c# - 异步批量复制,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38759458/