Files
PolyMPR/routes/(apps)/students/api/insert_students.ts
T

103 lines
2.8 KiB
TypeScript

import { Handlers } from "$fresh/server.ts";
import { Database } from "@db/sqlite";
export const handler: Handlers = {
async GET() {
try {
const db = new Database("databases/data/mobility.db");
db.prepare(
`
CREATE TABLE IF NOT EXISTS promotions (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT UNIQUE NOT NULL
);
`
).run();
db.prepare(
`
CREATE TABLE IF NOT EXISTS students (
id INTEGER PRIMARY KEY AUTOINCREMENT,
firstName TEXT NOT NULL,
lastName TEXT NOT NULL,
email TEXT NOT NULL,
promotionId INTEGER NOT NULL,
FOREIGN KEY (promotionId) REFERENCES promotions (id)
);
`
).run();
const promotions = db.prepare("SELECT id, name FROM promotions").all();
const students = db
.prepare(
`
SELECT students.id, firstName, lastName, email, promotionId, promotions.name AS promotionName
FROM students
JOIN promotions ON students.promotionId = promotions.id
`
)
.all();
db.close();
return new Response(
JSON.stringify({ promotions, students }),
{
status: 200,
headers: { "Content-Type": "application/json" },
}
);
} catch (error) {
console.error("Error fetching data:", error);
return new Response("Failed to fetch data", { status: 500 });
}
},
async POST(request) {
console.log("API /mobility/api/insert_students called");
try {
const body = await request.json();
const { data, promoName } = body;
console.log("Received data:", { promoName, data });
if (!promoName || !Array.isArray(data)) {
throw new Error("Invalid request body");
}
const db = new Database("databases/data/mobility.db");
db.prepare(
"INSERT OR IGNORE INTO promotions (name) VALUES (?)"
).run(promoName);
const promoIdRow = db
.prepare("SELECT id FROM promotions WHERE name = ?")
.get(promoName);
const promoId = promoIdRow.id;
console.log(`Promotion ID for "${promoName}":`, promoId);
const insertQuery = db.prepare(
"INSERT INTO students (firstName, lastName, email, promotionId) VALUES (?, ?, ?, ?)"
);
for (const student of data) {
console.log("Inserting student:", student);
insertQuery.run(student.Nom, student["Prénom"], student.Mail, promoId);
}
db.close();
console.log("All data inserted successfully");
return new Response("Data inserted successfully", { status: 201 });
} catch (error) {
console.error("Error inserting data:", error);
return new Response("Failed to insert data", { status: 500 });
}
},
};