NestJS项目中含数据库事务的E2E测试随机失败问题排查

排查事务代码正确性 #

• 确保服务中所有事务内的异步操作都用await等待，包括事务本身的执行。比如：

  // 服务层代码
  async updateDataInTransaction() {
    return await this.manager.transaction(async (txManager) => {
      // 所有数据库操作必须await
      await txManager.save(Entity, data);
      await txManager.update(Entity, condition, updateData);
    });
  }
  

• 如果使用QueryRunner手动管理事务，必须确保完成commitTransaction()和release()后才返回响应：

  async updateWithQueryRunner() {
    const queryRunner = this.connection.createQueryRunner();
    await queryRunner.connect();
    await queryRunner.startTransaction();
    try {
      await queryRunner.save(Entity, data);
      await queryRunner.commitTransaction();
    } catch (e) {
      await queryRunner.rollbackTransaction();
      throw e;
    } finally {
      // 必须等待释放完成
      await queryRunner.release();
    }
  }
  

• 控制器层必须await服务的事务方法再返回响应，不能直接返回Promise而不等待：

  @Post('/trigger-transaction')
  async triggerTransaction() {
    // 这里必须await，确保事务完成后才返回响应
    await this.dataService.updateDataInTransaction();
    return { success: true };
  }
  

修正测试代码逻辑 #

• 绝对不要依赖sleep()来规避问题，这是不可靠的。确保测试中第一个请求的Promise完全resolve后，再发送第二个请求：

  // 测试代码示例（使用supertest）
  it('should fetch updated data after transaction', async () => {
    // 等待第一个请求完成
    await request(app.getHttpServer())
      .post('/trigger-transaction')
      .send(payload)
      .expect(201);
    
    // 再发送第二个请求
    const response = await request(app.getHttpServer())
      .get('/fetch-updated-data')
      .expect(200);
    
    // 断言数据正确
    expect(response.body.data).toEqual(expectedData);
  });
  

其他可能的排查点 #

• 检查数据库隔离级别：确保PostgreSQL使用默认的READ COMMITTED，避免因隔离级别导致的读取未提交数据问题。
• 测试数据库连接池：确保测试中每个请求使用的连接是独立的，或者连接池配置合理，避免连接复用导致的事务上下文残留。
• 检查TypeORM配置：确保synchronize或migrations在测试环境中不会干扰事务执行，比如不要在测试过程中自动同步表结构。

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