Trying to use the DB (not working)

databases/init/mobility.sql

@@ -1,12 +0,0 @@
-CREATE TABLE IF NOT EXISTS students (
-  id INTEGER PRIMARY KEY AUTOINCREMENT,
-  firstName TEXT NOT NULL,
-  lastName TEXT NOT NULL,
-  email TEXT NOT NULL,
-  promotion TEXT NOT NULL
-);
-CREATE TABLE IF NOT EXISTS promotions (
-  id INTEGER PRIMARY KEY AUTOINCREMENT,
-  name TEXT NOT NULL,
-  year INTEGER NOT NULL
-);

databases/mobility.ts

@@ -1,21 +1,30 @@
-import { Database } from "@db/sqlite";
+import { DB } from "https://deno.land/x/sqlite/mod.ts";
 
-export default async function insertIntoMobility(data: Array<{ firstName: string; lastName: string; email: string }>, promoName: string) {
+export default function insertIntoMobility(
+  data: Array<{ firstName: string; lastName: string; email: string }>,
+  promoName: string
+) {
   try {
-    const databasePath = "databases/data/mobility.db";
-    const db = new Database(databasePath);
+    const db = new DB("databases/data/mobility.db");
 
-    db.transaction(() => {
-      for (const student of data) {
-        db.query(
-          "INSERT INTO students (firstName, lastName, email, promotion) VALUES (?, ?, ?, ?)",
-          [student.firstName, student.lastName, student.email, promoName]
-        );
-      }
-    })();
+    db.execute(`
+      CREATE TABLE IF NOT EXISTS students (
+        id INTEGER PRIMARY KEY AUTOINCREMENT,
+        firstName TEXT NOT NULL,
+        lastName TEXT NOT NULL,
+        email TEXT NOT NULL,
+        promotion TEXT NOT NULL
+      );
+    `);
+
+    const insertQuery = "INSERT INTO students (firstName, lastName, email, promotion) VALUES (?, ?, ?, ?)";
+    for (const student of data) {
+      db.query(insertQuery, [student.firstName, student.lastName, student.email, promoName]);
+    }
+
+    console.log(`Data for promotion ${promoName} inserted successfully.`);
 
     db.close();
-    console.log(`Data for promotion ${promoName} inserted successfully.`);
   } catch (error) {
     console.error("Error inserting data into mobility database:", error);
   }