dbconnect.js

dbconnect.js

var mysql = require('mysql');
var fs = require('fs');

var properties = require('./db-properties.json');
var env = require('./env.json');
var connection =  mysql.createConnection(properties);

 var filename = env.query_result_filename;
 var surveyIds = [];
  connection.query("use database");
  var strQuery = env.query;
  connection.query( strQuery, function(err, rows){
    if(err) {
      throw err;
    }else {
      console.log( rows );

      fs.unlink(filename);
      for (var i = 0; i < rows.length; i++) {
        var id = rows[i].id;
        var title = rows[i].title;
        console.log("id: " + id + ", title: " + title);
          
        fs.appendFile(filename, id+'\n', function(err) {
          if (err) {
            console.log(err);
          } else {
            console.log(id + "(" + title + ") saved...");
          }
      });
    }
  }
  });

connection.end(function(err){
// Do something after the connection is gracefully terminated.
 connection.destroy();

});