if (process.env.NODE_ENV !== 'production') {
  require('dotenv').load();
}
var Connection = require('tedious').Connection;
var Request = require('tedious').Request;
var fs = require('fs');
var query = fs.readFileSync("query.sql", "utf8");
var port = 3000;
var config = {
  userName: process.env.USER_NAME,
  password: process.env.PASSWORD,
  server: process.env.SERVER,
  options:
     {
        database: process.env.DATABASE
        , encrypt: true
     }
}
var connection = new Connection(config);
const express = require('express')
const app = express()
app.get('/', getData)
connection.on('connect', function(err) {
  if (err) {
    throw err;
  }
  app.listen(port, () => console.log('App listening on port ' + port + '!'));
});
function getData(req, res, next) {
  request = new Request(query, function(err, rowCount, rows) {
                                          console.log(rowCount + ' row(s) returned');
                                      });
  var results = [];
  request.on('row', function(columns) {
      var obj = {}
      columns.forEach(function(column) {
        obj[column['metadata']['colName']] = column['value'];
      })
      results.push(obj);
  });
  request.on('doneProc', function(rowCount, more, returnStatus, rows) {
    res.json(results);
  });
  request.on('error', next);
  try {
    connection.execSql(request);
  } catch (e) {
    next(e);
  }
}