在LINQ查询中动态设置表名

Question

我正在开发数据仓库应用程序，我们有 4 个表，其中架构相同。这些表之间的唯一区别只是表名称。

表格示例：

• ps_承包商
• ps_员工
• ps_联盟
• ps_非联盟

架构

• id
• 每小时
• 好处
• 总计

现在我需要根据这些表格生成 4 份报告。我不想编写 4 个单独的 LINQ 查询，而是编写一个可以动态传递表名的查询。

问题如何在以下 LINQ 查询中动态传递表名称？

var data = ( from q in _dbcontext.ps_Contractor 
join _l in _dbcontext.log on q.id equals l.tablelogid 
where q.hourly = 8
select new{
 hourly=q.hourly,
 benefit=q.benefit,
 total=q.total,
 log = l.message
}.ToList();

我已经查看了堆栈溢出建议的所有类似问题。我不想使用 ExecuteStoreQuery。

我有什么选择？

Answer 1

如果所有表都有相同的列，那么我会从这些表中提取一个

interface

并创建

partial entity classes

只是为了实现该接口，最后使用该接口进行查询。

例如：

//entities
public partial class ps_Contractor: ICommonInterface{}
public partial class Table2 : ICommonInterface{}

在搜索方法中，我将传递

IEnumerable<ICommonInterface>

或

IQueryable<ICommonInterface>

并对其应用该查询。您需要做的就是将不同的表传递给该搜索方法。 或者您甚至可以拥有

ICommonInterface

类型的泛型类并使用它来执行查询。

public void Example(IQueryable<ICommonInterface>dataSource)
{
var data = ( from q in dataSource 
join _l in _dbcontext.log on q.id equals l.tablelogid 
where q.hourly = 8
select new{
 hourly=q.hourly,
 benefit=q.benefit,
 total=q.total,
 log = l.message
}.ToList();
}

Example(_dbcontext.ps_Contractor.AsQueryable())

这只是我现在测试的示例：

 public class Repository
{
    private List<string> GetData(IQueryable<IContractor> data)
    {
        return (from d in data select d.Name).ToList();
    }

    public List<string> GetFullTime()
    {
        using (var context = new TestDbEntities())
        {
            return GetData(context.FTContractors.AsQueryable());
        }
    }

    public List<string> GetPartTime()
    {
        using (var context = new TestDbEntities())
        {
            return GetData(context.PTContractors.AsQueryable());
        }
    }
}

实体：

public interface IContractor
    {
        int Id { get; set; }
        string Name { get; set; }
    }

    public partial class FTContractor : IContractor
    {
        public int Id { get; set; }
        public string Name { get; set; }
    }
public partial class PTContractor : IContractor
    {
        public int Id { get; set; }
        public string Name { get; set; }
    }

测试：

[TestMethod]
        public void Temp()
        {
            var tester = new Repository();

            var ft = tester.GetFullTime();
            var pt = tester.GetPartTime();

             Assert.AreEqual(3, ft.Count);
             Assert.AreEqual(4, pt.Count);
        }

在数据库中，有两个表仅包含

Id

和

Name

列

Answer 2

EF Core 不再具有非通用 .set 方法，但此扩展类可以轻松使用动态 Linq 基于字符串查询表

public static class DbContextExtensions
{
    public static IQueryable<Object> Set(this DbContext _context, Type t)
    {
        return (IQueryable<Object>)_context.GetType().GetMethod("Set").MakeGenericMethod(t).Invoke(_context, null);
    }


    public static IQueryable<Object> Set(this DbContext _context, String table)
    {
        Type TableType = _context.GetType().Assembly.GetExportedTypes().FirstOrDefault(t => t.Name == table);
        IQueryable<Object> ObjectContext = _context.Set(TableTypeDictionary[table]);
        return ObjectContext;
    }
}

}

用途：

IQueryable<Object> query = db.Set("TableName");
// Filter against "query" variable below...
List<Object> result = query.ToList();
// or use further dynamic Linq
IQueryable<Object> query = db.Set("TableName").Where("t => t.TableFilter == \"MyFilter\"");

Answer 3

这是一种执行动态函数的方法，该函数接受

DbSet<T>

（您想要作为参数传递的数据库类的类型）和特定表达式来在该表上构建查询：

private IQueryable<T> BuildQueriedCollection<T>(Expression<Func<T, bool>> exp, DbSet<T> dbTable) where T : class
{
    var appliedQueryCollection = dbTable.AsExpandable().Where(exp);
    return appliedQueryCollection;
}

你可以像这样调用该函数：

Expression<Func<MyClass, bool>> myExp = myList => myList... // some condition...;
var dbset = dbContext.MyTable;
var query = BuildQueriedCollection(myExp, dbset);

Answer 4

有人能仅使用 linq 或动态 linq 找到有效的解决方案吗？