3

免责声明:我将服务/实体/等的名称更改为记事本中 SO 的通用名称。如果您发现类名不一致,请忽略它们,因为这不是问题。

我正在为客户开发 WCF 服务,并且我正在序列化的表达式存在一些问题。我目前正在使用Serialize.Linq来处理表达式序列化。最重要的是,我使用我的 DataContract 类在客户端创建表达式,并使用我的 Entity 类将其转换为表达式。

假设这两个类:

  1. MyEntity(项目中 DataContract 命名空间的一部分)
  2. MyEntity(项目中实体命名空间的一部分)

两者具有相同的属性,我使用 AutoMapper 将通过 EF 获得的实体转换为我的 DataContract 对象,然后将该对象发送回客户端。

为了处理表达式转换,我使用了 ExpressionVisitor 类:

class MyExpressionVisitor : ExpressionVisitor
{
    public ParameterExpression ParameterExpression { get; private set; }

    public MyExpressionVisitor(ParameterExpression newParameterExp)
    {
        ParameterExpression = newParameterExp;
    }

    protected override Expression VisitParameter(ParameterExpression node)
    {
        return ParameterExpression;
    }

    protected override Expression VisitMember(MemberExpression node)
    {
        if (node.Member.DeclaringType == typeof(DataContracts.MyEntity))
        {
            return Expression
                .MakeMemberAccess(this.Visit(node.Expression), typeof(Entities.MyEntity).GetMember(node.Member.Name).FirstOrDefault());
        }

        return base.VisitMember(node);
    }
}

这就是我调用我的服务的方式:

Expression<Func<DataContracts.MyEntity, bool>> expression =
    fl.SomeNameField1 == "John Doe" || fl.SomeNameField2 == "John Doe";
var entities = manager.MyService.GetFilteredEntities(expression.ToExpressionNode());

这是我当前的服务实现(部分,省略返回行等)GetFilteredEntities

// Using Serialize.Linq for send expressions over WCF.
// query is an ExpressionNode from the Serialize.Linq library.
// This DOES NOT execute the where clause on the database.
var expression = query.ToExpression<Func<DataContracts.MyEntity, bool>>();
var visitor = new MyExpressionVisitor(Expression.Parameter(typeof(Entities.MyEntity), expression.Parameters[0].Name));
var entityExpression = Expression.Lambda<Func<Entities.MyEntity, bool>>(visitor.Visit(expression.Body), visitor.ParameterExpression);
var func = entityExpression.Compile();
var entities = this.Entities.MyEntities.Where(func);

所有这些代码都有效,但Where不是在数据库级别应用,而是针对我表中每一行的内存集应用。这需要很长时间,因为该表有 150k+ 行。

如果我在服务中对我想要的位置进行硬编码,它会在数据库级别应用 where 子句:

// This DOES execute the where clause on the database.
var temp1 = this.Entities.MyEntities.Where(fl => fl.SomeNameField1 == "John Doe" || fl.SomeNameField2 == "John Doe");

// This DOES execute the where clause on the database.
Func<Entities.MyEntity, bool> func2 = fl => fl.SomeNameField1 == "John Doe" || fl.SomeNameField2 == "John Doe";
var temp2 = this.Entities.MyEntities.Where(func2);

我知道我可以编写一堆不同的服务操作,允许用户通过传入名称、ID 等进行过滤,但是这个表有大量的列(200+),我在所述数据库上输入为零. 对于可能正在使用我正在编写的客户端的其他开发人员来说,能够使用他们喜欢的任何数据和列来创建表达式要容易得多,所以我很乐意在数据库级别应用 where。

我几乎可以肯定我已经在这篇文章中包含了所有相关的内容。我使用 SQL Server Profiler 检查 EF 正在运行的查询,这就是我知道哪些查询在哪里使用的方式。请在需要时询问更多信息。

谢谢!

/墙文字

4

3 回答 3

2

也许问题出在这一行:

var func = entityExpression.Compile();

由于您Where使用已编译的委托函数进行调用,因此您不会调用实际发送到数据库的 Where 的重载。

您需要将表达式对象传递给Where(即调用其中之一

于 2012-10-11T19:22:07.580 回答
1

Where我认为你不应该在你的子句中使用它之前编译你的表达式。这样做将调用命名空间中提供的扩展System.Core方法System.Linq。您需要采用类型对象的方法重载Expression

换句话说,尝试删除这一行:

var func = entityExpression.Compile();
于 2012-10-11T19:28:29.620 回答
0

您是否尝试过使用LinqKit来创建复合查询?它提供了 PredicateBuilder一种使用表达式的简单方法。

看看这个地址,源代码很简单,在我的案例中创造了奇迹。

于 2012-10-11T19:21:30.697 回答