Mikro-ORM批量插入时如何全量回滚并捕获行级错误？

你当前代码的核心问题是在循环内部调用了em.commit()，这会将每次循环中持久化的实体直接提交到数据库，导致前面的行已经被永久保存，出错时只能回滚最后一次的变更，无法实现全量回滚。

要实现「全量回滚+捕获行级错误」，需要将事务的提交放在循环外部，同时在循环内通过flush()触发单条数据的插入操作（事务未提交），这样一旦某行出错，整个事务可以完全回滚，同时能定位到错误行号。

方案1：事务内逐行flush捕获错误 #

await this.em.begin();
try {
  let row = 1;
  for (const data of entries) {
    const entity = this.studentsRepo.create(data);
    this.em.persist(entity);
    
    try {
      // 触发当前实体的INSERT操作，但事务未提交
      await this.em.flush();
    } catch (e) {
      // 出错后立即回滚整个事务，所有已插入的行都会被撤销
      await this.em.rollback();
      throw new Error(`第 ${row} 行插入失败：${e.message}`);
    }
    
    row++;
  }
  // 所有行都插入成功后，再提交整个事务
  await this.em.commit();
} catch (e) {
  // 处理外层可能的其他异常，确保事务最终回滚
  if (this.em.isInTransaction()) {
    await this.em.rollback();
  }
  throw e;
}

关键逻辑说明 #

• em.flush()：会将当前EntityManager中待持久化的实体发送到数据库执行，但不会提交事务，所有操作都处于未确认状态。
• 事务全局控制：整个循环在同一个事务中，任何一行出错都会触发全量回滚，确保数据库状态回到初始状态。
• 行号定位：通过循环变量row直接标记当前处理的行，出错时可以精准抛出错误位置。

方案2：预检查+事务处理（优化用户体验） #

如果希望提前发现重复的code（减少数据库层面的错误触发），可以在插入前先查询数据库做预检查，但要注意：并发场景下仍可能出现唯一约束冲突，所以数据库的唯一约束不能省略，预检查仅作为体验优化。

await this.em.begin();
try {
  let row = 1;
  for (const data of entries) {
    if (data.code) {
      // 预检查当前code是否已存在
      const codeExists = await this.studentsRepo.exists({ code: data.code });
      if (codeExists) {
        await this.em.rollback();
        throw new Error(`第 ${row} 行的code「${data.code}」已存在`);
      }
    }
    
    const entity = this.studentsRepo.create(data);
    this.em.persist(entity);
    await this.em.flush();
    
    row++;
  }
  await this.em.commit();
} catch (e) {
  if (this.em.isInTransaction()) {
    await this.em.rollback();
  }
  throw e;
}

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