Spring Data同一事务实现删后批量插入：单条失败不中断

嗨，我来帮你搞定这个问题！你遇到的核心痛点是Spring Data JPA自带的save(Iterable)会在单条记录插入失败时触发整个事务回滚，而你需要的是跳过错误记录、继续处理其余数据的能力。下面是具体的实现方案和细节说明：

要实现“单条失败不影响全局”的效果，关键是把每条插入操作隔离在独立的事务中，同时保证初始的删除操作是原子性的。这样一来，某条记录插入失败只会回滚自己的小事务，不会波及已经成功的插入或之前的删除操作。

这里提供两种常用的实现方式，你可以根据自己的偏好选择：

方式一：使用TransactionTemplate手动控制事务 #

这种方式更灵活，能直接在方法内控制事务的边界：

import org.springframework.jdbc.datasource.DataAccessException;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.repository.CrudRepository;

// 假设你的实体类是Employee
public class EmployeeService {

    @Autowired
    private CrudRepository<Employee, Long> employeeRepository;

    @Autowired
    private PlatformTransactionManager transactionManager;

    public void saveToDB(List<Employee> dataList) {
        // 1. 先执行删除操作，用独立事务确保原子性
        TransactionTemplate deleteTx = new TransactionTemplate(transactionManager);
        deleteTx.execute(status -> {
            employeeRepository.deleteAll();
            return null;
        });

        // 2. 逐条插入，每条用独立事务处理
        TransactionTemplate insertTx = new TransactionTemplate(transactionManager);
        for (Employee emp : dataList) {
            try {
                insertTx.execute(status -> {
                    employeeRepository.save(emp);
                    return null;
                });
            } catch (DataAccessException e) {
                // 这里可以记录错误日志、标记失败记录等
                System.err.printf("插入记录失败 [ID: %d, Name: %s]，错误信息：%s%n", 
                                 emp.getId(), emp.getName(), e.getMessage());
                // 捕获异常后继续执行下一条
            }
        }
    }
}

方式二：用事务传播级别实现独立事务 #

通过给单条插入的方法设置REQUIRES_NEW传播级别，让每条插入都开启新事务：

import org.springframework.jdbc.datasource.DataAccessException;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.repository.CrudRepository;

public class EmployeeService {

    @Autowired
    private CrudRepository<Employee, Long> employeeRepository;

    @Transactional
    public void saveToDB(List<Employee> dataList) {
        // 第一步：删除所有数据，在当前事务中执行
        employeeRepository.deleteAll();

        // 第二步：逐条调用独立事务的插入方法
        for (Employee emp : dataList) {
            try {
                saveSingleEmployee(emp);
            } catch (DataAccessException e) {
                System.err.printf("插入记录失败 [ID: %d, Name: %s]，错误信息：%s%n", 
                                 emp.getId(), emp.getName(), e.getMessage());
            }
        }
    }

    // 该方法每次调用都会开启新事务，失败仅回滚自身
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void saveSingleEmployee(Employee employee) {
        employeeRepository.save(employee);
    }
}

1. 删除操作的原子性：删除所有数据的逻辑必须放在一个独立事务中，避免出现“删了一半就中断”的不一致情况。
2. 异常捕获范围：要捕获DataAccessException及其子类（比如SQLIntegrityConstraintViolationException，对应你示例中sal字段类型不匹配的错误），确保错误能被正确捕获并跳过。
3. 性能优化：如果数据量很大，逐条插入可能会有性能问题。你可以开启Hibernate的批量插入优化，在配置文件中添加：

   spring.jpa.properties.hibernate.jdbc.batch_size=50
   spring.jpa.properties.hibernate.order_inserts=true
   

   这样Hibernate会自动把多条save操作合并成批量SQL语句，提升插入效率。
4. 为什么原方案不行？：你原来的save(Iterable)是在同一个事务中执行所有插入，一旦某条失败，整个事务会回滚——包括之前的删除操作和已经成功插入的记录，完全不符合你“失败后继续执行”的需求。

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