如何循环创建和删除 Entity Framework 中的记录
How do I create and delete records in Entity Framework in a loop
我们有一个 postgres 数据库来存储 Event
个对象并使用 Entity Framework 作为我们的 ORM。
在定期运行的后台服务中,我们想要获取所有过期事件,将它们从 Event
table 中删除并将它们移动到 EventArchive
table.
我们有一项服务 class ExpiredEventService
,它检索所有过期事件并将它们传递到存储库 class 以删除和创建 EventArchive
项。
通过日志记录,我们注意到确实检索到了过期事件,并且删除和创建存档项的代码没有导致异常。
但是项目没有被删除,也没有创建 EventArchive
个项目。
我们使用以下代码将这些项目移动到存档中:
public async Task MoveEventsToArchive(IList<Event> events, CancellationToken cancellationToken)
{
using (var dbContextTrans = _dbContext.Database.BeginTransactionAsync(IsolationLevel.ReadUncommitted, cancellationToken))
{
foreach(var event in events)
{
var archiveItem = new ArchiveEvent(event);
archiveItem.Status = EventStatus.Archived;
_dbContext.ArchiveEvents.Add(archiveItem);
_dbContext.Events.Remove(event);
}
await _dbContext.SaveChangesAsync(cancellationToken);
}
}
正确的做法是什么?
您必须提交交易。此外,我建议使用 AddRange 和 RemoveRange 方法来提高性能。
using (var transaction = _dbContext.Database.BeginTransactionAsync())
{
var archives = new List<ArchiveEvent>();
foreach(var event in events)
{
var archiveItem = new ArchiveEvent(event);
archiveItem.Status = EventStatus.Archived;
archives.Add(archiveItem);
}
_dbContext.ArchiveEvents.AddRange(archives);
_dbContext.Events.RemoveRange(events);
await _dbContext.SaveChangesAsync();
await transaction.CommitAsync();
}
注意:如果 AddRange 导致 PK 插入问题并且您可以更改模型,请在您的 PK 中添加:
public class ArchiveEvent
{
[Key]
[DatabaseGenerated(DatabaseGeneratedOption.Identity)]
public long id { get; set; }
//...
}
我们有一个 postgres 数据库来存储 Event
个对象并使用 Entity Framework 作为我们的 ORM。
在定期运行的后台服务中,我们想要获取所有过期事件,将它们从 Event
table 中删除并将它们移动到 EventArchive
table.
我们有一项服务 class ExpiredEventService
,它检索所有过期事件并将它们传递到存储库 class 以删除和创建 EventArchive
项。
通过日志记录,我们注意到确实检索到了过期事件,并且删除和创建存档项的代码没有导致异常。
但是项目没有被删除,也没有创建 EventArchive
个项目。
我们使用以下代码将这些项目移动到存档中:
public async Task MoveEventsToArchive(IList<Event> events, CancellationToken cancellationToken)
{
using (var dbContextTrans = _dbContext.Database.BeginTransactionAsync(IsolationLevel.ReadUncommitted, cancellationToken))
{
foreach(var event in events)
{
var archiveItem = new ArchiveEvent(event);
archiveItem.Status = EventStatus.Archived;
_dbContext.ArchiveEvents.Add(archiveItem);
_dbContext.Events.Remove(event);
}
await _dbContext.SaveChangesAsync(cancellationToken);
}
}
正确的做法是什么?
您必须提交交易。此外,我建议使用 AddRange 和 RemoveRange 方法来提高性能。
using (var transaction = _dbContext.Database.BeginTransactionAsync())
{
var archives = new List<ArchiveEvent>();
foreach(var event in events)
{
var archiveItem = new ArchiveEvent(event);
archiveItem.Status = EventStatus.Archived;
archives.Add(archiveItem);
}
_dbContext.ArchiveEvents.AddRange(archives);
_dbContext.Events.RemoveRange(events);
await _dbContext.SaveChangesAsync();
await transaction.CommitAsync();
}
注意:如果 AddRange 导致 PK 插入问题并且您可以更改模型,请在您的 PK 中添加:
public class ArchiveEvent
{
[Key]
[DatabaseGenerated(DatabaseGeneratedOption.Identity)]
public long id { get; set; }
//...
}