可以将多个已编译的linq查询链接在一起吗？

Question

我想链接多个编译LINQ查询在一起。我成功地将两个查询链接在一起，但我无法获得三个正确的工作链。所以这里是减少我的代码重新创建问题。我的两个问题是：'为什么这不起作用？'和'是否有更好的方法来保持已编译查询的性能优势，并避免重复使用常用的基本查询逻辑？

定义以下两个查询：

Func<DataContext, IQueryable<User>> selectUsers = 
    CompiledQuery.Compile(
     (DataContext dc)=>dc.Users.Select(x=>x) 
    ); 
//   
Func<DataContext, string, IQueryable<User>> filterUserName = 
    CompiledQuery.Compile(
     (DataContext dc, string name) => 
      selectUsers(dc).Where(user=>user.Name == name) 
    ); 

通话和枚举链正常工作：

filterUserName(new DataContext(), "Otter").ToList(); 

添加第三个查询链：

Func<DataContext, string, int, IQueryable<User>> filterUserAndGroup =  
    CompiledQuery.Compile(
     (DataContext dc, string name, int groupId) => 
      filterUserName(dc, name).Where(user=>user.GroupId == groupId) 
    ); 

调用链不起作用：

filterUserAndGroup(new DataContext(), "Otter", 101); 

System.InvalidOperationException： 成员访问 '字符串名称' '用户' 上 类型不合法的“System.Linq.IQueryable 1[User].. at System.Data.Linq.SqlClient.SqlMember.set_Expression(SqlExpression value) at System.Data.Linq.SqlClient.SqlFactory.Member(SqlExpression expr, MemberInfo member) at System.Data.Linq.SqlClient.SqlBinder.Visitor.AccessMember(SqlMember m, SqlExpression expo) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitMember(SqlMember m) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitExpression(SqlExpression expr) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitBinaryOperator(SqlBinary bo) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitExpression(SqlExpression expr) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitSelect(SqlSelect select) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitAlias(SqlAlias a) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlVisitor.VisitSource(SqlSource source) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitSelect(SqlSelect select) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlBinder.Visitor.VisitIncludeScope(SqlIncludeScope scope) at System.Data.Linq.SqlClient.SqlVisitor.Visit(SqlNode node) at System.Data.Linq.SqlClient.SqlBinder.Bind(SqlNode node) at System.Data.Linq.SqlClient.SqlProvider.BuildQuery(ResultShape resultShape, Type resultType, SqlNode node, ReadOnlyCollection 1个 parentParameters，SqlNodeAnnotations 注释）在 将System.Data.Linq .SqlClient.SqlProvider.BuildQuery（表达式 查询，SqlNodeAnnotations注解） 在 System.Data.Linq.SqlClient.SqlProvider.System.Data.Linq.Provider.IProvider.Compile（表达式 查询）在 将System.Data.Linq .CompiledQuery.ExecuteQuery（DataContext 上下文在TestMethod的（）中 ，对象[]参数）在 System.Data.Linq.CompiledQuery.Invoke（TArg0 为arg0，TArg1 ARG1）....

Answer 1

看起来您需要在执行第二个查询之前将您的第一个已编译查询转换为列表。在理论上，这也应该导致你的两个查询链出现错误。

从MSDN CompiledQuery：

如果一个新的查询运算符应用于委托执行的结果，产生一个异常。

当您想要对执行编译查询的结果执行查询操作符时，必须先将结果转换为列表，然后再对其进行操作。

也许这段代码可以修复它，尽管如果你使用LINQ to SQL，这可能会影响到往返数据库。

filterUserName(dc, name).ToList().Where(user=>user.GroupId == groupId) 

Answer 2

诚然，我不熟悉CompiledQuery。但是，由于LINQ的延期执行性质，你可以这样做：

var result = dbContext.Users.Where(user => user.id == id); 
result = result.Where(user => user.GroupID == groupID); 
result = result.Select(user => user.username); 

for(String username in result){ 
    ; // do something 
} 

上面当然是一个简单的例子。但是，当基于用户输入（例如网站上的“高级搜索”表单）将不同查询组合在一起时，它可能非常有用。

Answer 3

您是否需要使用CompiledQuery类？试试这个...

static Func<DataContext, IQueryable<User>> selectUsers = 
    (dc) => dc.Users.Select(x => x); 
//   
static Func<DataContext, string, IQueryable<User>> filterUserName = 
    (DataContext dc, string name) => 
     selectUsers(dc).Where(user => user.Name == name); 
// 
static Func<DataContext, string, int, IQueryable<User>> filterUserAndGroup = 
    (DataContext dc, string name, int groupId) => 
     filterUserName(dc, name).Where(u => u.GroupID == groupId); 

...测试代码（我知道我的DataContext这里就不LINQ2SQL但这是乐趣和LINQ的美）......

另外，我用这个方法对我自己的数据库，所以我知道他们建立到单个查询发送到数据库。我甚至使用了返回IQueryable而不是Func <>代表的普通实例方法。

public class DataContext 
{ 
    public static Func<DataContext, IQueryable<User>> selectUsers = 
     (dc) => dc.Users.Select(x => x); 
    //   
    public static Func<DataContext, string, IQueryable<User>> filterUserName = 
     (DataContext dc, string name) => 
      selectUsers(dc).Where(user => user.Name == name); 
    // 
    public static Func<DataContext, string, int, IQueryable<User>> UsrAndGrp = 
     (DataContext dc, string name, int groupId) => 
      filterUserName(dc, name).Where(u => u.GroupID == groupId); 

    public DataContext() 
    { 
     Users = new List<User>() 
     { 
      new User(){ Name = "Matt", GroupID = 1}, 
      new User(){ Name = "Matt", GroupID = 2}, 
      new User(){ Name = "Jim", GroupID = 2}, 
      new User(){ Name = "Greg", GroupID = 2} 
     }.AsQueryable(); 
    } 
    public IQueryable<User> Users { get; set; } 
    public class User 
    { 
     public string Name { get; set; } 
     public int GroupID { get; set; } 
    } 
} 

class Program 
{ 
    static void Main(string[] args) 
    { 
     var q1 = DataContext.UsrAndGrp(new DataContext(), "Matt", 1); 
     Console.WriteLine(q1.Count()); // 1 
     var q2 = DataContext.filterUserName(new DataContext(), "Matt"); 
     Console.WriteLine(q2.Count()); // 2 
    } 
}