c# - 如何在已编译的 Linq to SQL 查询中使用返回 IQueryable 的方法而不会出错

Question

我有一个方法返回我在编译查询中使用的 IQueryable。这种方法使我不必在仅修改 WHERE 子句的同时重复合并非常大的 linq to sql 查询。例如，我们在内部使用数据库生成的标识列来引用这些项目，因此我有一个函数采用该内部 id 值并返回在内部 id 列上搜索的对象。对于我们的 Web 服务，我们得到一个不同的 ID，我有另一个函数使用相同的底层查询，只有不同的 where 子句(或 singleordefault 等)。在我尝试将其用作编译查询之前，所有这些都很好用(这在这种情况下对于性能至关重要)。当我调用已编译的查询时，我收到“查询包含对在不同数据上下文中定义的项目的引用”。带有巨大的堆栈跟踪。请注意，当它在我们的应用程序服务器上运行时，这只会发生在特定的执行序列中。如果我设置一个简单的测试用例来调用此方法，它就可以正常工作。

我的问题是，我怎样才能让它在 NET 4.5 下工作？我意识到我在 NET 4 中可能是“幸运的”，因为我使用的函数版本在我的数据访问类中引用数据上下文的实例变量。这是在 4.0 下工作的原始版本:

public IQueryable<Log> GetBaseLogQuery(EncDataContext context)
{
    var query =
        from pl in context.DbLog
        ... (lots of joins and lets)
        select new Log
        {
            LogID = pl.LogId,
            UniqueID = pl.UniqueID,
            ... many other memebers set
        }
    ;
    return query;
}

public IQueryable<Log> GetBaseLogQuery()
{
    return GetBaseQuery(Context); // Context is an instance variable
}

private static Func<EncDataContext, int, string, Log> _loadLogByUniqueId;
public Log LoadLog(int organizationId, string uniqueId)
{
    if (_loadLogByUniqueId == null)
    {
        var query = GetBaseLogQuery();
        _loadLogByUniqueId = CompiledQuery.Compile<EncDataContext, int, string, Log>(
            (context, orgId, uid) => query.SingleOrDefault(pl => pl.OrganizationId == orgId && pl.UniqueID == uid)
        );
    }
    var ret = _loadLogByUniqueId.Invoke(Context, organizationId, uniqueId);
    return ret;
}

如果我尝试使用该方法并像这样在编译中直接将数据上下文传递给它:

_loadLogByUniqueId = CompiledQuery.Compile<EncDataContext, int, string, Log>(
    (context, orgId, uid) => GetBaseLogQuery(context).SingleOrDefault(pl => pl.OrganizationId == orgId && pl.UniqueID == uid)

我收到一个不同的错误——“成员访问‘BusinessEntities.Log’的‘Int32 LogID’在类型‘System.Linq.IQueryable`1[BusinessEntities.Log] 上不合法。”

所以经过一些研究，人们提到需要在编译时间之前扩展该方法，以便它可以通过 linq to sql 转换为 SQL。但是，我无法使它正常工作。当我尝试将 GetBaseLogQuery 的输出分配给一个表达式以便我可以对其调用 LinqKit 调用时，我发现类型不匹配。

有什么方法可以让我不必在我当前使用的每个编译查询中复制 GetBaseLogQuery 中的 linq to sql 查询？

Answer 1

只是随机尝试:

将您的 GetBaseLogQuery 函数转换为:

Func<EncDataContext,IQueryable<Log>> getBaseLogQuery;
public Expression<Func<EncDataContext,IQueryable<Log>>> GetBaseLogQuery(EncDataContext context)
{
    if(getBaseLogQuery==null)
        getBaseLogQuery=GetBaseLogQueryExpr().Compile();
    return getBaseLogQuery(context);
}

public Expression<Func<EncDataContext,IQueryable<Log>>> GetBaseLogQueryExpr()
{
    return context=>from pl in context.DbLog ..... etc ....; // contrainst: this MUST be a lambda.
}

然后，创建这个函数:

static Expression<Func<EncDataContext, TArg1, TArg2, TReturn>> WrapQuery<T, TArg1, TArg2, TReturn>(Expression<Func<IQueryable<T>, TArg1, TArg2, TReturn>> todo)
{
    var baseQuery = GetBaseLogQueryExpr();
    var newQueryExpression = new ReplaceVisitor(todo.Parameters.First(), baseQuery.Body).Visit(todo.Body);
    List<ParameterExpression> @params = todo.Parameters.Skip(1).ToList();
    @params.Insert(0, baseQuery.Parameters.First());
    return Expression.Lambda<Func<EncDataContext, TArg1, TArg2, TReturn>>(newQueryExpression, @params.ToArray());
}

使用类

    class ReplaceVisitor : ExpressionVisitor
    {
        readonly Expression to;
        readonly ParameterExpression @from;

        public ReplaceVisitor(ParameterExpression from, Expression to)
        {
            this.to = to;
            this.@from = @from;
        }

        public override Expression Visit(Expression node)
        {
            if (node == @from)
                return @to;
            return base.Visit(node);
        }
    }

您可以像这样创建查询扩展:

var resultExpr = WrapQuery((query,orgId,uid)=>query.SingleOrDefault(pl =>  pl.OrganizationId == organizationId && pl.UniqueID == uniqueId));
_loadLogByUniqueId = CompiledQuery.Compile(resultExpr);

未测试。

优点:可以重复使用。

缺点:您必须为每个参数计数重写一个新的 WrapQuery 函数(这很容易，不过...只是转储复制/粘贴/改编)