var express = require('express');
const mysql =require('mysql');
var bodyParser = require('body-parser');
const connections = mysql.createPool({
  connectionLimit : 100,
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'mydb'
});

var app = express ();



app.use(bodyParser.urlencoded({
	extended: false
}));



app.get("/",function(req,res){

connections.getConnection(function (err,connection){

 if (err) {
          res.json({"code" : 100, "status" : "Error in connection database"});
          return;
        }

    console.log('connected as id ' + connection.threadId);

    connection.query('SELECT * from customers',function(err,rows,field){
           connection.release();

           if(!err){
            console.log("Results are",rows);

           }
          });
         connection.on('error', function(err) {
              res.json({"code" : 100, "status" : "Error in connection database"});
              return;
        });
    });


});






app.post("/register",function(req,res){

console.log("Username",req.body.name);
console.log("Value",req.body.value);

    connections.getConnection(function (err,connection){

 				if (err) {
          				res.json({"code" : 100, "status" : "Error in connection database"});
          		return;
       	 }

    console.log('connected as id ' + connection.threadId);
    connection.query("INSERT INTO customers (name, address) VALUES ('"+req.body.name+"', '"+req.body.value+"')",function(err,rows,field){
     connection.release();

           if(!err){
           	let message =  "Successfully registered";
            res.send(message);

           }
          });
         connection.on('error', function(err) {
              res.json({"code" : 100, "status" : "Error in connection database"});
              return;
        });
    });

});

app.listen(3000);