Spring JPA中如何处理ERROR: Duplicate entry错误？

嘿，我来帮你搞定Spring JPA批量创建优惠券时遇到的Duplicate entry错误！

首先得明确这个错误的核心：Duplicate entry本质是触发了数据库的唯一约束——你要插入的Voucher记录里，某个（或某几个）字段的值已经存在于库中，而这个字段（或字段组合）被设置了唯一索引（比如优惠券code、product_id + user_id的组合约束，或是业务上的唯一规则）。

结合你的批量插入场景，我给你几个针对性的解决思路：

1. 从源头避免：生成前先校验重复 #

在创建Voucher对象前，先查询数据库确认要生成的内容是否已存在，从根源杜绝重复：

entityManager.getTransaction().begin();
int batchSize = 30;
for(int i=0;i<100;i++) {
    Voucher voucher = null;
    // 生成你的优惠券唯一标识（比如code）
    String voucherCode = generateUniqueVoucherCode();
    
    // 校验是否已存在（如果是组合唯一约束，就同时匹配多个字段）
    Long count = entityManager.createQuery(
            "SELECT COUNT(v) FROM Voucher v WHERE v.code = :code", Long.class)
            .setParameter("code", voucherCode)
            .getSingleResult();
    
    if(count == 0) {
        // 不存在则创建并保存
        voucher = new Voucher();
        voucher.setCode(voucherCode);
        voucher.setProduct(product);
        voucher.setUserMaster(userMaster);
        // 其他字段赋值...
        entityManager.persist(voucher);
        
        // 批量提交逻辑
        if (i % batchSize == 0 && i > 0) {
            entityManager.flush();
            entityManager.clear();
        }
    } else {
        // 重复则重新生成当前索引的优惠券
        i--;
        continue;
    }
}
entityManager.getTransaction().commit();

2. 捕获异常：跳过重复记录继续执行 #

如果是并发场景下的竞争导致偶然重复，你可以捕获JPA的PersistenceException，跳过重复记录继续执行：

entityManager.getTransaction().begin();
int batchSize = 30;
for(int i=0;i<100;i++) {
    try {
        Voucher voucher = createVoucher(product, userMaster); // 你的优惠券创建逻辑
        entityManager.persist(voucher);
        
        if (i % batchSize == 0 && i > 0) {
            entityManager.flush();
            entityManager.clear();
        }
    } catch (PersistenceException e) {
        // 检查是否是唯一约束错误（不同数据库错误码不同，MySQL是1062）
        Throwable rootCause = e.getCause();
        if (rootCause instanceof SQLIntegrityConstraintViolationException) {
            SQLIntegrityConstraintViolationException sqlEx = (SQLIntegrityConstraintViolationException) rootCause;
            if (sqlEx.getErrorCode() == 1062) {
                System.out.println("发现重复优惠券，跳过当前记录");
                continue; // 跳过重复，继续下一条
            }
        }
        // 非重复异常直接抛出，不吞掉
        throw e;
    }
}
entityManager.getTransaction().commit();

⚠️ 注意：不同数据库的唯一约束错误码不一样，比如PostgreSQL是23505，需要根据你使用的数据库调整判断逻辑。

3. 优化批量操作的Flush策略 #

你代码里设置了FlushModeType.COMMIT，这意味着只有事务提交时才会把数据刷入数据库，容易导致批量操作到最后才发现重复，前功尽弃。可以调整为：

• 每batchSize条就flush一次，更早发现重复错误
• 如果不需要整个批量操作的原子性，也可以考虑拆分事务（但会影响性能，谨慎使用）

4. 数据库层面兜底：用原生SQL处理重复 #

如果愿意用原生SQL批量插入，可以利用数据库语法直接忽略或更新重复记录（以MySQL为例）：

String sql = "INSERT IGNORE INTO voucher(code, product_id, user_id, ...) VALUES (?, ?, ?, ...)";
Query query = entityManager.createNativeQuery(sql);

for(int i=0;i<100;i++) {
    String voucherCode = generateUniqueVoucherCode();
    query.setParameter(1, voucherCode);
    query.setParameter(2, productId);
    query.setParameter(3, userId);
    // 其他参数赋值...
    query.addBatch();
    
    if (i % batchSize == 0 && i > 0) {
        query.executeBatch();
    }
}
query.executeBatch();

这种方式由数据库直接处理重复，不需要Java层做校验，但缺点是失去了JPA的实体管理优势，且不同数据库语法不通用。

最后提醒：一定要先看错误日志里的具体提示（比如Duplicate entry 'XXX' for key 'voucher.code_UNIQUE'），搞清楚是哪个字段触发了唯一约束，才能精准解决问题！

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