DbContext从Oracle数据库返回无关数据问题求助

核心原因 #

1. DbContext生命周期被错误延长
   你在IHostedService的构造函数中创建Scope并持有DbContext，但IHostedService是单例服务，构造函数仅执行一次，这导致DbContext脱离了Scoped生命周期，变成了长期持有的“伪单例”。而EF Core的DbContext设计为短生命周期使用，长期持有会引发一系列缓存和状态问题。

2. ChangeTracker缓存旧数据
   DbContext的ChangeTracker会缓存所有跟踪查询的实体，长期持有的DbContext不会自动清理这些缓存，即使数据库中数据已被删除，后续查询仍可能返回缓存里的旧实体。

3. 模型元数据缓存未更新
   EF Core启动时会编译并缓存数据库模型元数据，长期持有的DbContext不会重新加载模型。如果数据库表结构发生变化（比如表被删除），旧的模型元数据仍会被使用，导致查询到“不存在的表数据”。

解决方案 #

1. 每次查询时创建新的Scope和DbContext #

不要在构造函数中持有DbContext，而是在每次需要访问数据库的逻辑中，临时创建Scope并获取DbContext，用完后立即释放。

修改GetItemsFromDBAsync方法如下：

protected override async IAsyncEnumerable<TItem> GetItemsFromDBAsync([EnumeratorCancellation] CancellationToken cancellationToken)
{
    // 每次查询创建新Scope，using确保自动释放
    using var scope = scopeFactory.CreateScope();
    var dbContext = scope.ServiceProvider.GetRequiredService<TContext>();
    
    // 使用AsNoTracking禁用跟踪，避免缓存旧数据
    await foreach (var item in dbContext.Set<TItem>()
        .Where(...)
        .AsNoTracking()
        .AsAsyncEnumerable()
        .WithCancellation(cancellationToken))
    {
        yield return item;
    }
}

2. 在后台服务的循环逻辑中管理Scope #

如果你的IHostedService是定时/循环执行任务，在每次循环迭代中创建Scope：

public async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        using var scope = _scopeFactory.CreateScope();
        var dbContext = scope.ServiceProvider.GetRequiredService<SomeDbContext>();
        
        // 执行数据查询或业务逻辑
        var items = await dbContext.Set<TItem>()
            .Where(...)
            .AsNoTracking()
            .ToListAsync(stoppingToken);
        
        // 处理数据...
        
        await Task.Delay(TimeSpan.FromMinutes(5), stoppingToken);
    }
}

3. 辅助优化措施 #

• 始终使用using语句包裹Scope，确保Scope和DbContext被及时释放，避免资源泄漏。
• 对于只读查询，强制使用AsNoTracking()，彻底避免ChangeTracker缓存旧数据的问题。
• 确认Oracle数据库客户端版本与EF Core Oracle Provider版本兼容，避免因驱动问题导致的异常缓存。

内容的提问来源于stack exchange，提问作者A.Max