使用repository.clear()清空ManyToOne关联的两张表时数据恢复如何解决

你遇到的现象本质是外键约束触发事务回滚导致的，核心逻辑如下：

• TableA存在指向TableB的外键关联，默认数据库的外键约束规则为RESTRICT，即只要还有任意记录关联了TableB的主键，就不允许删除/清空TableB的数据。
• 你的两个清空操作没有在独立的已提交事务中执行，当tableBRepository.clear()触发外键约束报错时，之前执行的tableARepository.clear()操作会被整体回滚，看起来就像TableA的数据“恢复”了。
• 额外注意：TypeORM的clear()方法底层执行的是TRUNCATE TABLE语句，部分数据库对TRUNCATE操作的外键校验比普通DELETE更严格，即使关联表数据已经清空，也可能因为外键规则拒绝执行TRUNCATE。

方案1：调整执行顺序+事务包裹（推荐，无需修改实体配置） #

优先清空有外键依赖的TableA，再清空被依赖的TableB，两个操作包裹在同一个事务中保证原子性，示例代码如下：

// 注入DataSource后通过QueryRunner开启事务
const queryRunner = this.dataSource.createQueryRunner();
await queryRunner.connect();
await queryRunner.startTransaction();

try {
  // 先清空有外键依赖的表
  await queryRunner.manager.getRepository(TableA).clear();
  // 再清空被依赖的主表
  await queryRunner.manager.getRepository(TableB).clear();
  // 提交事务后操作才会真正生效
  await queryRunner.commitTransaction();
} catch (err) {
  // 任意一步报错就回滚所有操作
  await queryRunner.rollbackTransaction();
  throw err;
} finally {
  await queryRunner.release();
}

如果执行后还是报错，检查是否有其他表未显式配置关联、但也指向了TableB的主键，存在遗漏的依赖数据。

方案2：配置级联删除（适合业务需要级联删除的场景） #

修改TableA的关联注解，配置外键的级联删除规则，后续删除TableB的记录时，数据库会自动删除关联的TableA记录，无需手动先清TableA：

@Entity('table_A')
export class TableA{
  @PrimaryGeneratedColumn()
  id: number;

  @Column()
  B_ID: number;
  // 新增onDelete: 'CASCADE'配置，同时指定关联的外键列
  @ManyToOne(() => TableB, { onDelete: 'CASCADE' })
  @JoinColumn({ name: 'B_ID' })
  tableB: TableB;

  @Column()
  userId: number;
  @ManyToOne(() => User, { onDelete: 'CASCADE' })
  @JoinColumn({ name: 'userId' })
  user: User;
}

配置生效后直接清空TableB即可，关联的TableA数据会被自动清理。

方案3：临时禁用外键校验（仅适合测试环境清数据，不推荐生产使用） #

如果不需要保留外键约束的校验，可以临时关闭外键检查后执行清空，以MySQL为例：

const queryRunner = this.dataSource.createQueryRunner();
await queryRunner.connect();
await queryRunner.startTransaction();
try {
  await queryRunner.query('SET FOREIGN_KEY_CHECKS = 0');
  await queryRunner.manager.getRepository(TableA).clear();
  await queryRunner.manager.getRepository(TableB).clear();
  await queryRunner.query('SET FOREIGN_KEY_CHECKS = 1');
  await queryRunner.commitTransaction();
} catch (err) {
  await queryRunner.rollbackTransaction();
  throw err;
} finally {
  await queryRunner.release();
}

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