Get employeesbyid

.gitignore

@@ -1 +1,2 @@
-node_modules
+.env
+node_modules

controllers/employees.js

@@ -0,0 +1,49 @@
+const mysql = require('mysql');
+const pool = require('../mysql/connection');
+const { handleSQLError } = require('../mysql/error');
+
+const getEmployees = (req, res) => {
+    let sql = "SELECT * FROM employees LIMIT 50";
+
+    pool.query(sql, (err, rows) => {
+        if (err) return handleSQLError(res, err);
+        return res.json("getting employees..." + rows);
+    })
+}
+
+const getEmployeesById = (req, res) => {
+    let sql = "SELECT * FROM employees WHERE emp_no = ?";
+    sql = mysql.format(sql, [req.params.emp_no]);
+
+    pool.query(sql, (err, rows) => {
+        if (err) return handleSQLError(res, err);
+        return res.json("getting employees..." + rows);
+    })
+}
+
+const getEmployeesByFirstName = (req, res) => { 
+    let sql = "SELECT * FROM employees WHERE first_name = ?";
+    sql = mysql.format(sql, [req.params.first_name]);
+
+    pool.query(sql, (err, rows) => {
+        if (err) return handleSQLError(res, err);
+        return res.json("getting employees..." + rows);
+    })
+}
+
+// const getSalariesById = (req, res) => { 
+//     let sql = "SELECT * FROM salaries WHERE emp_no = ?";
+//     sql = mysql.format(sql, [req.body.emp_no]);
+
+//     pool.query(sql, (err, rows) => {
+//         if (err) return handleSQLError(res, err);
+//         return res.json("getting employee salary data..." + rows);
+//     })
+// }
+
+module.exports = {
+    getEmployees,
+    getEmployeesById,
+    getEmployeesByFirstName,
+    // getSalariesById
+}

index.js

@@ -0,0 +1,18 @@
+const express = require('express');
+const bodyParser = require("body-parser");
+const employees = require('./routes/employees');
+require('dotenv').config()
+const port = process.env.PORT || 4001;
+const app = express();
+
+// app.get('/', (req, res) => {
+//     res.send('Welcome to our API');
+// })
+
+app.use(bodyParser.json());
+app.use('/', employees);
+
+
+app.listen(port, () => {
+    console.log(`web server is listening on port ${port}`);
+})

mysql/connection.js

@@ -0,0 +1,30 @@
+const mysql = require('mysql')
+require('dotenv').config()
+
+const employeeDatabase = {
+  host     : process.env.HOST,
+  user     : process.env.USER,
+  password : process.env.PASSWORD,
+  database : process.env.DATABASE,
+  multipleStatements: true //allows execution of multiple SQL statements
+}
+
+class Connection {
+  constructor() {
+    if (!this.pool) {
+      console.log('creating connection...')
+      this.pool = mysql.createPool({
+        connectionLimit: 100,
+        ...employeeDatabase
+      })
+
+      return this.pool
+    }
+
+    return this.pool
+  }
+}
+
+const instance = new Connection()
+
+module.exports = instance;

mysql/error.js

@@ -0,0 +1,6 @@
+const handleSQLError = (res, err) => {
+    console.log('SQL Error: ', err)
+    return res.status(500).send('something went wrong');
+  }
+
+  module.exports = { handleSQLError }