From 6846d73611c33162cc46c8e27f06492c94c21d32 Mon Sep 17 00:00:00 2001 From: Aswin Ashar Abdullah Date: Fri, 26 Jul 2024 12:50:49 +0700 Subject: [PATCH] fix(base) perbaikan query transaction --- src/core/modules/domain/usecase/base.manager.ts | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/core/modules/domain/usecase/base.manager.ts b/src/core/modules/domain/usecase/base.manager.ts index 9900f13..edcf5b0 100644 --- a/src/core/modules/domain/usecase/base.manager.ts +++ b/src/core/modules/domain/usecase/base.manager.ts @@ -60,7 +60,7 @@ export abstract class BaseManager { try { this.setUser(); - // this.queryRunner.startTransaction(); + this.queryRunner.startTransaction(); this.baseLog.verbose('prepareData'); await this.prepareData(); @@ -80,11 +80,12 @@ export abstract class BaseManager { this.baseLog.verbose('afterProcess'); await this.afterProcess(); - // this.baseLog.verbose('commitTransaction'); - // await this.queryRunner.commitTransaction(); + this.baseLog.verbose('commitTransaction'); + await this.queryRunner.commitTransaction(); - // await this.queryRunner.release(); + await this.queryRunner.release(); } catch (e) { + await this.queryRunner.rollbackTransaction(); if (e.response) throw new Error(JSON.stringify(e.response)); else throw new Error(e.message); }