如何实现Trigger阻止批量插入重复记录？覆盖库内及待插入集内重复场景

现有方案的根本问题 #

你的Trigger方案无法完全满足需求，核心原因和具体问题如下：

1. Salesforce DML机制限制：
   你提到的“单个重复记录导致整个插入操作中止”是Salesforce的默认DML行为——使用普通insert语句时，只要有一条记录被添加错误（addError），整个事务会回滚，所有记录都无法插入，包括你希望保留的“第一条重复记录”。只有使用Database.insert(records, false)（即allOrNone=false）时，才会跳过错误记录，插入合法的记录，但此时仍会返回错误信息，这是机制本身的特性，无法通过Trigger完全规避。

2. 逻辑冗余与漏洞：

   • 代码中IsDuplicate__c字段的标记和contactId集合完全未被后续逻辑使用，属于无效代码，增加了不必要的资源消耗。
   • 未处理Email为null的场景：如果插入的Contact记录Email为空，现有逻辑会将所有空Email的记录判定为重复，这通常不符合业务需求（空Email不应视为重复）。
   • 大小写敏感问题：Email地址在业务中通常不区分大小写，但你的代码直接用原始字符串判断，会导致test@example.com和Test@Example.com被视为不同值，漏判重复。

3. 场景处理逻辑偏差：
   若数据库中已存在某Email，你的逻辑会将插入集合中该Email的第一条记录也标记错误，这符合“库中已存在则拦截所有相关插入记录”的逻辑；但如果你的需求是“即使库中已有，仍允许插入集合的第一条记录覆盖或跳过”，则逻辑完全不符合预期（不过通常业务中库中已有重复时应全部拦截）。

其他需要考虑的事项 #

• 字段唯一性约束：如果Contact的Email字段已设置为系统级唯一约束，数据库层面会自动拦截重复插入，此时Trigger的逻辑会与系统约束产生重复报错，需要权衡是保留Trigger的自定义错误提示，还是直接依赖系统约束。
• 并发插入的竞态条件：当多个用户同时插入相同Email时，Trigger中的SOQL查询和后续判断之间存在时间间隙，可能导致重复记录插入。此时需要结合FOR UPDATE锁定查询记录，或依赖数据库唯一约束来保证最终数据唯一性。
• 批量处理性能：当前代码存在三次循环遍历Trigger.new，可优化为两次循环（一次收集待检查的Email并处理内部重复标记，一次查询库中已有记录并标记错误），减少资源消耗。
• 错误消息定制：可针对两种重复场景返回不同的错误提示，比如“该Email已存在于系统中”（库中已有）和“插入列表中存在重复Email”（内部重复），提升用户体验。
• null值与特殊字符处理：明确业务规则，是否允许Email为空，若允许则需在逻辑中排除空值的重复检查；同时处理Email中的特殊字符（如前后空格），避免因格式问题导致误判。
• 上下文扩展：若后续需要处理更新场景（如Contact更新Email时检查重复），需将Trigger逻辑扩展到before update上下文，并调整判断逻辑（排除当前记录自身）。

优化后的Trigger示例（参考） #

trigger FindDuplicate on Contact (before insert) {
    if(Trigger.isBefore && Trigger.isInsert){
        Set<String> processedEmails = new Set<String>();
        Set<String> emailsToCheck = new Set<String>();
        // 第一步：处理内部重复，收集需检查的Email（排除空值，统一小写）
        for(Contact c : Trigger.new){
            if(String.isNotBlank(c.Email)){
                String normalizedEmail = c.Email.trim().toLowerCase();
                if(processedEmails.contains(normalizedEmail)){
                    c.Email.addError('插入列表中存在重复Email地址');
                } else {
                    processedEmails.add(normalizedEmail);
                    emailsToCheck.add(normalizedEmail);
                }
            }
        }

        // 第二步：查询库中已存在的Email
        Set<String> existingEmails = new Set<String>();
        for(Contact existing : [SELECT Email FROM Contact WHERE Email IN :emailsToCheck]){
            existingEmails.add(existing.Email.trim().toLowerCase());
        }

        // 第三步：标记库中已存在的重复记录
        for(Contact c : Trigger.new){
            if(String.isNotBlank(c.Email)){
                String normalizedEmail = c.Email.trim().toLowerCase();
                if(existingEmails.contains(normalizedEmail)){
                    c.Email.addError('该Email地址已存在于系统中');
                }
            }
        }
    }
}

注意：使用该Trigger时，必须调用Database.insert(contactList, false)才能实现“跳过错误记录，插入合法记录”的效果，普通insert语句仍会导致整个批量操作回滚。

内容的提问来源于stack exchange，提问作者dev-user