From db95d126b84f33273c60125f800c104ce7bd981a Mon Sep 17 00:00:00 2001 From: Xavier Carron <33637571+xav-car@users.noreply.github.com> Date: Tue, 24 Sep 2024 11:16:45 +0200 Subject: [PATCH] tech?(api): use batch insert to create jobs --- .../infrastructure/repositories/jobs/job-repository.js | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/api/src/shared/infrastructure/repositories/jobs/job-repository.js b/api/src/shared/infrastructure/repositories/jobs/job-repository.js index abf3c51d1ce..e470c5b321a 100644 --- a/api/src/shared/infrastructure/repositories/jobs/job-repository.js +++ b/api/src/shared/infrastructure/repositories/jobs/job-repository.js @@ -59,7 +59,11 @@ export class JobRepository { async #send(jobs) { const knexConn = DomainTransaction.getConnection(); - return knexConn('pgboss.job').insert(jobs); + const results = await knexConn.batchInsert('pgboss.job', jobs); + + const rowCount = results.reduce((total, batchResult) => total + (batchResult.rowCount || 0), 0); + + return { rowCount }; } async performAsync(...datas) {