tNwCY2M7

1CREATE TABLE IF NOT EXISTS `employee` (
2`id` int(11) NOT NULL COMMENT 'primary key',
3  `employee_name` varchar(255) NOT NULL COMMENT 'employee name',
4  `employee_salary` double NOT NULL COMMENT 'employee salary',
5  `employee_age` int(11) NOT NULL COMMENT 'employee age'
6);
7	
8npm install --save mysql express body-parser
9	
10var http = require("http");
11var express = require('express');
12var app = express();
13var mysql      = require('mysql');
14var bodyParser = require('body-parser');
15
16//start mysql connection
17var connection = mysql.createConnection({
18  host     : 'localhost', //mysql database host name
19  user     : 'root', //mysql database user name
20  password : '', //mysql database password
21  database : 'dummy_db' //mysql database name
22});
23
24connection.connect(function(err) {
25  if (err) throw err
26  console.log('You are now connected...')
27})
28//end mysql connection
29
30//start body-parser configuration
31app.use( bodyParser.json() );       // to support JSON-encoded bodies
32app.use(bodyParser.urlencoded({     // to support URL-encoded bodies
33  extended: true
34}));
35//end body-parser configuration
36
37//create app server
38var server = app.listen(3000,  "127.0.0.1", function () {
39
40  var host = server.address().address
41  var port = server.address().port
42
43  console.log("Example app listening at http://%s:%s", host, port)
44
45});
46
47//rest api to get all results
48app.get('/employees', function (req, res) {
49   connection.query('select * from employee', function (error, results, fields) {
50      if (error) throw error;
51      res.end(JSON.stringify(results));
52    });
53});
54
55//rest api to get a single employee data
56app.get('/employees/:id', function (req, res) {
57   console.log(req);
58   connection.query('select * from employee where id=?', [req.params.id], function (error, results, fields) {
59      if (error) throw error;
60      res.end(JSON.stringify(results));
61    });
62});
63
64//rest api to create a new record into mysql database
65app.post('/employees', function (req, res) {
66   var postData  = req.body;
67   connection.query('INSERT INTO employee SET ?', postData, function (error, results, fields) {
68      if (error) throw error;
69      res.end(JSON.stringify(results));
70    });
71});
72
73//rest api to update record into mysql database
74app.put('/employees', function (req, res) {
75   connection.query('UPDATE `employee` SET `employee_name`=?,`employee_salary`=?,`employee_age`=? where `id`=?', [req.body.employee_name,req.body.employee_salary, req.body.employee_age, req.body.id], function (error, results, fields) {
76      if (error) throw error;
77      res.end(JSON.stringify(results));
78    });
79});
80
81//rest api to delete record from mysql database
82app.delete('/employees', function (req, res) {
83   console.log(req.body);
84   connection.query('DELETE FROM `employee` WHERE `id`=?', [req.body.id], function (error, results, fields) {
85      if (error) throw error;
86      res.end('Record has been deleted!');
87    });
88});
89	
90node app.js