NestJS中如何替代已废弃的getConnectionManager与getManager？

TypeORM 0.3+ 废弃了getConnection、getManager等全局方法，改用DataSource实例来处理事务。在NestJS中可以通过以下两种方式解决：

方案一：依赖注入获取DataSource（推荐） #

@nestjs/typeorm@9.x 已完全兼容TypeORM 0.3的DataSource，直接通过依赖注入就能拿到全局的DataSource实例，无需手动创建。

实现步骤： #

1. 在需要处理事务的服务中注入DataSource：

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';
import { YourEntity } from './entities/your.entity'; // 替换为你的实体

@Injectable()
export class YourService {
  constructor(private readonly dataSource: DataSource) {}

  async executeTransactionalLogic() {
    // 调用DataSource的transaction方法开启事务
    await this.dataSource.transaction(async (transactionalEntityManager) => {
      // 所有数据库操作必须使用传入的transactionalEntityManager
      await transactionalEntityManager.save(YourEntity, { name: 'test' });
      await transactionalEntityManager.delete(YourEntity, { id: 1 });
      
      // 若回调内抛出异常，事务会自动回滚；正常执行则自动提交
    });
  }
}

2. 保持你当前app.module.ts中TypeOrmModule.forRoot的配置不变即可，NestJS会自动创建并管理全局DataSource实例。

方案二：手动创建全局DataSource实例（适合全局访问场景） #

如果需要在模块初始化等特殊场景下直接访问DataSource，可以手动创建实例并关联到NestJS的TypeORM模块：

实现步骤： #

1. 创建单独的data-source.ts文件：

import { DataSource, DataSourceOptions } from 'typeorm';
import * as config from './config'; // 引入你的配置文件

export const appDataSource = new DataSource({
  type: 'postgres',
  host: config.host,
  port: config.port,
  username: config.user || 'postgres',
  password: config.password,
  database: config.dbName,
  autoLoadEntities: true,
} as DataSourceOptions);

2. 修改app.module.ts，用TypeOrmModule.forRootAsync关联这个DataSource：

import { Module } from '@nestjs/common';
import { ConfigModule } from '@nestjs/config';
import { TypeOrmModule } from '@nestjs/typeorm';
import { appDataSource } from './data-source';
import { configuration } from './config';

@Module({
  imports: [
    ConfigModule.forRoot({
      isGlobal: true,
      cache: true,
      load: [configuration],
    }),
    TypeOrmModule.forRootAsync({
      useFactory: () => appDataSource.options,
      dataSourceFactory: async () => {
        await appDataSource.initialize();
        return appDataSource;
      },
    }),
  ],
})
export class AppModule {}

3. 之后可在任意位置导入appDataSource并调用事务：

import { appDataSource } from './data-source';

async function someGlobalOperation() {
  await appDataSource.transaction(async (em) => {
    // 执行事务内的数据库操作
  });
}

关键注意事项 #

• 你的依赖版本是兼容的：@nestjs/typeorm@9.0.1 匹配 typeorm@0.3.15，无需调整版本
• 事务中必须使用传入的transactionalEntityManager执行操作，不能用全局的EntityManager/Repository，否则操作不会纳入事务
• 事务回调内抛出任何异常都会触发自动回滚，正常执行完成则自动提交

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