Entity Framework Core - 使用OData执行NOLOCK查询遇问题

核心问题 #

你的代码存在两个关键问题，导致OData结合NOLOCK时失效且性能极差：

1. 提前加载全表数据：仓库方法FindAll()直接调用ToListWithNoLockAsync将整张表的数据加载到内存，后续转成IQueryable后，OData的$filter、$expand都是在内存中处理，不仅会拉取数百万条无效数据，还会导致Include失效（内存IQueryable的Include不会生成SQL JOIN，导航属性无法正确加载）。
2. NOLOCK扩展方法设计不符合延迟执行需求：原扩展方法直接执行查询返回List，无法配合OData的延迟执行特性，导致过滤逻辑无法下推到数据库层面。

修正方案 #

1. 重构仓库代码，保持IQueryable延迟执行

修改仓库方法，直接返回未执行的IQueryable，让OData能将过滤、展开等逻辑下推到数据库：

// Repository base
public IQueryable<T> FindAllQueryable() => _dbContext.Set<T>().AsNoTracking();

// Repository method
public IQueryable<User> GetUserDataQueryable()
{
    return _dbContext.Users
                .Include(u => u.Products)
                .Include(u => u.Orders)
                .AsNoTracking();
}

2. 调整NOLOCK扩展方法，适配延迟执行

重写扩展方法，支持在最终执行查询时包裹ReadUncommitted事务，确保OData处理后的查询在NOLOCK级别下执行：

public static class EFCoreNoLockExtensions
{
    public static async Task<List<T>> ToListWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
    {
        // 获取查询对应的DbContext
        var dbContext = GetDbContextFromQuery(query);
        
        using var transaction = await dbContext.Database.BeginTransactionAsync(System.Data.IsolationLevel.ReadUncommitted, cancellationToken);
        try
        {
            var result = await query.ToListAsync(cancellationToken);
            await transaction.CommitAsync(cancellationToken);
            return result;
        }
        catch
        {
            await transaction.RollbackAsync(cancellationToken);
            throw;
        }
    }

    private static DbContext GetDbContextFromQuery<T>(IQueryable<T> query)
    {
        var enumerator = query.Provider.Execute<IEnumerable<T>>(query.Expression).GetEnumerator();
        try
        {
            var contextField = enumerator.GetType().GetField("_context", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance);
            return contextField?.GetValue(enumerator) as DbContext 
                ?? throw new InvalidOperationException("无法从查询中获取DbContext");
        }
        finally
        {
            (enumerator as IDisposable)?.Dispose();
        }
    }
}

3. 修改Controller，整合OData与NOLOCK

手动处理OData查询选项，确保过滤、展开逻辑先应用到IQueryable，再在NOLOCK事务中执行查询：

[HttpGet]
public async Task<IActionResult> Get(ODataQueryOptions<User> options)
{
    // 获取延迟执行的查询
    var baseQuery = _repository.UserRepository.GetUserDataQueryable();
    
    // 应用OData的过滤、展开等查询规则
    var processedQuery = options.ApplyTo(baseQuery) as IQueryable<User>;
    
    // 在NOLOCK隔离级别下执行查询
    var result = await processedQuery.ToListWithNoLockAsync();
    
    return Ok(result);
}

关键说明 #

• 延迟执行的重要性：保持IQueryable未执行状态，让OData的所有查询逻辑都能转化为SQL语句，只拉取符合条件的数据，避免内存处理百万级数据。
• NOLOCK的本质：通过ReadUncommitted隔离级别实现，和EF的AsNoTracking无关——AsNoTracking是关闭EF的实体跟踪提升性能，NOLOCK是数据库层面的读取策略。

内容的提问来源于stack exchange，提问作者ufccoder