使用实体框架在运行时动态选择列

Question

我有这样的现有功能

public int sFunc(string sCol , int iId)
{
    string sSqlQuery = "  select  " + sCol + " from TableName where ID = " +  iId ;
    // Executes query and returns value in column sCol
}

该表有四列存储整数值，我正在使用上述函数分别读取它们。

现在我将它转换为 Entity Framework 。

 public int sFunc(string sCol , int iId)
{
     return Convert.ToInt32(TableRepository.Entities.Where(x => x.ID == iId).Select(x => sCol ).FirstOrDefault());
}

但是上面的函数返回错误

输入字符串格式不正确

因为它返回列名本身。

我不知道如何解决这个问题，因为我对 EF 很陌生。

任何帮助，将不胜感激

谢谢

原文由 pravprab 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

这可能有助于解决您的问题：

 public int sFunc(string sCol, int iId)
{
    var _tableRepository = TableRepository.Entities.Where(x => x.ID == iId).Select(e => e).FirstOrDefault();
    if (_tableRepository == null) return 0;

    var _value = _tableRepository.GetType().GetProperties().Where(a => a.Name == sCol).Select(p => p.GetValue(_tableRepository, null)).FirstOrDefault();

    return _value != null ? Convert.ToInt32(_value.ToString()) : 0;
}

此方法现在适用于动态输入法参数 sCol 。

更新：这不是当前问题的上下文，而是一般我们如何使用表达式选择动态列：

 var parameter = Expression.Parameter(typeof(EntityTable));
var property = Expression.Property(parameter, "ColumnName");
//Replace string with type of ColumnName and entity table name.
var selector = Expression.Lambda<Func<EntityTable, string>>(property, parameter);

//Before using queryable you can include where clause with it. ToList can be avoided if need to build further query.
var result = queryable.Select(selector).ToList();

原文由 Ankush Madankar 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

8年后对OP没有用，但是这个问题有很多观点，所以我认为对其他人有一个正确的答案可能会有所帮助。

如果您使用实体框架，您应该进行 Linq 投影（ Select() ），因为这会导致在数据库端进行正确、高效的查询，而不是拉入整个实体。

但是，使用 Linq Select() 您通常必须提供一个 lambda，因此将您的列/属性名称放在字符串中是这里的主要困难。

最简单的解决方案是使用动态 LINQ（ EntityFramework.DynamicLinq Nuget 包）。这个包提供了原始 Linq 方法的替代方案，这些方法将字符串作为参数，并将这些字符串转换为适当的表达式。

例子：

 async Task<int> GetIntColumn(int entityId, string intColumnName)
{
    return await TableRepository.Entities
        .Where(x => x.Id == entityId)
        .Select(intColumnName) // Dynamic Linq projection
        .Cast<int>()
        .SingleAsync();
}

我还把它变成了一个 async 调用，因为现在所有的数据库调用都应该异步执行。当您调用此方法时，您必须 await 它才能得到结果（即： var res = await GetIntColumn(...); ）。

通用变异

将其更改为 IQueryable 上的扩展方法可能更有用，并将列/属性类型变为泛型类型参数，因此您可以将其与任何列/属性一起使用：

（前提是您的所有实体都有一个通用接口，指定 Id 属性。）

 public static async Task<TColumn> GetColumn<TEntity, TColumn>(this IQueryable<TEntity> queryable, int entityId, string columnName)
    where TEntity : IEntity
{
    return await queryable
        .Where(x => x.Id == entityId)
        .Select(columnName) // Dynamic Linq projection
        .Cast<TColumn>()
        .SingleAsync();
}

这被称为： var result = await TableRepository.Entities.GetColumn<Entity, int>(id, columnName);

接受列列表的通用变体

您可以进一步扩展它以支持动态选择多个列：

 public static async Task<dynamic> GetColumns<TEntity>(this IQueryable<TEntity> queryable, int entityId, params string[] columnNames)
    where TEntity : IEntity
{
    return await queryable
        .Where(x => x.Id == entityId)
        .Select($"new({string.Join(", ", columnNames)})")
        .Cast<dynamic>()
        .SingleAsync();
}

这被称为： var result = await TableRepository.Entities.GetColumns(id, columnName1, columnName2, ...); 。

由于返回类型及其成员在编译时未知，因此我们必须在此处返回 dynamic 。这使得处理结果变得困难，但如果你想要的只是序列化它并将其发送回客户端，那么就可以了。

原文由 Leaky 发布，翻译遵循 CC BY-SA 4.0 许可协议