Restify

var restify = require('restify');
var mysql = require('mysql');
connection = mysql.createConnection({
               host : 'localhost',
               user : 'nuestroUsuarioDeMySQL',
               password : 'nuestraContraseñaDeMySQL',
               database: 'PruebasDB'
         });

var ip_addr = '127.0.0.1';
var port    =  '1234';

var server = restify.createServer({
    name : "usuarios"
});

server.use(restify.queryParser());
server.use(restify.bodyParser());
server.use(restify.CORS());
server.listen(port ,ip_addr, function(){
    console.log('%s listening at %s ', server.name , server.url);
});

var PATH = '/usuarios'
server.get({path : PATH , version : '0.0.1'} , findAllUsers);
server.get({path : PATH +'/:userId' , version : '0.0.1'} , findUser);
server.post({path : PATH , version: '0.0.1'} , postNewUser);
server.del({path : PATH +'/:userId' , version: '0.0.1'} , deleteUser);

function findAllUsers(req, res, next){
  connection.query('SELECT * FROM Usuarios', function (error, results){
      if(error) throw error;
      //console.log(results);
      res.send(200, results);
      return next();
  });
}


function findUser(req, res, next){
    connection.query('SELECT * FROM Usuarios WHERE ID ='+req.params.userId, function (error, results){
       if(error) throw error;
       //console.log(results);
       res.send(200, results);
       return next();
    });
}


function postNewUser(req , res , next){
    var user = {};
    user.Nombre = req.params.Nombre;
    user.Apellido = req.params.Apellido;
    user.Correo = req.params.Correo;

    connection.query('INSERT INTO Usuarios (Nombre, Apellido, Correo) VALUES (\''
        +user.Nombre+'\', \''
        +user.Apellido+'\', \''
        +user.Correo+'\', \')'
        , function (error, success){
            if(error) throw error;
            //console.log(success);
            res.send(200, success.insertId);
        }
    );
}


function deleteUser(req , res , next){

    connection.query('DELETE FROM Usuarios WHERE ID = '+req.params.userId, function (error, success){
        if(error) throw error;
        res.send(200, 'Eliminado con exito');
    });
}