如何在C# LINQ左连接结果中过滤无效的新增记录

场景说明 #

现有PreviousDayData和CurrentDayData两个数据表，通过C# LINQ左连接查询时，结果混入了ID为4的无效新增记录。需要过滤掉以下两类无效条目：

• 仅存在于CurrentDayData中，且IsEmail≠"Y"
• 仅存在于CurrentDayData中，且EmailAddress无效（已具备邮箱有效性验证方法IsValidEmail(string email)）

原查询逻辑为：匹配ID、Account，并筛选IsEmail或EmailAddress发生变更的记录。

解决方案代码 #

假设实体类定义 #

public class DataRecord
{
    public int ID { get; set; }
    public string Account { get; set; }
    public string IsEmail { get; set; }
    public string EmailAddress { get; set; }
    // 其他业务字段
}

已有的邮箱验证方法 #

private bool IsValidEmail(string email)
{
    // 示例验证逻辑，可替换为实际业务规则
    if (string.IsNullOrWhiteSpace(email))
        return false;
    
    try
    {
        var mailAddr = new System.Net.Mail.MailAddress(email);
        return mailAddr.Address.Equals(email, StringComparison.OrdinalIgnoreCase);
    }
    catch
    {
        return false;
    }
}

修改后的LINQ查询 #

var filteredQuery = from current in CurrentDayData
                    join previous in PreviousDayData
                    on new { current.ID, current.Account } equals new { previous.ID, previous.Account }
                    into joinedGroup
                    from prevRecord in joinedGroup.DefaultIfEmpty()
                    // 保留两类合法记录：
                    // 1. 有前一天匹配记录，且IsEmail/EmailAddress发生变更
                    // 2. 无前一天匹配记录，但IsEmail为"Y"且邮箱地址有效
                    where (prevRecord != null && 
                           (prevRecord.IsEmail != current.IsEmail || prevRecord.EmailAddress != current.EmailAddress))
                       || (prevRecord == null && current.IsEmail == "Y" && IsValidEmail(current.EmailAddress))
                    select new 
                    {
                        current.ID,
                        current.Account,
                        CurrentIsEmail = current.IsEmail,
                        CurrentEmail = current.EmailAddress,
                        PreviousIsEmail = prevRecord?.IsEmail,
                        PreviousEmail = prevRecord?.EmailAddress
                    };

关键逻辑说明 #

1. 左连接结构保留：通过join...into...DefaultIfEmpty()维持左连接逻辑，确保能捕获CurrentDayData中的新增记录（即prevRecord == null的情况）。
2. 双重条件过滤：
   • 第一分支保留原需求中“匹配记录且字段变更”的合法记录；
   • 第二分支针对新增记录，仅保留IsEmail="Y"且邮箱有效的条目，直接排除不符合要求的无效新增（比如ID为4的记录）。

内容的提问来源于stack exchange，提问作者DevP