*sunglasses cool guy emoji*

controllers/departments.js

@@ -0,0 +1,30 @@
+const mysql = require('mysql');
+const pool = require('../mysql/connection');
+
+
+
+function getAllDepartments(req, res) {
+let sql = 'SELECT * FROM employees.departments';
+
+pool.query(sql, (err, rows) => {
+    if (err) {
+        return err + 'Something went wrong'
+    } return res.json(rows);
+}) 
+}
+
+function getEmployeeDepartment(req, res) {
+    let sql = 'SELECT dept_name FROM employees.departments WHERE dept_no = (SELECT dept_no FROM dept_emp where emp_no = ?)'
+
+    sql = mysql.format(sql, [req.params.id])
+
+    pool.query(sql, (err, rows) => {
+        if (err) {
+            return err + 'Something went wrong'
+        } return res.json(rows)
+
+    })
+
+}
+
+module.exports = {getAllDepartments, getEmployeeDepartment}

controllers/employees.js

@@ -0,0 +1,45 @@
+const mysql = require('mysql')
+const { handleSQLError } = require('../../311_wk4_day2_node_mysql/sql/error');
+const pool = require('../mysql/connection')
+
+
+function getEmployees(req, res) {
+    pool.query('select * from employees order by emp_no desc limit 50', (err, rows) => {
+        if (err) {
+            return 'error occured!'
+        } return res.json(rows);
+    })
+}
+
+function getEmployeeById(req, res) {
+    console.log(req.params);
+    let employeeID = req.params.id;
+    let sql = 'select * from employees where emp_no = ?'
+
+    sql = mysql.format(sql, [employeeID])
+
+    pool.query(sql, (err, rows) => {
+        if(err) {
+            return err + 'error occured!'
+        } return res.json(rows)
+    })
+
+
+}
+
+function getEmployeesByFirstName(req, res) {
+console.log(req.params)
+let firstName = req.params.firstname;
+let sql = 'select * from employees where first_name = ?'
+
+sql = mysql.format(sql, [firstName])
+
+pool.query(sql, (err, rows) => {
+    if(err) {
+        return err + 'error occured!'
+    } return res.json(rows)
+})
+}
+
+
+module.exports = {getEmployees, getEmployeeById, getEmployeesByFirstName};

controllers/salaries.js

@@ -0,0 +1,28 @@
+const mysql = require('mysql');
+const pool = require('../mysql/connection.js')
+
+
+function getUserIdSalary(req, res) {
+    let sql = 'SELECT salary, from_date, to_date from employees.salaries where emp_no = ?'
+
+    sql = mysql.format(sql, [req.params.id])
+
+    pool.query(sql, (err, rows) => {
+        if (err) {
+            return err + 'Looks like youve got yourself an oopsie there bud'
+        } return res.json(rows);
+    })
+}
+
+function getMaxSalary(req, res) {
+    let sql = 'SELECT s.salary, e.first_name, e.last_name FROM employees.salaries s JOIN employees.employees e ON s.emp_no = e.emp_no ORDER BY salary desc limit 1';
+
+    pool.query(sql, (err, rows) => {
+        if(err) {
+            return err + 'Ya done hecked up A-A-Ron'
+        } return res.json(rows)
+    })
+
+}
+
+module.exports = {getUserIdSalary, getMaxSalary};

index.js

@@ -0,0 +1,19 @@
+const express = require('express');
+const employeesRouter = require('./routes/employees.js')
+const departmentsRouter = require('./routes/departments.js')
+const salariesRouter = require('./routes/salaries.js')
+const app = express();
+app.use(express.json());
+
+const port = process.env.PORT || 4001
+
+app.use(employeesRouter)
+
+app.use(departmentsRouter)
+
+app.use(salariesRouter)
+
+app.listen(port, () => {
+    console.log('app is listening on:', port)
+})
+

mysql/connection.js

@@ -0,0 +1,23 @@
+const mysql = require('mysql');
+
+class Connection {
+    constructor() {
+        if (!this.pool) {
+            console.log('creating connection')
+            this.pool = mysql.createPool({
+                connectionLimit: 100,
+                host: '34.67.138.63',
+                user: 'root',
+                password: 'AB8675309Az',
+                database: 'employees'
+            })
+
+            return this.pool
+        }
+        return this.pool
+    }
+}
+
+const instance = new Connection()
+
+module.exports = instance;