NestJS：如何将Config Service值传入构造器/装饰器及解决mysql_sca为undefined问题

1. 核心问题原因 #

装饰器（比如@InjectDataSource）的参数在类定义阶段就会执行，此时NestJS的依赖注入容器还未完全初始化，直接调用configuration()无法获取到正确的配置值（尤其是配置异步加载的场景），这就是mysql_sca返回undefined的根本原因。

2. 提取连接名称为常量 #

将数据库连接名称定义为独立常量，确保在代码执行早期就能获取到有效值：

// src/config.ts
import * as dotenv from 'dotenv';

// 提前加载环境变量（若未通过ConfigModule自动加载）
dotenv.config();

// 定义常量，默认值兜底避免undefined
export const MYSQL_SCA_CONNECTION_NAME = process.env.MYSQL_SCA_CONNECTION_NAME || 'mysql_sca';

export default () => ({
  mysql_sca: {
    connectionName: MYSQL_SCA_CONNECTION_NAME,
    host: process.env.MYSQL_SCA_HOST,
    port: parseInt(process.env.MYSQL_SCA_PORT, 10),
    username: process.env.MYSQL_SCA_USERNAME,
    password: process.env.MYSQL_SCA_PASSWORD,
    database: process.env.MYSQL_SCA_DATABASE,
  },
});

3. 正确注册多数据源 #

在模块中通过TypeOrmModule.forRootAsync从ConfigService读取配置，注册指定名称的数据源：

// src/app.module.ts
import { Module } from '@nestjs/common';
import { ConfigModule, ConfigService } from '@nestjs/config';
import { TypeOrmModule } from '@nestjs/typeorm';
import configuration, { MYSQL_SCA_CONNECTION_NAME } from './config';
import { YourEntity } from './entities';

@Module({
  imports: [
    ConfigModule.forRoot({
      isGlobal: true,
      load: [configuration],
      envFilePath: '.env', // 指定环境变量文件路径
    }),
    // 主数据源（默认无名称）
    TypeOrmModule.forRootAsync({
      useFactory: (configService: ConfigService) => ({
        type: 'mysql',
        host: configService.get('mysql.host'),
        port: configService.get('mysql.port'),
        username: configService.get('mysql.username'),
        password: configService.get('mysql.password'),
        database: configService.get('mysql.database'),
        entities: [YourEntity],
        synchronize: false,
      }),
      inject: [ConfigService],
    }),
    // SCA专属数据源（指定名称）
    TypeOrmModule.forRootAsync({
      name: MYSQL_SCA_CONNECTION_NAME,
      useFactory: (configService: ConfigService) => ({
        name: MYSQL_SCA_CONNECTION_NAME,
        type: 'mysql',
        host: configService.get('mysql_sca.host'),
        port: configService.get('mysql_sca.port'),
        username: configService.get('mysql_sca.username'),
        password: configService.get('mysql_sca.password'),
        database: configService.get('mysql_sca.database'),
        entities: [YourEntity],
        synchronize: false,
      }),
      inject: [ConfigService],
    }),
  ],
})
export class AppModule {}

4. 使用常量注入指定数据源 #

在服务/控制器的构造器中，直接用定义好的常量作为@InjectDataSource的参数：

import { InjectDataSource } from '@nestjs/typeorm';
import { DataSource } from 'typeorm';
import { MYSQL_SCA_CONNECTION_NAME } from './config';

// ...

constructor(
  private configService: EnvService,
  private globalHttpService: GlobalHttpService,
  @InjectDataSource() private dataSource: DataSource,
  @InjectDataSource(MYSQL_SCA_CONNECTION_NAME) private mysqlDataSource: DataSource,
  private dbService: DbService,
  private chroniclesService: ChroniclesService,
  private commonIspService: CommonIspService,
) {}

额外检查点 #

• 确认.env文件中存在MYSQL_SCA_CONNECTION_NAME字段，且拼写无错误
• 保证ConfigModule的isGlobal设为true，避免在其他模块重复导入配置
• 若使用异步配置加载（比如从远程配置中心获取），需确保配置在模块初始化前完成加载

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