use a transaction for stability

Author: mitchellston

src/mysql/runMigrations.ts

@@ -43,39 +43,39 @@ export async function runMigrations(
 
     // Execute the migrations sql
     const path = `${migrationsPath}/${migration}/migration.sql`;
+    let statements = ""; // Used to create the checksum
+    // Execute the migrations line by line
+    await prisma.$transaction(async (tx) => {
+      const fileStream = fs.createReadStream(path);
+      const rl = readline.createInterface({
+        input: fileStream,
+        crlfDelay: Infinity,
+      });
 
-    // @TODO: Make this safer/ better
-    // Read file line by line
-    const fileStream = fs.createReadStream(path);
-    const rl = readline.createInterface({
-      input: fileStream,
-      crlfDelay: Infinity,
-    });
-
-    let statements = "";
-    let statement = "";
+      let statement = "";
 
-    for await (const line of rl) {
-      // Skip comments and empty lines
-      if (
-        line.startsWith("--") ||
-        line.startsWith("/*") ||
-        line.trim() === ""
-      ) {
-        continue;
-      }
+      for await (const line of rl) {
+        // Skip comments and empty lines
+        if (
+          line.startsWith("--") ||
+          line.startsWith("/*") ||
+          line.trim() === ""
+        ) {
+          continue;
+        }
 
-      statement += line + " ";
+        statement += line + " ";
 
-      // If the line ends with a semicolon, execute the statement
-      if (line.trim().endsWith(";")) {
-        await prisma.$executeRawUnsafe(statement);
-        statements += statement;
+        // If the line ends with a semicolon, execute the statement
+        if (line.trim().endsWith(";")) {
+          await tx.$executeRawUnsafe(statement);
+          statements += statement;
 
-        // Reset statement
-        statement = "";
+          // Reset statement
+          statement = "";
+        }
       }
-    }
+    });
 
     // Update the migration table
     const getFinishedDateTime = new Date();

src/types/PrismaClient/index.ts

@@ -1,5 +1,6 @@
 import type { PrismaClientConfig } from "./prismaClientConfig";
 
+// @TODO: Get the real type
 export type PrismaClient = {
   _engine: {
     config: PrismaClientConfig;
@@ -14,4 +15,5 @@ export type PrismaClient = {
   ) => Promise<unknown>;
   $queryRawUnsafe: (query: string, ...values: any[]) => Promise<unknown>;
   $executeRawUnsafe: (query: string, ...values: any[]) => Promise<unknown>;
+  $transaction: (queries: (fn: PrismaClient) => Promise<void>) => Promise<void>;
 };