dan/sql2csv
1
0
Fork 0
mirror of https://github.com/danbulant/sql2csv synced 2026-06-19 22:41:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix files, wrapper now working

Browse source
This commit is contained in:
danbulant 2019-09-28 18:06:33 +02:00
parent 7adf0af66a
commit fd91d397fa
2 changed files with 13 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
index.js
View file

@ -100,21 +100,27 @@ con.connect(function(err) {
process.exit(1); process.exit(1);
} }
log("\x1b[32mMySQL Connected!"); log("\x1b[32mMySQL Connected!");
s2c.setConnection(con);
fs.readdirSync('./input/').forEach(file => { fs.readdirSync('./input/').forEach(file => {
var fileName = file;
file = "./input/" + file; file = "./input/" + file;
if(fs.statSync(file).isDirectory()) return;//skip directories if(fs.statSync(file).isDirectory()) return;//skip directories
var query = fs.readFileSync(file); var query = fs.readFileSync(file);
log("Running " + query + " from file " + file); log("Running " + query + " from file " + file);
s2c.query(query) s2c.query(query + '')
.then(result => { .then(result => {
console.log(result.csv); var loc = "/output/" + fileName;
if(loc.lastIndexOf(".") != -1){
loc = loc.substr(0, loc.lastIndexOf("."));
}
loc = "." + loc;//fix for empty location
loc += ".csv";
fs.writeFile(loc, result.csv, { flag: "w"}, (err)=>{if(err)error(err)});
log(`Task from file ${file} done in ` + Math.round(result.end - result.start) + "ms"); log(`Task from file ${file} done in ` + Math.round(result.end - result.start) + "ms");
con.end();
}) })
.catch(err => {error(err); process.exit(0)}) .catch(err => {error(err); process.exit(0)})
}); });
}); });
s2c.setConnection(con);

3
sql2csv.js
View file

@ -56,9 +56,8 @@ class sql2csv {
query(sql){ query(sql){
var self = this; var self = this;
var startDate = performance.timeOrigin + performance.now(); var startDate = performance.timeOrigin + performance.now();
this.log(sql);
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
this.conn.query(sql, function (err, result) { self.conn.query(sql, function (err, result) {
if (err){reject(err); return } if (err){reject(err); return }
if(result == undefined){reject("undefined result"); return; } if(result == undefined){reject("undefined result"); return; }
var csv = ""; var csv = "";