Group By结合Having Count筛选多目的地DMC公司失效问题排查

问题根源 #

TypeORM自动生成的SQL会把查询中所有非聚合字段都加入GROUP BY，这会导致分组粒度过细——每个分组仅对应单条目的地记录，COUNT()结果始终为1，自然无法匹配“同时拥有多个目的地”的筛选条件。

可行解决方案 #

方案1：子查询筛选符合条件的DMC Profile ID #

先通过子查询找出拥有所有指定目的地的DMC Profile，再关联回公司表获取完整信息，完全绕开主查询的GROUP BY问题。

TypeORM QueryBuilder示例：

const targetDestinations = ['阿尔及利亚', '阿尔巴尼亚'];
const requiredCount = targetDestinations.length;

const subQuery = getRepository(DmcDestinations)
  .createQueryBuilder('dd')
  .innerJoin('dd.destination', 'd')
  .where('d.name IN (:...destinations)', { destinations: targetDestinations })
  .groupBy('dd.dmcProfileId')
  .having('COUNT(DISTINCT d.id) = :count', { count: requiredCount })
  .select('dd.dmcProfileId');

const result = getRepository(Company)
  .createQueryBuilder('c')
  .innerJoin('c.dmcProfile', 'dp')
  .where('dp.id IN (' + subQuery.getQuery() + ')')
  .andWhere('c.type = :type', { type: 'DMC' })
  .setParameters(subQuery.getParameters())
  .getMany();

方案2：手动指定GROUP BY字段，覆盖TypeORM自动生成逻辑 #

强制让分组粒度仅基于公司或DMC Profile的ID，避免TypeORM自动加入无关字段。注意需确保查询中选中的非聚合字段都能被分组字段唯一确定（比如公司ID对应的公司名称、地址等是唯一的）。

TypeORM QueryBuilder示例：

const targetDestinations = ['阿尔及利亚', '阿尔巴尼亚'];
const requiredCount = targetDestinations.length;

const result = getRepository(Company)
  .createQueryBuilder('c')
  .innerJoin('c.dmcProfile', 'dp')
  .innerJoin('dp.dmcDestinations', 'dd')
  .innerJoin('dd.destination', 'd')
  .where('d.name IN (:...destinations)', { destinations: targetDestinations })
  .andWhere('c.type = :type', { type: 'DMC' })
  .groupBy('c.id') // 仅按公司ID分组，覆盖自动生成的多字段分组
  .having('COUNT(DISTINCT d.id) = :count', { count: requiredCount })
  .getMany();

注：如果TypeORM仍自动添加其他字段到GROUP BY，可以尝试关闭strictMode（在TypeORM配置中设置strict: false），或者在QueryBuilder中使用addGroupBy()明确指定所有需要分组的字段（仅必要字段）。

方案3：多EXISTS子查询（适合目的地数量较少的场景） #

对每个目标目的地单独检查存在性，无需使用GROUP BY和HAVING，逻辑更直观。

TypeORM QueryBuilder示例：

const targetDestinations = ['阿尔及利亚', '阿尔巴尼亚'];

const queryBuilder = getRepository(Company)
  .createQueryBuilder('c')
  .innerJoin('c.dmcProfile', 'dp')
  .where('c.type = :type', { type: 'DMC' });

// 为每个目的地添加EXISTS条件
targetDestinations.forEach((dest, index) => {
  const alias = `d${index}`;
  const subAlias = `dd${index}`;
  queryBuilder.andWhere(`EXISTS (
    SELECT 1 FROM dmc_destinations ${subAlias}
    INNER JOIN destinations ${alias} ON ${subAlias}.destinationId = ${alias}.id
    WHERE ${subAlias}.dmcProfileId = dp.id AND ${alias}.name = :dest${index}
  )`, { [`dest${index}`]: dest });
});

const result = queryBuilder.getMany();

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