如何使用 linq lambda 表达式通过内部连接进行分组

Question

我正在尝试将 sql 存储过程转换为 linq。我遇到了 groupby 和 inner join 的问题。

这是我尝试过的：

var r = _context.Table1
    .GroupBy(x => new { x.OptionId, x.Years, x.Strike })
    .Join(_context.Table2,
        oc => oc.OptionId, o => o.OptionId, (oc, o) => new
        {
            OptionsCosts = oc,
            Options = o
        }).Where(x => x.Options.OptionType == 1
                && x.Options.QualifierId != null
                && x.Options.CreditingMethod != "xxx")
    
    .Select(y => new DataModel.Table1()
    {
        Years = y.Select(a => a.OptionsCosts.Years).FirstOrDefault(),
        Strike = y.Select(a => a.OptionsCosts.Strike).FirstOrDefault(),
        Value = y.Select(a => a.OptionsCosts.Value).FirstOrDefault(),
        ChangeUser = y.Select(a => a.OptionsCosts.ChangeUser).FirstOrDefault(),
        ChangeDate = DateTime.Now,
        OptionId = y.Select(a => a.OptionsCosts.OptionId).FirstOrDefault()
    });

这是我要转换的 SQL：

SELECT o2.OptionId, o2.Years, o2.Strike, SUM(d2.Weights) as 'TotalWeight', COUNT(*) as 'Counts'
FROM Table1 o2
INNER JOIN @Dates d2  --this is a temp table that just holds dates. I was thinking just a where statement could do it???
  ON d2.EffectiveDate = o2.EffectiveDate
INNER JOIN Table2 od2
   ON od2.OptionId = o2.OptionId
  AND od2.OptionType = 1
  AND od2.qualifierid is null
  AND od2.CreditingMethod <> 'xxx' --28095
GROUP BY o2.OptionId,o2.Years, o2.Strike

我的数据有问题，所以我确定我做错了什么。

Answer 1

var table1=_context.Table1
.groupBy(o2=> new{
o2.OptionId
, o2.Years
, o2.Strike
})
.select(s=> new{
s.key.OptionId
, s.key.Years
, s.key.Strike
,TotalWeight=s.sum(x=>x.Weights)
,Counts=o2.count(c=>c.OptionId)
}).tolist();
var result=table1
.Join(_context.Table2,oc => oc.OptionId, o => o.OptionId, (oc, o) => new{ OptionsCosts = oc,  Options = o })
.Where(x => x.Options.OptionType == 1
                && x.Options.QualifierId != null
                && x.Options.CreditingMethod != "xxx")
.select(x=> new {
    x.oc.OptionId,  x.oc.Years,  x.oc.Strike,  x.oc.TotalWeight, x.oc.Counts
}).tolist();

Answer 2

小建议，在重写SQL查询时，使用与SQL接近的LINQ Query语法，更有效避免错误。

var dates = new List<DateTime>() { DateTime.Now }; // fill list

var query = 
    from o2 in _context.Table1
    where dates.Contains(o2.EffectiveDate)
    from od2 in _context.Table1.Where(od2 => // another way to join
         od2.OptionId == o2.OptionId
      && od2.OptionType == 1
      && od2.qualifierid == null
      && od2.CreditingMethod != "xxx")
    group o2 by new { o2.OptionId, o2.Years, o2.Strike } into g
    select new 
    {
       g.Key.OptionId, 
       g.Key.Years, 
       g.Key.Strike, 
       Counts = g.Count()
       // SUM(d2.Weights) as 'TotalWeight', -this one is not available because dates in memory
    };

如果您刚开始并尝试在 LINQ 上重写程序 - EF Core 是个坏主意。 IQueryable 支持太有限，通常您会为每个复杂的 LINQ 查询而战。 试试linq2db，它支持临时表，你的存储过程可以重写为相同的 LINQ 查询。或者，您可以使用 linq2db.EntityFrameworkCore 来扩展 EF Core 功能。

免责声明。我是此扩展程序的创建者，也是 linq2db 创建者的创建者。