LINQ 外部联接有重复项

Question

我正在 LINQPad 中运行此查询。除了 ProductSeries 有重复记录之外，它可以工作。

var query = from etaRecord in EtaRecord_0140

  join productSeriesRecord in ProductSeries
  on etaRecord.ProductSeriesID equals productSeriesRecord.ProductSeriesID
  into productSeriesGroup
  from productSeries in productSeriesGroup.DefaultIfEmpty()

  where etaRecord.State == "A"
  select new { EtaRecord = etaRecord, ProductSeriesRecord = productSeries };

query.Dump();

我尝试使用FirstOrDefault() 而不是DefaultIfEmpty()，但出现此错误：

“LINQPad.User.ProductSeries”类型的表达式不允许在 具有源类型的查询表达式中的后续 from 子句 'System.Linq.IQueryable'。类型推断失败 对“SelectMany”的调用。

如何获取 ProductSeries 的 FirstOrDefault() 以便每个 EtaRecord 只有一行？

.NET 小提琴在这里：https://dotnetfiddle.net/kRrold

Answer 1

看来您需要分组：

var query = from etaRecord in EtaRecord_0140

join productSeriesRecord in ProductSeries
on etaRecord.ProductSeriesID equals productSeriesRecord.ProductSeriesID
into productSeriesGroup
from productSeries in productSeriesGroup.DefaultIfEmpty()

where etaRecord.State == "A"
group productSeries by new { etaRecord.ProductSeriesId, etaRecord } into g
select new 
       { 
         EtaRecord = g.Key.etaRecord, 
         ProductSeriesRecord = g.Select(x => x).FirstOrDefault() 
        };

UPDATED FIDDLE

Answer 2

你是说你加入的收藏有重复吗？因为如果是这样，您可以提前对 ProductSeries 集合进行分组。

var query = from etaRecord in EtaRecord_0140

join productSeriesRecord in ProductSeries.GroupBy(series => series.ProductSeriesID).Select(seriesGroup => seriesGroup.First())
on etaRecord.ProductSeriesID equals productSeriesRecord.ProductSeriesID
into productSeriesGroup
from productSeries in productSeriesGroup.DefaultIfEmpty()

where etaRecord.State == "A"
select new { EtaRecord = etaRecord, ProductSeriesRecord = etaRecord };

query.Dump();

现在假设您使用的是静态列表，而不是数据库。如果它是数据库连接，那么您可能应该对结果进行不同的处理。事后可以以类似的方式完成。

Answer 3

问题是你额外的from 子句：

from productSeries in productSeriesGroup.DefaultIfEmpty() 

你应该放弃它，只使用：

let productSeries = productSeriesGroup.FirstOrDefault()

...或者只是在select 子句中使用productSeriesGroup.FirstOrDefault()，如下所示：

var query = from etaRecord in etaRecords            
            join productSeriesRecord in productSeriesRecords
            on etaRecord.ProductSeriesId equals productSeriesRecord.ProductSeriesId
            into productSeriesGroup
            select new { EtaRecord = etaRecord,
                         ProductSeriesRecord = productSeriesGroup.FirstOrDefault() };

无论是哪一种改变，现在的结果都是：

Snuh 1 - null
Snuh 2 - null
Snuh 3 - null
Snuh 4 - Description A
Snuh 5 - null
Snuh 6 - Description B

我想这就是你想要的。

Answer 4

您应该能够通过 EtaRecord 为分组添加额外的过滤步骤，并且只需选择每个组的第一条记录

即

query  = (from r in query 
         group r by r.EtaRecord.EtaId into results 
         select results.FirstOrDefault());

Answer 5

我会在子查询中这样做：

var query = from etaRecord in EtaRecord_0140
            where etaRecord.State == "A"
            select new 
            { 
                EtaRecord = etaRecord,
                ProductSeriesRecord = 
                  (from productSeriesRecord in ProductSeries
                   where productSeriesRecord.ProductSeriesID == etaRecord.ProductSeriesID
                   select productSeriesRecord).FirstOrDefault()
            };

在 LINQ to objects 中，这可能是一个低效的操作，因为子查询是为每个 etaRecord 执行的，但由于整个语句被转换为 SQL，查询优化器将负责优化的执行计划。

这就是 LINQ-to-entities 的故事。

LINQ-to-SQL 总是 似乎产生了 n + 1 组连接查询（即join - into）和FirstOrDefault()。我已经尝试了几种情况，但我不能让它只生成一个查询。我能找到生成一个查询的唯一解决方案是：

var query = from etaRecord in EtaRecord_0140
            where etaRecord.State == "A"
            from productSeriesRecord in
                     ProductSeries
                        .Where(ps => ps.ProductSeriesID == etaRecord.ProductSeriesID)
                        .Take(1)
                        .DefaultIfEmpt()
            select new { EtaRecord = etaRecord, ProductSeriesRecord = productSeries };

因此放弃了连接语法，并以一种相当人为的方式查询了属于EtaRecord 的ProductSeries 的第一条记录。