Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
85 changes: 80 additions & 5 deletions index.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
import fs from "node:fs/promises";
import { createInterface } from 'node:readline';

async function writeSQL(statement, saveFileAs = "") {


async function writeSQL (statement, saveFileAs = "") {
try {
const destinationFile = process.argv[2] || saveFileAs;

Expand All @@ -14,7 +17,80 @@ async function writeSQL(statement, saveFileAs = "") {
}
}

async function readCSV(csvFileName = "") {
function previewSQL (fileData) {
const rl = createInterface({
input: process.stdin,
output: process.stdout
});


rl.question(`Here's a preview of your SQL code:\n\n${fileData}\n\nDo you want to save it? (Yes/No) `, (reply) => {

// Valid options
const options = ["y", "yes", "n", "no"];

let cleanReply = reply.trim().toLowerCase();

if (options.includes(cleanReply)) {
// Save or exit
if (cleanReply[0] == 'y') {
// Save
writeSQL(fileData);
console.log("SQL code successfully saved!");
} else {
console.log("SQL code not saved. Operation cancelled.");
}

// Close readline interface
rl.close();
} else {


// User gave an invalid response, provide a chance to correct
rl.setPrompt(`${reply.trim()} is an invalid response, do you want to save the file? (Yes | Y OR No | N) `);

rl.prompt();

// Set a limit on attempts
let maxAttempts = 5;


// Get user input every time they hit enter!
rl.on("line", (userInput) => {

if (maxAttempts > 0) {
let cleanReply = userInput.trim().toLowerCase();

if (options.includes(cleanReply)) {
// Save or exit
if (cleanReply[0] == 'y') {
// Save
writeSQL(fileData);
console.log("SQL code successfully saved!");
} else {
console.log("SQL code not saved. Operation cancelled.");
}
// Close readline interface
rl.close();

} else {
rl.setPrompt(`${userInput.trim()} is an invalid response, do you want to save the file? (Yes | Y OR No | N) `);
rl.prompt();
}
} else {
// Max attempts reached
console.log("Maximum attempts exceeded. Operation cancelled.");
rl.close();
}
// Decrement attempts
maxAttempts--;

});
}
});
}

async function readCSV (csvFileName = "") {
try {
const fileAndTableName = process.argv[2] || csvFileName;

Expand Down Expand Up @@ -67,13 +143,12 @@ async function readCSV(csvFileName = "") {

const sqlStatement = beginSQLInsert + values;

// Write File
writeSQL(sqlStatement);
// Preview and save
previewSQL(sqlStatement);
} catch (err) {
console.log(err);
}
}

readCSV();

console.log("Finished!");