Throw exception to rollback transaction if sql migration fails

leapfrogtechnology · Mar 23, 2021 · 7cd8016 · 7cd8016
1 parent 8ae0cbc
commit 7cd8016
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/migration/KnexMigrationSource.ts b/src/migration/KnexMigrationSource.ts
@@ -41,8 +41,6 @@ class KnexMigrationSource {
    * @returns {string}
    */
   getMigrationName(migration: string): string {
-    this.log('getMigrationName - resolve: ', migration);
-
     return migration;
   }
 

diff --git a/src/service/execution.ts b/src/service/execution.ts
@@ -74,5 +74,11 @@ export async function executeOperation<T extends OperationContext>(
     await context.params.onFailed(result);
   }
 
+  if (result.error) {
+    logDb('Result:\n%O', result);
+
+    throw result.error
+  }
+
   return result;
 }