github-mirrors/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2026-05-18 03:10:24 +03:00
Code Issues Packages Projects Releases Wiki Activity

refactor: rewrite countAll SQL to use GROUP BY count

Browse Source 
Signed-off-by: izzy <me@insrt.uk>
This commit is contained in:
izzy
2026-02-06 17:20:27 +00:00
parent 3d5db67656
commit 08fb19b5b7
1 changed files with 9 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/repositories/integrity.repository.ts
+9 -21
View File
@@ -39,28 +39,16 @@ export class IntegrityRepository {
} }
@GenerateSql({ params: [] }) @GenerateSql({ params: [] })
getIntegrityReportSummary() { async getIntegrityReportSummary() {
return this.db const counts = await this.db
.selectFrom('integrity_report') .selectFrom('integrity_report')
.select((eb) => .select(['type', this.db.fn.countAll<number>().as('count')])
eb.fn .groupBy('type')
.countAll<number>() .execute();
.filterWhere('type', '=', IntegrityReportType.ChecksumFail)
.as(IntegrityReportType.ChecksumFail), return Object.fromEntries(
) Object.values(IntegrityReportType).map((type) => [type, counts.find((count) => count.type === type)?.count || 0]),
.select((eb) => ) as Record<IntegrityReportType, number>;
eb.fn
.countAll<number>()
.filterWhere('type', '=', IntegrityReportType.MissingFile)
.as(IntegrityReportType.MissingFile),
)
.select((eb) =>
eb.fn
.countAll<number>()
.filterWhere('type', '=', IntegrityReportType.UntrackedFile)
.as(IntegrityReportType.UntrackedFile),
)
.executeTakeFirstOrThrow();
} }
@GenerateSql({ params: [{ cursor: DummyValue.NUMBER, limit: 100 }, DummyValue.STRING] }) @GenerateSql({ params: [{ cursor: DummyValue.NUMBER, limit: 100 }, DummyValue.STRING] })