Update the API with MySQL Version

Author: junerockwell

.gitignore

@@ -104,3 +104,4 @@ dist
 .tern-port
 .DS_Store
 API_MongoDB_Atlas/.env
+API_MySQL_AWS/.env

API_MSSQL_AZURE/package.json

@@ -4,6 +4,8 @@
   "description": "",
   "main": "server.js",
   "scripts": {
+    "watch:dev": "nodemon server.js",
+    "prod": "pm2 start pm2.config.js",
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "author": "June Rockwell",

API_MongoDB_Atlas/package.json

@@ -5,6 +5,7 @@
   "main": "server.js",
   "scripts": {
     "watch:dev": "nodemon server.js",
+    "prod": "pm2 start pm2.config.js",
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "author": "June Rockwell",

API_MongoDB_Atlas/routes/note.js

@@ -41,7 +41,7 @@ module.exports = server => {
         }
     });
 
-    server.get('/note/author/:id', async(req, res, next) => {
+    server.get('/notes/author/:id', async(req, res, next) => {
         try {
             const data = await Note.GetNotesByAuthorId(req.params.id);
             res.send(data.code, data.note);

API_MySQL_AWS/.env.sample

@@ -0,0 +1,9 @@
+ENV = 'development'
+API_PORT = 4000
+BASE_URL = 'http://localhost:4000',
+JWT_SECRET = 'api_jwt_secret'
+DB_HOST=localhost
+DB_USER=root
+DB_PASSWORD=root
+DB_PORT=3306
+DB_NAME=node_api_mysql

API_MySQL_AWS/MySQLData/MySQLData.js

@@ -0,0 +1,167 @@
+const db = require('./index');
+const errors = require('restify-errors');
+
+function CreateOneNote(data) {
+    return new Promise((resolve, reject) => {
+        const qry = "INSERT INTO notes SET ?";
+        db.pool.query(qry, data, (err, result) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+
+            if (result.affectedRows <= 0) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: 'Failed to create'
+                });
+            }
+
+            resolve({
+                code: 201,
+                message: '',
+                note: result
+            });
+        });
+    });
+}
+
+function GetOneNoteById(id) {
+    return new Promise((resolve, reject) => {
+        const qry = "SELECT * FROM notes WHERE id = ?";
+        db.pool.query(qry, id, (err, rows) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+
+            resolve({
+                code: 200,
+                message: '',
+                note: rows[0] || {}
+            });
+        });
+    });
+}
+
+function GetAll() {
+    return new Promise((resolve, reject) => {
+        const qry = `SELECT 
+                     notes.id as noteId, 
+                     notes.text, 
+                     author.id as authorId, 
+                     author.first_name as author_firstname
+                     FROM notes 
+                     RIGHT JOIN users as author 
+                     ON author.id = notes.authorId 
+                     WHERE notes.authorId IS NOT NULL 
+                     AND notes.id IS NOT NULL`;
+        db.pool.query(qry, {}, (err, rows) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+
+            resolve({
+                code: 200,
+                message: '',
+                note: rows
+            });
+        });
+    });
+}
+
+function GetNotesByAuthorId(id) {
+    return new Promise((resolve, reject) => {
+        const qry = `SELECT 
+                     notes.id as noteId, 
+                     notes.text, 
+                     author.id as authorId, 
+                     author.first_name as author_firstname
+                     FROM notes 
+                     RIGHT JOIN users as author 
+                     ON author.id = notes.authorId 
+                     WHERE notes.authorId = ?`;
+        db.pool.query(qry, id, (err, rows) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+
+            resolve({
+                code: 200,
+                message: '',
+                note: rows
+            });
+        });
+    });
+}
+
+function UpdateOneNote(id, newNote) {
+    return new Promise((resolve, reject) => {
+        const qry = `UPDATE notes SET text = ? WHERE id = ?`;
+        db.pool.query(qry, [newNote.text, id], (err, rows) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+            
+            if (rows.changedRows <= 0) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: 'Failed to update'
+                });
+            }
+
+            resolve({
+                code: 200,
+                message: ''
+            });
+        });
+    });
+}
+
+function DeleteOneNoteById(id) {
+    return new Promise((resolve, reject) => {
+        const qry = `DELETE FROM notes WHERE id = ?`;
+        db.pool.query(qry, id, (err, rows) => {
+            if (err) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: err
+                });
+            }
+            
+            if (rows.affectedRows <= 0) {
+                return reject({ 
+                    code: new errors.InternalServerError(),
+                    message: 'Failed to delete'
+                });
+            }
+        
+            resolve({
+                code: 200,
+                message: '',
+            });
+        });
+    });
+}
+
+module.exports = {
+    CreateOneNote,
+    GetOneNoteById,
+    GetAll,
+    GetNotesByAuthorId,
+    UpdateOneNote,
+    DeleteOneNoteById
+};