Merge branch 'main' into ESLintConfig

Author: YugandharrPatil

index.js

@@ -0,0 +1,74 @@
+import fs from "node:fs/promises"
+import { existsSync } from "node:fs"
+import { createIfNot } from "./utils/fileUtils.mjs"
+import path from "node:path"
+async function writeSQL(statement, saveFileAs = "") {
+  try {
+    const destinationFile = process.argv[2] || saveFileAs
+    if (!destinationFile) {
+      throw new Error("Missing saveFileAs parameter")
+    }
+    createIfNot(path.resolve(`./sql/${destinationFile}`))
+    await fs.writeFile(`sql/${process.argv[2]}.sql`, statement)
+  } catch (err) {
+    console.log(err)
+  }
+}
+async function readCSV(csvFileName = "") {
+  try {
+    const fileAndTableName = process.argv[2] || csvFileName
+    if (!fileAndTableName) {
+      throw new Error("Missing csvFileName parameter")
+    }
+    if (!existsSync(path.resolve(`./csv/${fileAndTableName}.csv`))) {
+      console.log("file not found")
+      return
+    }
+    const data = await fs.readFile(`csv/${fileAndTableName}.csv`, {
+      encoding: "utf8",
+    })
+    const linesArray = data.split(/\r|\n/).filter(line => line)
+    const columnNames = linesArray.shift().split(",")
+    let beginSQLInsert = `INSERT INTO ${fileAndTableName} (`
+    columnNames.forEach(name => (beginSQLInsert += `${name}, `))
+    beginSQLInsert = beginSQLInsert.slice(0, -2) + ")\nVALUES\n"
+    let values = ""
+    linesArray.forEach(line => {
+      // Parses each line of CSV into field values array
+      const arr = line.split(/,(?=(?:(?:[^"]*"){2})*[^"]*$)/)
+      if (arr.length > columnNames.length) {
+        console.log(arr)
+        throw new Error("Too Many Values in row")
+      } else if (arr.length < columnNames.length) {
+        console.log(arr)
+        throw new Error("Too Few Values in row")
+      }
+      let valueLine = "\t("
+      arr.forEach(value => {
+        // Matches NULL values, Numbers,
+        // Strings accepted as numbers, and Booleans (0 or 1)
+        if (value === "NULL" || !isNaN(+value)) {
+          valueLine += `${value}, `
+        } else {
+          // If a string is wrapped in quotes, it doesn't need more
+          if (value.at(0) === '"') valueLine += `${value}, `
+          else {
+            // This wraps strings in quotes
+            // also wraps timestamps
+            valueLine += `"${value}", `
+          }
+        }
+      })
+      valueLine = valueLine.slice(0, -2) + "),\n"
+      values += valueLine
+    })
+    values = values.slice(0, -2) + ";"
+    const sqlStatement = beginSQLInsert + values
+    // Write File
+    writeSQL(sqlStatement)
+  } catch (err) {
+    console.log(err)
+  }
+}
+readCSV()
+console.log("Finished!")

src/index.ts

@@ -1,51 +1,47 @@
-import { promises as fs } from "fs";
-
+import { promises as fs ,existsSync} from "fs";
+import {createIfNot} from "./utils/fileUtils.js"
+import * as  path from "node:path"
 async function writeSQL(statement: string, saveFileAs = "") {
   try {
     const destinationFile = process.argv[2] || saveFileAs;
-
     if (!destinationFile) {
       throw new Error("Missing saveFileAs parameter");
     }
-
+    createIfNot(path.resolve(`./sql/${destinationFile}.sql`))
     await fs.writeFile(`sql/${process.argv[2]}.sql`, statement);
   } catch (err) {
     console.log(err);
   }
 }
-
 async function readCSV(csvFileName = "") {
   try {
     const fileAndTableName = process.argv[2] || csvFileName;
-
     if (!fileAndTableName) {
       throw new Error("Missing csvFileName parameter");
     }
-
+    if(!existsSync(path.resolve(`./csv/${fileAndTableName}.csv`))){
+      console.log("file not found")
+      return
+    }
     const data = await fs.readFile(`csv/${fileAndTableName}.csv`, {
       encoding: "utf8",
     });
-
     const linesArray = data.split(/\r|\n/).filter((line) => line);
     const columnNames = linesArray?.shift()?.split(",") || [];
-
     let beginSQLInsert = `INSERT INTO ${fileAndTableName} (`;
     columnNames.forEach((name) => (beginSQLInsert += `${name}, `));
     beginSQLInsert = beginSQLInsert.slice(0, -2) + ")\nVALUES\n";
-
     let values = "";
     linesArray.forEach((line) => {
       // Parses each line of CSV into field values array
       const arr = line.split(/,(?=(?:(?:[^"]*"){2})*[^"]*$)/);
-
       if (arr.length > columnNames.length) {
         console.log(arr);
         throw new Error("Too Many Values in row");
       } else if (arr.length < columnNames.length) {
         console.log(arr);
         throw new Error("Too Few Values in row");
       }
-
       let valueLine = "\t(";
       arr.forEach((value) => {
         // Matches NULL values, Numbers,
@@ -66,16 +62,12 @@ async function readCSV(csvFileName = "") {
       values += valueLine;
     });
     values = values.slice(0, -2) + ";";
-
     const sqlStatement = beginSQLInsert + values;
-
     // Write File
     writeSQL(sqlStatement);
   } catch (err) {
     console.log(err);
   }
 }
-
 readCSV();
-
 console.log("Finished!");

src/utils/fileUtils.ts

@@ -0,0 +1,6 @@
+import * as fs from "node:fs"
+export function createIfNot(dir:string) {
+  if (!fs.existsSync(dir)) {
+    fs.mkdirSync(dir, { recursive: true })
+  }
+}