如何在ASP.NET中实现运行时动态指定查询的数据表？

核心思路 #

利用EF Core的非泛型Set方法或反射调用泛型Set<T>，结合你已有的资源元数据（实体类型、权限），在运行时动态构建对应表的查询。

步骤实现 #

1. 完善ResourceService的元数据存储 #

确保ResourceService在扫描程序集时，将实体Type与资源名称关联存储，比如新增字典映射：

public class ResourceService
{
    private readonly Dictionary<string, (Type EntityType, ResourceType AccessType)> _resourceMap = new();

    public void ScanAssemblies(params Assembly[] assemblies)
    {
        foreach (var assembly in assemblies)
        {
            var entityTypes = assembly.GetTypes()
                .Where(t => t.GetCustomAttribute<ResourceAttribute>() != null && !t.IsAbstract);

            foreach (var type in entityTypes)
            {
                var attr = type.GetCustomAttribute<ResourceAttribute>();
                var resourceName = attr.ResourceName ?? type.Name.ToLower();
                _resourceMap[resourceName] = (type, attr.ResourceType);
            }
        }
    }

    public bool TryGetResourceInfo(string resourceName, out (Type EntityType, ResourceType AccessType) info)
    {
        return _resourceMap.TryGetValue(resourceName.ToLower(), out info);
    }
}

2. 动态获取IQueryable的两种方案 #

方案一：直接使用非泛型Set方法（简单高效）

EF Core的DbContext提供非泛型Set(Type entityType)方法，直接返回对应表的IQueryable（非泛型），足够支撑后续动态查询操作：

// 控制器中获取查询实例
if (!_resourceService.TryGetResourceInfo(resourceName, out var resourceInfo))
{
    return NotFound();
}
IQueryable query = _dbContext.Set(resourceInfo.EntityType);

方案二：反射获取强类型IQueryable<IEntity>（适配接口操作）

如果需要基于IEntity<TKey>接口做统一主键处理，可以通过反射调用泛型方法：

// 定义泛型辅助方法
private IQueryable<IEntity<TKey>> GetTypedQueryable<TKey>(DbContext dbContext, Type entityType)
{
    return dbContext.Set(entityType).Cast<IEntity<TKey>>();
}

// 运行时调用
var (entityType, accessType) = _resourceService.GetResourceInfo(resourceName);
// 提取IEntity<TKey>的主键类型
var entityInterface = entityType.GetInterface(typeof(IEntity<>).FullName);
var keyType = entityInterface.GetGenericArguments()[0];

// 反射调用泛型方法
var method = GetType().GetMethod(nameof(GetTypedQueryable), BindingFlags.NonPublic | BindingFlags.Instance)
                      .MakeGenericMethod(keyType);
var typedQuery = (IQueryable)method.Invoke(this, new object[] { _dbContext, entityType });

3. 整合权限与动态查询 #

获取到IQueryable后，先做权限过滤，再应用你已实现的动态查询逻辑：

[HttpGet("{resourceName}")]
public async Task<IActionResult> Query(string resourceName, [FromQuery] QueryParams queryParams)
{
    // 1. 校验资源存在性
    if (!_resourceService.TryGetResourceInfo(resourceName, out var resourceInfo))
    {
        return NotFound("资源不存在");
    }

    // 2. 权限验证
    if (!HasPermission(User, resourceInfo.AccessType))
    {
        return Forbid();
    }

    // 3. 获取动态查询实例
    IQueryable query = _dbContext.Set(resourceInfo.EntityType);

    // 4. 权限过滤示例：User类型仅返回当前用户数据
    if (resourceInfo.AccessType == ResourceType.User)
    {
        var userIdProperty = resourceInfo.EntityType.GetProperty("UserId");
        if (userIdProperty != null)
        {
            var parameter = Expression.Parameter(resourceInfo.EntityType, "e");
            var propertyAccess = Expression.Property(parameter, userIdProperty);
            var userIdValue = User.FindFirst(ClaimTypes.NameIdentifier)?.Value;
            var equalExpression = Expression.Equal(propertyAccess, Expression.Constant(userIdValue));
            var lambda = Expression.Lambda(equalExpression, parameter);
            
            query = query.Provider.CreateQuery(
                Expression.Call(
                    typeof(Queryable),
                    "Where",
                    new[] { resourceInfo.EntityType },
                    query.Expression,
                    lambda
                )
            );
        }
    }

    // 5. 应用动态查询参数（排序、过滤、分页）
    query = _dynamicQueryHandler.ApplyFilters(query, queryParams.Filters);
    query = _dynamicQueryHandler.ApplySorting(query, queryParams.SortBy, queryParams.SortDesc);
    query = _dynamicQueryHandler.ApplyPagination(query, queryParams.Page, queryParams.PageSize);

    // 6. 执行查询并返回结果
    var total = await query.CountAsync();
    var data = await query.ToListAsync();

    return Ok(new { Total = total, Data = data });
}

关键注意事项 #

• 动态查询操作（排序、过滤）需基于非泛型IQueryable实现，可通过Expression.Call调用Queryable静态方法（如OrderBy、Where）。
• 分页的Skip和Take同样可通过反射调用Queryable.Skip和Queryable.Take实现。
• 确保实体类属性名称与前端传入的查询参数一致，避免反射时找不到属性。

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