NestJS服务关停时清空TypeORM MySQL报Pool is closed错误

问题场景 #

尝试在NestJS服务关闭流程中清空TypeORM对接的MySQL表数据，初始实现代码如下：

export class RoomsService {
  async onApplicationShutdown() {
    await this.roomService.deleteAll()
  }
}

async deleteAll(): Promise<DeleteResult> {
    const res = await this.roomRepository.delete('*');
    return res;
  } 

执行时触发固定报错，即使去掉async/await语法也会复现：

Error: Pool is closed.
at C:\Users\Admin\Desktop\sites\UltimatePartyRoom\upr-server\node_modules\mysql2\lib\pool.js:39:40
at processTicksAndRejections (node:internal/process/task_queues:77:11)

报错根因 #

• 生命周期钩子选择错误：onApplicationShutdown钩子触发时，NestJS已经完成了核心依赖的销毁流程，TypeORM持有的MySQL连接池已经被关闭，此时再发起数据库操作必然会拿到已关闭的连接池抛出错误。
• 全量删除写法错误：TypeORM的delete方法不支持传入'*'作为参数，该方法接收查询条件对象，全表删除有专门的实现API。

正确实现步骤 #

• 替换生命周期钩子：将onApplicationShutdown替换为beforeApplicationShutdown，该钩子在NestJS启动模块销毁流程（包括关闭数据库连接、断开第三方服务连接）之前触发，此时数据库连接池处于可用状态。
• 开启NestJS关闭钩子监听：必须在入口文件main.ts中调用app.enableShutdownHooks()，否则NestJS不会监听进程退出信号，生命周期钩子的执行顺序会完全混乱。
• 修正全表删除逻辑：使用TypeORM内置的clear()方法清空表数据，该方法是官方提供的全表清空API，执行效率高于手写DELETE语句，且会自动处理表级约束。

完整代码示例 #

main.ts配置：

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  // 开启关闭钩子监听，必须配置
  app.enableShutdownHooks();
  await app.listen(3000);
}
bootstrap();

Service层实现：

import { BeforeApplicationShutdown, Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { Room } from './entities/room.entity';

@Injectable()
export class RoomsService implements BeforeApplicationShutdown {
  constructor(
    @InjectRepository(Room)
    private readonly roomRepository: Repository<Room>,
  ) {}

  async beforeApplicationShutdown() {
    await this.deleteAll();
  }

  async deleteAll(): Promise<void> {
    // 全量清空room表所有数据
    await this.roomRepository.clear();
    // 如果不想用clear，全量delete的正确写法是 await this.roomRepository.delete({})
  }
}

注意事项 #

多表关联场景下，需要按照外键依赖的倒序执行清空操作，否则会触发外键约束报错
生产环境谨慎使用全表清空逻辑，建议增加环境判断，仅在测试、开发环境执行该逻辑。

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