feat: execute migrations in transaction and lock table

gabts · Jun 30, 2021 · 0899a39 · 0899a39
1 parent f21b4a3
commit 0899a39
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -166,9 +166,11 @@ export async function migratorosaurus(
     }
   }
 
+  await client.query(`BEGIN; LOCK TABLE ${table} IN EXCLUSIVE MODE;`);
   targetFile && targetFile.index <= lastIndex
     ? await downMigration(client, log, table, files, lastIndex, targetFile)
     : await upMigration(client, log, table, files, lastIndex, targetFile);
+  await client.query('COMMIT;');
 
   await client.end();
   log('🌋 migratorosaurus completed!');