如何使用Spring Data JPA批量删除MySQL中大量数据？

方案1：使用原生SQL执行TRUNCATE/DELETE #

清空整表场景下，TRUNCATE TABLE是最高效的选择——它直接重置表数据（不会触发触发器，自增主键会重置），执行速度远快于ORM层的批量删除逻辑。如果表存在外键约束导致TRUNCATE无法执行，再退而使用DELETE FROM语句。

在Spring Data JPA中可通过自定义Repository方法实现：

@Repository
public interface YourEntityRepository extends JpaRepository<YourEntity, Long> {
    @Modifying
    @Query(value = "TRUNCATE TABLE your_table_name", nativeQuery = true)
    void truncateTable();

    // 存在外键约束时使用原生DELETE
    @Modifying
    @Query(value = "DELETE FROM your_table_name", nativeQuery = true)
    void deleteAllWithNativeSql();
}

注意：执行这些方法需开启事务，且TRUNCATE默认无法回滚，需根据业务场景谨慎选择。

方案2：分批删除，避免内存溢出与长时锁表 #

如果不能用TRUNCATE（比如需要触发业务逻辑、触发器），可采用分批删除的方式：每次删除固定数量的记录，循环执行直到数据清空。这种方式既不会一次性加载大量数据到内存，也能缩短数据库锁的持有时间。

示例代码：

@Service
@Transactional
public class YourEntityService {
    @Autowired
    private YourEntityRepository repository;

    private static final int BATCH_SIZE = 1000; // 可根据数据库性能调整

    public void deleteAllInBatches() {
        long deletedCount;
        do {
            deletedCount = repository.deleteTopNBatch(BATCH_SIZE);
        } while (deletedCount > 0);
    }
}

// Repository接口新增方法
@Repository
public interface YourEntityRepository extends JpaRepository<YourEntity, Long> {
    @Modifying
    @Query(value = "DELETE FROM your_table_name LIMIT ?1", nativeQuery = true)
    long deleteTopNBatch(int batchSize);
}

方案3：排查deleteAllInBatch停滞的根源 #

你遇到的deleteAllInBatch()停滞问题，通常是因为JPA底层生成无条件的DELETE FROM语句，触发全表扫描并持有表锁；如果实体类配置了级联删除或表存在大量触发器，会进一步拖慢执行速度。

优化方向：

• 检查实体类的级联配置，关闭不必要的cascade = CascadeType.REMOVE，改为手动处理关联数据删除
• 确保表的主键或核心查询字段有索引，避免全表扫描
• 执行前关闭JPA二级缓存与自动刷新，减少ORM层的额外开销

方案4：直接使用JDBC跳过ORM层 #

如果JPA的批量操作开销仍过大，可直接用JdbcTemplate执行删除语句，跳过ORM的对象映射、缓存等环节，性能更接近原生SQL：

@Service
@Transactional
public class YourEntityService {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    private static final int BATCH_SIZE = 1000;

    public void truncateTableWithJdbc() {
        jdbcTemplate.execute("TRUNCATE TABLE your_table_name");
    }

    public void deleteAllInBatchesWithJdbc() {
        final String deleteSql = "DELETE FROM your_table_name LIMIT ?";
        int deleted;
        do {
            deleted = jdbcTemplate.update(deleteSql, BATCH_SIZE);
        } while (deleted > 0);
    }
}

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