chore/14-importskript

backend/scripts/import.ts

@@ -1,5 +1,6 @@
 import { createReadStream } from "node:fs";
 import { parse } from "csv-parse";
+import { pool } from "../src/db.js";
 
 const WINES_FILE = "data/XWines_Test_100_wines.csv";
 
@@ -8,10 +9,38 @@ async function main() {
 
   let count = 0;
   for await (const row of parser) {
-    if (count === 0) console.log(row);
+    await pool.query(
+      `INSERT INTO countries (code, name) VALUES ($1, $2)
+       ON CONFLICT (code) DO NOTHING`,
+      [row.Code, row.Country]
+    );
+
+    await pool.query(
+      `INSERT INTO regions (id, name, country_code) VALUES ($1, $2, $3)
+       ON CONFLICT (id) DO NOTHING`,
+      [row.RegionID, row.RegionName, row.Code]
+    );
+
+    await pool.query(
+      `INSERT INTO wineries (id, name, website) VALUES ($1, $2, $3)
+       ON CONFLICT (id) DO NOTHING`,
+      [row.WineryID, row.WineryName, row.Website || null]
+    );
+
+    await pool.query(
+      `INSERT INTO wines
+         (id, name, type, elaborate, abv, body, acidity, winery_id, region_id, country_code)
+       VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
+       ON CONFLICT (id) DO NOTHING`,
+      [row.WineID, row.WineName, row.Type, row.Elaborate, row.ABV,
+       row.Body, row.Acidity, row.WineryID, row.RegionID, row.Code]
+    );
+
     count++;
   }
-  console.log(`Leste ${count} rader`);
+
+  console.log(`Importerte ${count} viner`);
+  await pool.end();
 }
 
 main();