How to create RESTFUL Webservice using Node JS + Express JS + MySQL ?

Please follow this 15 Minute Step by Step Video Tutorial to Create the RESTful Webservice.

**Database Sample Data**
Roles :	Departments:

app.js - File Changes

var mysql = require('mysql');
var connection = require("express-myconnection");

// npm install to install the dependencies

// Create Sql Connection
app.use(connection(mysql, {
host: "localhost",
user: "root",
password: "root",
database: "test"
},'request'));

index.js - File Changes

/* Create Employee Service. */
router.post('/techgeek/v1/createEmployee', function(req, res, next) {
 try {
  var reqObj = req.body;
  console.log(reqObj);
  req.getConnection(function(err, conn) {
   if (err) {
    console.error('SQL Connection error: ', err);
    return next(err);
   } else {
    var insertSql = "INSERT INTO employee SET ?";
    var insertValues = {
     "Emp_Name": reqObj.empName,
     "Role_Id": reqObj.roleId,
     "Dept_Id": reqObj.deptId
    };
    var query = conn.query(insertSql, insertValues, function(err, result) {
     if (err) {
      console.error('SQL error: ', err);
      return next(err);
     }
     var Employee_Id = result.insertId;
     res.json({
      "Emp_id": Employee_Id
     });
    });
   }
  });
 } catch (ex) {
  console.error("Internal error:" + ex);
  return next(ex);
 }
}); /* Get Employee Service. */
router.get('/techgeek/v1/getEmployeeDetails', function(req, res, next) {
 try {
  var roleId = req.param('roleId');
  var deptId = req.param('deptId'); /*var query = url.parse(req.url,true).query; console.log(query); var roleId = query.roleId; var deptId = query.deptId;*/
  console.log(roleId);
  console.log(deptId);
  req.getConnection(function(err, conn) {
   if (err) {
    console.error('SQL Connection error: ', err);
    return next(err);
   } else {
    conn.query('select E.Emp_Name, Date_Format(E.Doj,"%d-%m-%Y") AS DOJ, D.Dept_Name, R.Role_Name from employee E, role R, department D where E.Role_Id = R.Role_Id and E.Dept_Id = D.Dept_Id and E.Role_Id = ? and E.Dept_Id = ? order by DOJ', [roleId, deptId], function(err, rows, fields) {
     if (err) {
      console.error('SQL error: ', err);
      return next(err);
     }
     var resEmp = [];
     for (var empIndex in rows) {
      var empObj = rows[empIndex];
      resEmp.push(empObj);
     }
     res.json(resEmp);
    });
   }
  });
 } catch (ex) {
  console.error("Internal error:" + ex);
  return next(ex);
 }
});

FIND COMPLETE CODE →

GITHUB : https://goo.gl/PxCRks

RELATED EPISODES :

Ep :01 – > Set up Node + Express Server in 10 Minutes for Beginners

https://www.youtube.com/watch?v=1c8kZX4zBec

Ep: 01 → Wamp Server - MySQL & phpMyAdmin

https://www.youtube.com/watch?v=P_tpOpXaUwI