EF 6.0中能否编译带可配置约束的查询以替代动态SQL？

问题背景 #

我们在C#中使用EF 6.0，希望通过EF编译查询替代动态SQL。不同网络有不同的筛选约束：

• AZNETWORK：Network Id=AZNETWORK、Speciality Code=PEDS、Age<21
• CANETWORK：Network Id=CANETWORK、Speciality Code=PEDS、Age<18

目前用动态SQL实现，想改用EF查询，且希望通过编译查询优化性能。已编写查询函数并尝试编译，但看到的示例都是直接在编译语句中定义查询，想确认当前写法是否可行。

现有代码（修正语法错误后） #

查询函数 #

public static IQueryable<ProvData> azFunction(preprodContext ctx, string networkId, 
string specCode, int maxAge)
{
   var azquery = from load in ctx.ProvTable
                 select new ProvData
                 {
                   Id        = load.Id,
                   NetworkId = load.NetworkId,
                   SpecCode  = load.SpecCode,
                   Age       = load.Age
                 };
  azquery = azquery.Where(x => x.NetworkId == networkId);
  azquery = azquery.Where(x => x.SpecCode == specCode);
  azquery = azquery.Where(x => x.Age < maxAge); // 修正为符合需求的小于判断
  return azquery;
}

尝试的编译代码（存在API适配错误） #

// 注意：EF 6.0 无EF.CompileAsyncQuery，该API属于EF Core
private static Func<preprodContext, string, string, int, IAsyncEnumerable<Prov>> azCompiled =
   EF.CompileAsyncQuery((preprodContext ctx, string networkId, string specCode, int age ) =>
      azFunction(ctx, networkId, specCode, age));

可行性分析与修正方案 #

核心结论 #

通过外部函数封装约束再编译是可行的，但需要修正API适配和语法问题，同时遵循EF 6.0的编译查询规则。

1. 适配EF 6.0的编译查询API #

EF 6.0不支持EF.CompileAsyncQuery，需使用System.Data.Entity.Core.Objects.CompiledQuery.Compile创建编译查询。EF 6.0的编译查询本身无异步版本，但可对编译后的IQueryable调用异步扩展方法（如ToListAsync）。

同步编译查询写法

// 编译同步查询，返回IQueryable<ProvData>
private static Func<preprodContext, string, string, int, IQueryable<ProvData>> azCompiledSync =
    System.Data.Entity.Core.Objects.CompiledQuery.Compile(
        (preprodContext ctx, string networkId, string specCode, int maxAge) =>
            azFunction(ctx, networkId, specCode, maxAge));

// 使用示例
using(var ctx = new preprodContext())
{
    var azResults = azCompiledSync(ctx, "AZNETWORK", "PEDS", 21).ToList();
}

异步执行编译查询

// 编译同步查询，后续通过异步方法执行
private static Func<preprodContext, string, string, int, IQueryable<ProvData>> azCompiled =
    System.Data.Entity.Core.Objects.CompiledQuery.Compile(
        (preprodContext ctx, string networkId, string specCode, int maxAge) =>
            azFunction(ctx, networkId, specCode, maxAge));

// 使用示例
using(var ctx = new preprodContext())
{
    var caResults = await azCompiled(ctx, "CANETWORK", "PEDS", 18).ToListAsync();
}

2. 更灵活的可配置约束扩展方案 #

如果要支持更多网络的不同约束，建议将约束封装为Expression<Func<ProvTable, bool>>表达式集合，既保证灵活性，又不影响编译查询的性能：

// 定义各网络的约束表达式
public static class NetworkConstraints
{
    public static Expression<Func<ProvTable, bool>> GetAzNetworkConstraint(int maxAge)
    {
        return p => p.NetworkId == "AZNETWORK" && p.SpecCode == "PEDS" && p.Age < maxAge;
    }

    public static Expression<Func<ProvTable, bool>> GetCaNetworkConstraint(int maxAge)
    {
        return p => p.NetworkId == "CANETWORK" && p.SpecCode == "PEDS" && p.Age < maxAge;
    }
}

// 通用查询函数
public static IQueryable<ProvData> GetProvData(preprodContext ctx, Expression<Func<ProvTable, bool>> constraint)
{
    return ctx.ProvTable
              .Where(constraint)
              .Select(p => new ProvData
              {
                  Id = p.Id,
                  NetworkId = p.NetworkId,
                  SpecCode = p.SpecCode,
                  Age = p.Age
              });
}

// 编译通用查询
private static Func<preprodContext, Expression<Func<ProvTable, bool>>, IQueryable<ProvData>> compiledProvQuery =
    System.Data.Entity.Core.Objects.CompiledQuery.Compile(
        (preprodContext ctx, Expression<Func<ProvTable, bool>> constraint) =>
            GetProvData(ctx, constraint));

// 使用示例
using(var ctx = new preprodContext())
{
    var azConstraint = NetworkConstraints.GetAzNetworkConstraint(21);
    var azResults = compiledProvQuery(ctx, azConstraint).ToList();

    var caConstraint = NetworkConstraints.GetCaNetworkConstraint(18);
    var caResults = await compiledProvQuery(ctx, caConstraint).ToListAsync();
}

3. 关键注意事项 #

• EF 6.0的编译查询会缓存生成的SQL，适合重复执行的查询，能减少EF的查询解析开销。
• 编译查询的参数类型必须严格匹配，否则会触发重新编译，失去性能优势。
• 可变的约束条件（如不同的NetworkId、maxAge）必须作为编译查询的参数传入，不能硬编码在表达式中（除非为每个硬编码版本单独编译）。

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