// Step 1: Import required modules
const express = require('express');
const bodyParser = require('body-parser');
const mongoose = require('mongoose');
// Step 2: Create an Express application
const app = express();
// Step 3: Set up middleware to parse incoming JSON data
app.use(bodyParser.json());
// Step 4: Connect to MongoDB database
mongoose.connect('mongodb://localhost:27017/mydatabase', { useNewUrlParser: true, useUnifiedTopology: true });
// Step 5: Define a Mongoose schema
const itemSchema = new mongoose.Schema({
name: String,
description: String,
});
// Step 6: Create a Mongoose model based on the schema
const Item = mongoose.model('Item', itemSchema);
// Step 7: Create route to handle INSERT operation (Create)
app.post('/items', async (req, res) => {
try {
const newItem = new Item({
name: req.body.name,
description: req.body.description,
});
const savedItem = await newItem.save();
res.json(savedItem);
} catch (error) {
res.status(400).json({ message: error.message });
}
});
// Step 8: Create route to handle SELECT operation (Read)
app.get('/items', async (req, res) => {
try {
const items = await Item.find();
res.json(items);
} catch (error) {
res.status(500).json({ message: error.message });
}
});
// Step 9: Create route to handle UPDATE operation (Update)
app.patch('/items/:id', async (req, res) => {
try {
const updatedItem = await Item.updateOne(
{ _id: req.params.id },
{
$set: {
name: req.body.name,
description: req.body.description,
},
}
);
res.json(updatedItem);
} catch (error) {
res.status(400).json({ message: error.message });
}
});
// Step 10: Create route to handle DELETE operation (Delete)
app.delete('/items/:id', async (req, res) => {
try {
const deletedItem = await Item.deleteOne({ _id: req.params.id });
res.json(deletedItem);
} catch (error) {
res.status(500).json({ message: error.message });
}
});
// Step 11: Set up the server to listen on a specific port
const port = 3000;
app.listen(port, () => {
console.log(`Server is running on port ${port}`);
});