事务内清空表后插入带唯一索引实体触发ConstraintViolationException

实体定义 #

@Entity
@Table(name = "product",
        indexes = {@Index(name = "productIndex", columnList = "family, group, type", unique = true)})
public class Product implements Serializable {

    @Id
    @Column(name = "id")
    private Long id;

    @Column(name = "family")
    private String family;

    @Column(name = "group")
    private String group;

    @Column(name = "type")
    private String type;

}

业务代码与Repository实现 #

尝试清空表后插入新数据的业务方法：

@Transactional
public void update(List<Product> products) {
    productRepository.deleteAll();
    productRepository.batchInsert(products);
}

ProductRepository定义：

public interface ProductRepository extends JpaRepository<Product, Long>, BatchRepository<Product> { }

BatchRepository的批量插入实现：

@Repository
public class BatchRepository<T> {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public int batchInsert(List<T> entities) {
        int count = 0;

        for (T entity : entities) {
            entityManager.persist(entity);
            count++;

            if (count % 2000 == 0) {
                entityManager.flush();
                entityManager.clear();
            }
        }

        entityManager.flush();
        entityManager.clear();

        return count;
    }

}

触发的异常 #

执行时抛出：

java.sql.BatchUpdateException: ORA-00001: unique constraint (productIndex) violated

问题分析 #

1. 原代码的事务延迟执行问题
   JPA的deleteAll()方法会先将实体加载到一级缓存，默认在事务提交时才执行实际的删除SQL。但你的batchInsert方法中手动调用了entityManager.flush()，会把插入操作立即提交到数据库，此时删除操作还未执行，表中原有数据仍存在，直接触发唯一约束冲突。

2. 更新1中的事务传播属性失效问题
   你将插入方法标记为@Transactional(propagation = Propagation.REQUIRES_NEW)，但如果该方法和update方法在同一个类中，Spring的事务代理不会生效——Spring AOP仅拦截外部Bean的方法调用，内部方法调用无法触发新事务，删除和插入仍处于同一事务中，问题无法解决。

3. 额外排查点：插入数据本身重复
   需确认传入的products列表中，是否存在family、group、type组合重复的记录，这也会触发约束违反。

解决方案 #

方案1：确保删除操作立即执行 #

在deleteAll()后手动触发flush，或者使用deleteAllInBatch()直接执行批量删除SQL：

@Transactional
public void update(List<Product> products) {
    // 方式1：deleteAll后强制flush执行删除
    productRepository.deleteAll();
    entityManager.flush();
    productRepository.batchInsert(products);

    // 方式2：使用deleteAllInBatch直接执行删除SQL，无需额外flush
    // productRepository.deleteAllInBatch();
    // productRepository.batchInsert(products);
}

方案2：让事务传播属性生效 #

将insertProducts方法抽离到单独的Spring Bean中，确保外部调用时REQUIRES_NEW能开启新事务：

// 单独的辅助类
@Service
public class ProductServiceHelper {
    @Autowired
    private ProductRepository productRepository;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void insertProducts(List<Product> products) {
        productRepository.batchInsert(products);
    }
}

// 原业务类
@Service
public class ProductService {
    @Autowired
    private ProductRepository productRepository;
    @Autowired
    private ProductServiceHelper helper;

    @Transactional
    public void update(List<Product> products) {
        productRepository.deleteAll();
        helper.insertProducts(products);
    }
}

方案3：排查插入数据的重复性 #

批量插入前，校验products列表中family、group、type组合是否唯一，避免因自身数据重复导致约束违反。

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