.Net 6环境下Entity Framework Core动态指定上下文表的实现方案问询

针对10张结构完全一致的表查询场景，以下两种方案均可完全替代冗余的if-else/重复代码，兼容.NET 6 + EF Core 环境。

方案1：公共接口 + 字典映射（推荐，无反射开销，易维护） #

步骤1：定义公共接口提取所有公共字段 #

所有表对应的实体类统一实现该接口：

public interface ITimeFrameEntity
{
    string ProductName { get; set; }
    // 其余公共字段统一在此定义
}

// 示例实体类实现
public class FiveMin : ITimeFrameEntity
{
    public string ProductName { get; set; }
    // 其他字段...
}
public class FifteenMin : ITimeFrameEntity { /* 同上实现接口 */ }
public class ThirtyMin : ITimeFrameEntity { /* 同上实现接口 */ }

步骤2：构建周期与表的映射字典 #

提前建立时间周期枚举和对应表查询的映射关系，仅需配置一次：

// 定义时间周期枚举
public enum TimeFrame
{
    FiveMin,
    FifteenMin,
    ThirtyMin,
    // 剩余7个周期依次补充
}

// 全局只读映射字典，无需重复构建
private static readonly Dictionary<TimeFrame, Func<TimeFrameContext, IQueryable<ITimeFrameEntity>>> _tableMap = new()
{
    { TimeFrame.FiveMin, ctx => ctx.FiveMin },
    { TimeFrame.FifteenMin, ctx => ctx.FifteenMin },
    { TimeFrame.ThirtyMin, ctx => ctx.ThirtyMin },
    // 剩余7张表依次补充映射
};

步骤3：封装统一查询方法，支持循环调用 #

// 统一查询方法
public async Task<bool> IsProductExistsAsync(TimeFrame timeFrame, string symbol, CancellationToken ct = default)
{
    await using var context = new TimeFrameContext();
    var query = _tableMap[timeFrame](context);
    return await query.AnyAsync(t => t.ProductName == symbol, ct).ConfigureAwait(false);
}

// 循环批量查询所有表示例
foreach (var timeFrame in Enum.GetValues<TimeFrame>())
{
    var exists = await IsProductExistsAsync(timeFrame, "目标产品名");
    // 处理查询结果
}

方案2：泛型动态查询（适合表频繁新增的场景） #

无需维护字典，直接通过EF Core的Set<T>()方法动态获取对应表：

// 泛型统一查询方法，约束为实现公共接口的实体类
public async Task<bool> IsProductExistsAsync<TEntity>(string symbol, CancellationToken ct = default)
    where TEntity : class, ITimeFrameEntity
{
    await using var context = new TimeFrameContext();
    return await context.Set<TEntity>().AnyAsync(t => t.ProductName == symbol, ct).ConfigureAwait(false);
}

调用示例 #

// 单表查询
var fiveMinExists = await IsProductExistsAsync<FiveMin>("目标产品名");

// 循环批量查询所有表
var entityTypes = new List<Type> { typeof(FiveMin), typeof(FifteenMin), typeof(ThirtyMin) /* 其余类型补充 */ };
foreach (var type in entityTypes)
{
    var method = typeof(当前类名).GetMethod(nameof(IsProductExistsAsync), BindingFlags.Public | BindingFlags.Instance)!
        .MakeGenericMethod(type);
    var exists = await (Task<bool>)method.Invoke(this, new object[] { "目标产品名", default(CancellationToken) })!;
    // 处理查询结果
}

.NET 6 适配优化点 #

• 可以配合C# 10+的Generic Attributes或者源生成器，自动扫描所有实现了ITimeFrameEntity的实体类，无需手动维护枚举/类型列表，进一步减少配置代码
• 可将查询方法注册为单例服务，映射字典全局仅初始化一次，减少运行时开销

注意：所有参与动态查询的实体类必须保证实现了公共接口，字段名与类型完全一致，否则EF Core会抛出映射错误。后续表结构调整仅需修改公共接口即可同步到所有实体。

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