Kaitland hackathon

.gitignore

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

controllers/employees.js

@@ -0,0 +1,62 @@
+const res = require("express/lib/response")
+const mysql = require("mysql")
+const pool = require("../mysql/connection")
+
+
+const getEmployees = (req, res) => {  
+  pool.query("SELECT * FROM users", (err, rows) => {
+     res.json(rows);
+  })
+}
+
+const getEmployeesById = (req, res) => {
+  let id = req.params.id;
+  let sql = "SELECT * FROM ?? WHERE ?? = ?";
+  sql = mysql.format(sql, ["users", "id", id]);
+     res.json(rows)
+}
+
+const getEmployeesByFirstName = (req, res) => {
+  let firstName = req.params.first_name
+  let sql = `SELECT * FROM users WHERE first_name = "${firstName}"`
+  pool.query(sql, (err, rows) => {
+    return res.json(rows)
+  })
+}
+
+const createEmployee = (req, res) => {
+  console.log(req.body);
+  const { first_name, last_name } = req.body;
+  let sql = `INSERT INTO ?? VALUES (null, ?, ?)`;
+
+  sql = mysql.format(sql, ["users", first_name, last_name]);
+
+  pool.query(sql, (err, rows) => {
+    return res.json(rows);
+  })
+}
+
+const updateEmployee = (req, res) => {
+  const { id } = req.params;
+  const { body } = req;
+  let sql = "UPDATE ?? SET ? WHERE ?? = ?";
+  sql = mysql.format(sql, ["users", body, "id", id]);
+
+  pool.query(sql, (err, results) => {
+    return res.status(204).json();
+  })
+}
+
+const deleteEmployeeById = (req, res) => {
+  const { id } = req.params;
+  let sql = "DELETE FROM ?? WHERE ?? = ?;";
+  sql = mysql.format(sql, ["users", "id", id])
+
+  pool.query(sql, (err, results) => {
+    console.log(err)
+    console.log(results)
+    return res.json({ message: `Deleted ${results.affectedRows} user(s)` });
+  })
+}
+
+module.exports = {getEmployees, getEmployeesById, getEmployeesByFirstName, createEmployee, updateEmployee, deleteEmployeeById}

controllers/employeesContact.js

@@ -0,0 +1,61 @@
+const mysql = require("mysql");
+const pool = require("../mysql/connection");
+
+const getContact = (req, res) => {
+  pool.query("SELECT * FROM usersContact", (err, rows) => {
+    res.json(rows);
+  });
+};
+
+const getContactById = (req, res) => {
+  let id = req.params.id;
+  let sql = "SELECT * FROM ?? WHERE ?? = ?";
+  sql = mysql.format(sql, ["usersContact", "id", id]);
+  pool.query(sql, (err, rows) => {
+    res.json(rows);
+  })
+};
+
+const postContact = (req, res) => {
+  console.log(req.body)
+  const {user_id, phone1, phone2, email} = req.body
+  let sql = `INSERT INTO usersContact
+	(user_id, phone1, phone2, email)
+  VALUES 
+  (?, ?, ?, ?);`;
+  sql = mysql.format(sql, [user_id, phone1, phone2, email]);
+  pool.query(sql, (err, results) => {
+    return res.json(results);
+  });
+};
+const putContact = (req, res) => {
+  console.log(req.body)
+  let id = req.params.id;
+  const {phone1, phone2, email} = req.body
+  let sql = `UPDATE usersContact 
+  SET phone1 = ? , phone2 = ?, email = ?
+  WHERE user_id = ${id}`;
+  sql = mysql.format(sql, [phone1, phone2, email]);
+  pool.query(sql, (err, results) => {
+    return res.json(results);
+  });
+}
+
+const deleteContact = (req, res) => {
+  console.log(req.body)
+  // Get the Id from the path parameters
+  let id = req.params.id;
+  // DON'T FORGET THE POOL.QUERY!
+  pool.query(`DELETE FROM usersContact
+  WHERE user_id = ${id}`, (err, results) => {
+    return res.json(results);
+  })
+}
+
+module.exports = {
+  getContact,
+  getContactById,
+  postContact,
+  putContact,
+  deleteContact
+};

index.js

@@ -0,0 +1,19 @@
+const express = require('express');
+const app = express();
+const employees = require('./routes/employee');
+const contact = require("./routes/employeesContact")
+
+const port = process.env.PORT || 4001;
+
+app.use(express.json())
+app.use( employees)
+app.use( contact)
+
+app.get('/', (req, res) => {
+    res.send('Welcome to our API!')
+  })
+
+  app.listen(port, () => {
+    console.log(`Web server is listening on port ${port}!`)
+   })
+

mysql/connection.js

@@ -0,0 +1,29 @@
+const mysql = require("mysql");
+
+require("dotenv").config();
+
+const { DB_HOST, DB_USER, DB_PASSWORD, DB_DATABASE, DB_PORT } = process.env;
+
+class Connection {
+  constructor() {
+    if (!this.pool) {
+      console.log("creating connection");
+      this.pool = mysql.createPool({
+        connectionLimit: 100,
+        host: DB_HOST,
+        user: DB_USER,
+        password: DB_PASSWORD,
+        database: DB_DATABASE,
+        port: DB_PORT,
+      });
+
+      return this.pool;
+    }
+
+    return this.pool;
+  }
+}
+
+const connection = new Connection();
+
+module.exports = connection;