Method countBy

packages/sql/src/SqlEntityManager.ts:181–224

* @inheritDoc

(
    entityName: EntityName<Entity>,
    groupBy: EntityKey<Entity> | readonly EntityKey<Entity>[],
    options: CountByOptions<Entity> = {},
  )

   * @inheritDoc
   */
  override async countBy<Entity extends object>(
    entityName: EntityName<Entity>,
    groupBy: EntityKey<Entity> | readonly EntityKey<Entity>[],
    options: CountByOptions<Entity> = {},
  ): Promise<Dictionary<number>> {
    const em = this.getContext(false) as SqlEntityManager;
    options = { ...options };
    em.prepareOptions(options);
    const meta = em.getMetadata().find(entityName)!;
    const fields = Utils.asArray(groupBy);
    const { where: rawWhere, ...countOptions } = options;

    await em.tryFlush(entityName, options);
    const where = await em.processWhere(entityName, rawWhere ?? ({} as FilterQuery<Entity>), options as any, 'read');

    const qb = em.createQueryBuilder(meta.class);

    (qb as any)
      .select([...fields, raw('count(*) as cnt')])
      .where(where)
      .groupBy(fields as string[]);

    if (countOptions.having) {
      (qb as any).having(countOptions.having);
    }

    if (countOptions.schema) {
      qb.withSchema(countOptions.schema);
    }

    const rows: any[] = await qb.execute('all', { mapResults: false });
    const results: Dictionary<number> = {};

    for (const row of rows) {
      const keyParts = fields.map(f => {
        const col = meta.properties[f as EntityKey<Entity>]?.fieldNames?.[0] ?? f;
        return String(row[col]);
      });
      const key = keyParts.join(Utils.PK_SEPARATOR);
      results[key] = +row.cnt;
    }

    return results;
  }

  override getRepository<T extends object, U extends EntityRepository<T> = SqlEntityRepository<T>>(
    entityName: EntityName<T>,