2

我有一个方法返回我在编译查询中使用的 IQueryable。这种方法使我不必在只修改 WHERE 子句时重复合并一个非常大的 linq to sql 查询。例如，在内部，我们使用 DB 生成的标识列引用这些项目，因此我有一个函数获取内部 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 查询？

4

1 回答 1

0

只是随机尝试：

将您的 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 函数（虽然这很容易......只是转储复制/粘贴/调整）

于 2013-11-07T17:23:30.833 回答