var express = require('express');
var app = express();
var mysql = require("mysql");
var con = mysql.createConnection({ 
  host: process.env.DB_HOST, // Use DB_HOST instead of MYSQL_HOST
  user: process.env.DB_USER, 
  password: process.env.DB_PASSWORD, 
  database: process.env.DB_NAME // Use DB_NAME instead of MYSQL_DATABASE
});

// mysql code
con.connect(function(err){
  if(err){
    console.log('Error connecting to db: ', err);
    return;
  }
  console.log('Connection to db established');
  con.query('CREATE TABLE IF NOT EXISTS visits (id INT NOT NULL PRIMARY KEY AUTO_INCREMENT, ts BIGINT)',function(err) {
    if(err) throw err;
  });
});

// Request handling
app.get('/', function (req, res) {
  con.query('INSERT INTO visits (ts) values (?)', Date.now(), function(err, dbRes) {
    if(err) throw err;
    res.send('Hello World! You are visitor number ' + dbRes.insertId + '\n');
  });
});

// server
var server = app.listen(3000, function () {
  var host = server.address().address;
  var port = server.address().port;

  console.log('Example app listening at http://%s:%s', host, port);
});