在NestJS中用TypeORM实现双向关联查询并规避循环依赖

场景背景 #

我用NestJS构建API，定义了一对多关联的Site和Truck实体，代码如下：

@Entity()
export class Site{
    @PrimaryColumn()
    SiteId: number

    @OneToMany(() => Truck, truck => truck.Site)
    TruckSystemID?: Truck[];
}

@Entity()
export class Truck{
    @PrimaryColumn()
    SystemId: number

    @ManyToOne(() => Site, (site) => site.TruckSystemID) // 注：原代码中`site.photos`应为笔误，修正为关联字段名
    Site: Site
}

目前在Truck侧已实现根据SiteId查询关联卡车的功能，通过注入SitesService获取Site实体后查询，代码如下：

async findBySite(siteId: number): Promise<CreateTruckDto[]> {
    const truckEntities: Truck[] = await this.truckRepository.find({
      where: {
        Site: await this.sitesService.findOneEntity(siteId)
      },
      relations: {
        Site: true
      }
    })
    // 省略DTO转换逻辑
}

但如果要在Site侧实现根据卡车SystemId查询对应站点的功能，注入TruckService会导致模块循环依赖，现针对以下疑问寻求解决方案：

问题解答 #

1. 如何避免循环依赖？ #

有两种核心可行方案：

• 直接使用Repository查询，跳过跨模块Service注入：
  无需在SitesService中注入TruckService，直接在SitesService注入TruckRepository（需在TruckModule中导出该Repository，或通过共享模块统一管理），直接执行关联查询：

  async findByTruckSystemId(systemId: number): Promise<Site> {
    // 方式1：先查卡车再取关联站点
    const truck = await this.truckRepository.findOne({
      where: { SystemId: systemId },
      relations: { Site: true }
    });
    return truck?.Site;
  
    // 方式2：直接通过SiteRepository关联查询
    // return this.siteRepository.findOne({
    //   where: { TruckSystemID: { SystemId: systemId } },
    //   relations: { TruckSystemID: false }
    // });
  }
  

• 拆分共享模块：
  将两个实体的Repository、通用查询逻辑抽离为独立的共享模块（如VehicleSharedModule），在该模块中导出SiteRepository和TruckRepository，然后SiteModule和TruckModule仅需导入此共享模块，各自使用Repository完成查询，无需互相注入Service。

2. 双向关联查询是否合理？当前跨模块注入服务的实现是否低效？ #

• 双向关联查询完全合理，属于ORM关联设计的常规业务场景，实际开发中经常需要从关联关系的任意一端发起查询。
• 当前跨模块注入Service的实现确实低效：
  每次查询都需要先调用SitesService.findOneEntity获取Site实体，再传入Truck查询条件，相当于多执行了一次数据库查询。直接使用Repository的关联ID查询可合并为一次JOIN查询，性能更优：

  // 优化后的Truck侧查询，无需注入SitesService
  async findBySite(siteId: number): Promise<CreateTruckDto[]> {
    const truckEntities: Truck[] = await this.truckRepository.find({
      where: { Site: { SiteId: siteId } }, // 直接通过关联ID查询
      relations: { Site: true }
    });
    // 省略DTO转换逻辑
  }
  

3. 使用forwardRef()仍无法解决循环依赖导致编译失败，该如何处理？ #

若必须保留双向Service注入（如业务逻辑复杂无法直接用Repository），但forwardRef()未解决问题，可按以下步骤排查修复：

• 检查forwardRef的完整配置：
  需同时在模块导入和服务注入时使用forwardRef：

  // SiteModule中导入TruckModule
  imports: [forwardRef(() => TruckModule)]
  // TruckModule中导入SiteModule
  imports: [forwardRef(() => SiteModule)]
  // SitesService中注入TruckService
  constructor(
    @Inject(forwardRef(() => TruckService))
    private readonly truckService: TruckService
  ) {}
  

• 排查隐藏循环依赖：检查DTO、装饰器、工具类等是否存在互相引用，将此类依赖抽离为独立文件。
• 改用全局服务：将其中一个Service标记为@Global()，另一个模块无需导入对应Module即可直接注入Service，避免模块间循环导入。
• 重构业务逻辑：将需要双向调用的逻辑抽离为独立的第三方服务（如VehicleQueryService），让SiteService和TruckService均注入该第三方服务，而非互相注入。

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