我們有一個 postgres 資料庫來存盤Event物件并使用物體框架作為我們的 ORM。
在定期運行的后臺服務中，我們希望獲取所有過期事件，將它們從Event表中洗掉并將它們移動到EventArchive表中。
我們有一個服務類ExpiredEventService，它檢索所有過期事件并將它們傳遞給存盤庫類以洗掉和創建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);
}
}
這樣做的正確方法是什么？
uj5u.com熱心網友回復：
你必須提交你的交易。另外我建議使用 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; }
//...
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/caozuo/378001.html
標籤：C＃ PostgreSQL的 实体框架