【发布时间】:2021-05-07 20:07:15
【问题描述】:
我正在使用 EFCore.BulkExtensions 将最多 100,000 条记录批量插入到数据库中。
我的问题是,出于某种原因,BulkInsertAsync 没有向数据库插入任何记录。我知道这是一个异步调用,但我等了半个小时,没有插入任何数据。常规的、同步的 BulkInsert 调用有效,但由于占用了大量的处理时间,因此非常不理想。
有人知道为什么BulkInsertAsync 在这种情况下不起作用,而BulkInsert 可以吗?
这是相关代码,它将二进制数据(从另一台机器传输)编组到 C 结构中,将该 C 结构添加到列表中,然后将列表批量插入到数据库中。
IList<object> records = new List<object>();
using (var db = new RecordContext())
{
// keep going until we process all the data; numRecs is at most 100,000
for (int i = 0; i < numRecs; i++)
{
// marshal the data into the struct and map it to its database struct
var tempStruct = Marshal.PtrToStructure<T>(dataPtr);
records.Add(tempStruct);
dataPtr += Marshal.SizeOf<T>();
}
db.BulkInsertAsync(records);
}
这里是相关的上下文代码:
public class RecordContext : DbContext
{
public RecordContext() : base(GetOptions())
{
// disable change tracking for performance
ChangeTracker.AutoDetectChangesEnabled = false;
}
private static DbContextOptions GetOptions()
{
return SqlServerDbContextOptionsExtensions.UseSqlServer(new DbContextOptionsBuilder(), new Settings().recordsConnectionString).Options;
}
// . . .
}
以下连接字符串是从设置中传入的:
Data Source=localhost;Integrated Security=True;TrustServerCertificate=True;ApplicationIntent=ReadWrite;Initial Catalog=Records
【问题讨论】:
标签: c# database entity-framework entity-framework-core efcore.bulkextensions