如何在 LINQ 中重用部分选择代码编写聚合查询

Question

我有一个可重用的选择查询方法，由另外两种方法调用。

这些是我的项目中的示例例程。 SalesQry() 方法在我们的项目中实际上非常复杂。

Private IEnumerable<Sales> SalesQry(SalesDataContext sContext, int customerID)
{
   return 
      from SALE in sContext.Sales
      where SALE.CustomerID = customerID
      select SALE
}

Public List<SalesAGG> SalesByArea()
{
   SalesDataContext oSContext = new SalesDataContext (.....);

  return from SALE in SalesQry(sContext,1230)
              group SALE by
              new
              {
                Type = SALE.SaleType,
                Area = SALE.Area
              }   into aggAREA
             select new  SalesAGG()
             {
                Type = aggAREA.Key.Type,
                Place =  aggAREA.Key.Area,
                TotalSales = aggAREA.Count()
             }.ToList();     
}

Public List<SalesAGG> SalesByState()
{
   SalesDataContext oSContext = new SalesDataContext (.....);

  return from SALE in SalesQry(sContext,1230)
              group SALE by
              new
              {
                Type = SALE.SaleType,
                State = SALE.State
              }   into aggSTATE
             select new  SalesAGG()
             {
                Type = aggSTATE.Key.Type,
                Place =  aggSTATE.Key.State,
                TotalSales = aggSTATE.Count()
             }.ToList();            
}

我遇到的问题是，当执行 SalesByState() 或 SalesByArea() 函数时，sql server 不运行聚合查询，而是仅运行返回大量行的这部分

from SALE in sContext.Sales
          where SALE.CustomerID = customerID
          select SALE

，其余部分正在应用程序内执行。如果我不调用函数 SalesQry() 并像下面这样更改查询，sql server 运行一个聚合查询，返回的行数非常少。

 from SALE in sContext.Sales
 where SALE.CustomerID = 1230
 group SALE by
  new
  {
     Type = SALE.SaleType,
     State = SALE.State
   }   into aggSTATE
  select new  SalesAGG()
  {
    Type = aggSTATE.Key.Type,
    Place =  aggSTATE.Key.State,
   TotalSales = aggSTATE.Count()
  }.ToList();

我需要分享代码，因为它非常复杂并且在许多其他地方使用。我应该如何编写查询以使sql服务器在服务器上运行整个聚合查询并使用函数SalesQry()

Answer 1

编辑：您可能返回的是 IEnumerable 而不是 IQueryable。我第一次没注意到这一点。

我相信它被迫在客户端上执行聚合，因为它无法在数据库服务器上运行 new SalesAGG() 。尝试使用 Let 语句将其取出，例如：

return from SALE in SalesQry(sContext,1230)
          group SALE by
          new
          {
            Type = SALE.SaleType,
            Area = SALE.Area
          }   into aggAREA
         let totalSales = aggAREA.Count()
         select new  SalesAGG()
         {
            Type = aggAREA.Key.Type,
            Place =  aggAREA.Key.Area,
            TotalSales = totalSales
         }.ToList();   

如果这不起作用，那么我的下一个预感是它是对新的分组进行分组的 group by 子句目的。尝试使用字符串连接作为 group by 标准，例如：

return from SALE in SalesQry(sContext,1230)
          group SALE by SALE.SaleType + SALE.Area into aggAREA
         select new  SalesAGG()
         {
            Type = aggAREA.First().Type,
            Place =  aggAREA.First().Area,
            TotalSales = aggAREA.Count()
         }.ToList();