Skip to content

Instantly share code, notes, and snippets.

@riccardopirani
Last active July 12, 2018 14:42
Show Gist options
  • Save riccardopirani/120f0cb43fb6b74349c26932482d60c1 to your computer and use it in GitHub Desktop.
Save riccardopirani/120f0cb43fb6b74349c26932482d60c1 to your computer and use it in GitHub Desktop.
Multiple read files node.js and insert into mussel
//file .txt
2;44.8326;11.32
3;44.805;11.3386
//First Function
fs.readFile(tempfilename, function (err, data) {
if (err) {
ManageError.SendError("error: " + err);
} else {
var array = data.toString().split("\n");
i=0;
for (i = 0; i < array.length; ++i) {
if (i in array) {
var campi = array[i].split(';');
console.log(array[i]);
if (campi[0] != "") {
time(campi[0], campi[1], campi[2], "Ingresso");
}
}
}
}
}
});
//second function
async function time(IdUtente, Longitudine, Latitudine, Stato) {
console.log("time tracking");
var ret = "true";
await sql.connect(DbConfig.config);
try {
var request = new sql.Request();
request.input('IdUtente', sql.Int, IdUtente);
request.input('Longitudine', sql.Money, Longitudine);
request.input('Latitudine', sql.Money, Latitudine);
request.input('Stato', sql.VarChar, Stato);
var recordset = await request.query('Insert into time(IdUtente,Longitudine,Latitudine,Stato) values(@IdUtente,@Longitudine,@Latitudine,@Stato)');
} catch (err) {
ret = "Errore";
console.log("Errore: ", err);
ManageError.SendError("error-> "+ err);
} finally {
await sql.close();
}
console.log("Ret vale: " + ret);
return ret;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment