Haidar Mongodb Crud (native driver)

README.md

@@ -1,2 +1,16 @@
-# mongodb-crud
-CRUD with MongoDB
+# mongoose-crud
+CRUD with Mongoose ODM
+
+## How To Use
+
+```
+npm install
+//install all depedencies
+npm start
+// node app.js
+npm run dev
+//nodemon app.js
+node seeds/books.js
+// run books seeder
+
+```

app.js

@@ -0,0 +1,15 @@
+const express = require('express');
+const app = express();
+const bodyParser = require('body-parser');
+const books = require('./routes/books');
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({extended: true}));
+
+app.use('/books',books);
+
+const port = process.env.PORT || 3000;
+
+app.listen(port,() => {
+  console.log(`App listening on port ${port}`);
+});

controllers/BookController.js

@@ -0,0 +1,58 @@
+const books = require('../models/books');
+
+module.exports = {
+  index : (req,res) => {
+    books.findAll().then((books) => {
+      res.status(200).json({
+        message: 'Read All Books',
+        data: books
+      });
+    }).catch((err) => {
+      console.log(err);
+      res.status(500).json({
+        message: 'Something Went Wrong'
+      });
+    });
+  },
+  create: (req,res) => {
+    books.create(req.body).then((book) => {
+      res.status(200).json({
+        message: 'Success Create New Book',
+        data: book
+      });
+    }).catch((err) => {
+      console.log(err);
+      res.status(500).json({
+        message: 'Something Went Wrong'
+      });
+    });
+  },
+  destroy: (req,res) => {
+    const id = req.params.id;
+    books.destroy(id).then((book) => {
+      res.status(200).json({
+        message: 'Success Delete a Book',
+        data: book
+      });
+    }).catch((err) => {
+      console.log(err);
+      res.status(500).json({
+        message: 'Something Went Wrong'
+      });
+    });
+  },
+  update: (req,res) => {
+    const id = req.params.id;
+    books.update(id,req.body).then((book) => {
+      res.status(200).json({
+        message: 'Success Update a Book',
+        data: book
+      });
+    }).catch((err) => {
+      console.log(err);
+      res.status(500).json({
+        message: 'Something Went Wrong'
+      });
+    });
+  }
+};

models/books.js

@@ -0,0 +1,98 @@
+const MongoClient = require('mongodb').MongoClient;
+const url = 'mongodb://localhost:27017';
+const dbName = 'library';
+const ObjectId = require('mongodb').ObjectID;
+let client;
+
+module.exports = {
+  findAll :  () => {
+    return new Promise(function(resolve, reject) {
+      (async function() {
+        try {
+          client = await MongoClient.connect(url);
+          const db = client.db(dbName);
+          const docs = await db.collection('books').find({}).toArray();
+          resolve(docs) ;
+
+        } catch (err) {
+          console.log(err.stack);
+          reject(err);
+        }
+        if (client) {
+          client.close();
+        }
+      })();
+    });
+  },
+  create: (input) => {
+    return new Promise(function(resolve, reject) {
+      (async function() {
+        try {
+          client = await MongoClient.connect(url);
+          const db = client.db(dbName);
+          const insert = await db.collection('books').insertOne(input);
+          const docs = await db.collection('books').find(input).toArray();
+          resolve(docs) ;
+
+        } catch (err) {
+          console.log(err.stack);
+          reject(err);
+        }
+        if (client) {
+          client.close();
+        }
+      })();
+    });
+  },
+  destroy: (id) => {
+    return new Promise(function(resolve, reject) {
+      (async function() {
+        try {
+          client = await MongoClient.connect(url);
+          const db = client.db(dbName);
+          const docs = await db.collection('books').find({
+            _id: ObjectId(id)
+          }).toArray();
+          const destroy = await db.collection('books').remove({
+            _id: ObjectId(id)
+          });
+          resolve(docs) ;
+
+        } catch (err) {
+          console.log(err.stack);
+          reject(err);
+        }
+        if (client) {
+          client.close();
+        }
+      })();
+    });
+  },
+  update: (id,input) => {
+    return new Promise(function(resolve, reject) {
+      (async function() {
+        try {
+          client = await MongoClient.connect(url);
+          const db = client.db(dbName);
+          const update = await db.collection('books').findOneAndUpdate({
+            _id: ObjectId(id)
+          },
+          { $set : input},
+          {
+             returnOriginal: false,
+             sort: [['_id',1]],
+             upsert: true
+           }
+          );
+          resolve(update.value);
+        } catch (err) {
+          console.log(err.stack);
+          reject(err);
+        }
+        if (client) {
+          client.close();
+        }
+      })();
+    });
+  }
+};