Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions .env
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
USER=dvizueta
HOST=database-1.cg5jx2izu82w.us-east-2.rds.amazonaws.com
DATABASE=test
PASSWORD=Ranger1985!
3 changes: 2 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
node_modules
node_modules
.env
71 changes: 41 additions & 30 deletions controllers/users.js
Original file line number Diff line number Diff line change
@@ -1,67 +1,78 @@
const mysql = require('mysql')
const pool = require('../sql/connection')
const { handleSQLError } = require('../sql/error')
const mysql = require("mysql");
const pool = require("../sql/connection");
const { handleSQLError } = require("../sql/error");

const getAllUsers = (req, res) => {
// SELECT ALL USERS
console.log("FIRE");
pool.query("SELECT * FROM users", (err, rows) => {
if (err) return handleSQLError(res, err)
if (err) return handleSQLError(res, err);
return res.json(rows);
})
}
});
};

const getUserById = (req, res) => {
console.log(req.params.id)
// SELECT USERS WHERE ID = <REQ PARAMS ID>
let sql = "QUERY GOES HERE"

let sql = "SELECT * FROM ?? WHERE ?? = ?";
// WHAT GOES IN THE BRACKETS
sql = mysql.format(sql, [])
const replacements = ["users", "id", req.params.id]
sql = mysql.format(sql, replacements);


pool.query(sql, (err, rows) => {
if (err) return handleSQLError(res, err)
if (err) return handleSQLError(res, err);
return res.json(rows);
})
}
});
};

const createUser = (req, res) => {
// INSERT INTO USERS FIRST AND LAST NAME
let sql = "QUERY GOES HERE"

console.log(`We're trying to add user ${req.body.first_name} ${req.body.last_name}.`)
// INSERT INTO USERS FIRST AND LAST NAME
let sql = "INSERT INTO users (first_name, last_name) VALUES (?, ?)";
// WHAT GOES IN THE BRACKETS
sql = mysql.format(sql, [])
const replacements = [req.body.first_name, req.body.last_name]
sql = mysql.format(sql, replacements);

pool.query(sql, (err, results) => {
if (err) return handleSQLError(res, err)
if (err) return handleSQLError(res, err);
return res.json({ newId: results.insertId });
})
}
});
};

const updateUserById = (req, res) => {
const body = req.body;
// UPDATE USERS AND SET FIRST AND LAST NAME WHERE ID = <REQ PARAMS ID>
let sql = ""
// ?? - this is anything coming from mysql
// ? - anything from express
let sql = `UPDATE ?? SET ? WHERE ?? = ?`;
// WHAT GOES IN THE BRACKETS
sql = mysql.format(sql, [])
sql = mysql.format(sql, ["users", body, "id", req.params.id]);

pool.query(sql, (err, results) => {
if (err) return handleSQLError(res, err)
return res.status(204).json();
})
}
if (err) return handleSQLError(res, err);
return res.json(results);
});
};

const deleteUserByFirstName = (req, res) => {
// DELETE FROM USERS WHERE FIRST NAME = <REQ PARAMS FIRST_NAME>
let sql = ""
let sql = "";
// WHAT GOES IN THE BRACKETS
sql = mysql.format(sql, [])
sql = mysql.format(sql, []);

pool.query(sql, (err, results) => {
if (err) return handleSQLError(res, err)
if (err) return handleSQLError(res, err);
return res.json({ message: `Deleted ${results.affectedRows} user(s)` });
})
}
});
};

module.exports = {
getAllUsers,
getUserById,
createUser,
updateUserById,
deleteUserByFirstName
}
deleteUserByFirstName,
};
Loading