Merge pull request #14 from Maanu07/enable-ts-support

Enabled ts support for the project

Author: gitdagray

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 .env
 .vscode
+dist/

index.js

@@ -1,20 +1,26 @@
 {
-	"name": "csv-to-sql-insert",
-	"version": "0.1.0",
-	"type": "module",
-	"repository": "https://github.com/gitdagray/csv-to-sql",
-	"description": "input a csv file, output a sql insert statement",
-	"main": "index.js",
-	"author": {
-		"name": "Dave Gray",
-		"email": "[email protected]",
-		"url": "https://www.davegray.codes/"
-	},
-	"license": "MIT",
+  "name": "csv-to-sql-insert",
+  "version": "0.1.0",
+  "type": "module",
+  "repository": "https://github.com/gitdagray/csv-to-sql",
+  "description": "input a csv file, output a sql insert statement",
+  "main": "index.js",
+  "scripts": {
+    "start": "npm run build && node dist/index.js",
+    "build": "tsc  --skipLibCheck"
+  },
+  "author": {
+    "name": "Dave Gray",
+    "email": "[email protected]",
+    "url": "https://www.davegray.codes/"
+  },
+  "license": "MIT",
 	"devDependencies": {
 		"husky": "^8.0.3",
 		"prettier": "3.1.1",
-		"pretty-quick": "^3.1.3"
+		"pretty-quick": "^3.1.3",
+		 "@types/node": "^20.10.5",
+    "typescript": "^5.3.3"
 	},
 	"husky": {
 		"hooks": {

package-lock.json

@@ -0,0 +1,81 @@
+import { promises as fs } from "fs";
+
+async function writeSQL(statement: string, saveFileAs = "") {
+  try {
+    const destinationFile = process.argv[2] || saveFileAs;
+
+    if (!destinationFile) {
+      throw new Error("Missing saveFileAs parameter");
+    }
+
+    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");
+    }
+
+    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!");

package.json

@@ -0,0 +1,12 @@
+{
+  "compilerOptions": {
+    "target": "es6",
+    "module": "ES2020",
+    "outDir": "./dist",
+    "rootDir": "./src",
+    "strict": true,
+    "noEmitOnError": true
+  },
+  "include": ["src/**/*.ts"],
+  "exclude": ["node_modules"]
+}