var express = require('express');
var app = express();
var mysql = require('mysql');
var path = require('path');
var bodyParser = require('body-parser');

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

var connection = mysql.createConnection({
	host : 'localhost',
	user : 'root',
	password : '12345678',
	database : 'teste'
});

connection.connect(function(err){
  if(err) return console.log(err);
  console.log('Conectado com sucesso!');
})

app.get('/pessoas', function(req, res) {
	connection.query('select * from Pessoa', function(err, result){
		if(err){
			res.send('Erro');
		} else{
			res.send(result);
		}

	});
});

app.post('/cadastro', function(req, res){
	var jsondata = req.body;
	var values = [jsondata.nome, jsondata.idade, jsondata.cod];

	connection.query('INSERT INTO Pessoa (nome, idade, cod) VALUES (?,?,?)', values, function(err, result){
		if(err){
			res.send('Erro');
		} else{
			res.send('Pessoa cadastrada!');
		}
	});
});

app.delete('/remover', function(req, res){
	connection.query('DELETE FROM Pessoa WHERE cod = (?)', req.body.cod, function(err, result){
		if(err){
			res.send('Erro');
		} else {
			res.send('Pessoa deletada!');
		}
	});
});

app.patch('/alterar', function(req, res){
	var jsondata = req.body;
	var values = [jsondata.nome, jsondata.idade, jsondata.cod];

	connection.query('UPDATE Pessoa SET nome = ?, idade = ? WHERE cod = ? ', values, function(err, result){
		if(err){
			res.send('Erro');
		} else {
			res.send('Pessoa atualizada!');
		}
	});
});

var port = 8080;

app.listen(port);

console.log("Servidor HTTP RODANDO OK na porta "+port);