使用 Nodejs 和 MongoDB 本机驱动程序构建快速灵活的 CRUD API

require('dotenv').config()
const dbconfig = require('../config/db.config');
const { mongoclient } = require('mongodb');

const client = new mongoclient(dbconfig.url);

let _db;
let connectpromise;

async function connecttodb() {
    if (!connectpromise) {
        connectpromise = new promise(async (resolve, reject) => {
            try {
                await client.connect();
                console.log('connected to the database ?', client.s.options.dbname);
                _db = client.db();
                resolve(_db);
            } catch (error) {
                console.error('error connecting to the database:', error);
                reject(error);
            }
        });
    }
    return connectpromise;
}

function getdb() {
    if (!_db) {
        throw new error('database not connected');
    }
    return _db;
}

function isdbconnected() {
    return boolean(_db);
}

module.exports = { connecttodb, getdb, isdbconnected };

const { objectid } = require('mongodb');
const db = require('../utils/db');

class appmodel {
    constructor($collection) {
        this.collection = null;

        (async () => {
            if (!db.isdbconnected()) {
                console.log('waiting for the database to connect...');
                await db.connecttodb();
            }
            this.collection = db.getdb().collection($collection);
            console.log('collection name:', $collection);
        })();
    }

    async find() {
        return await this.collection.find().toarray();
    }

    async findone(condition = {}) {
        const result = await this.collection.findone(condition);
        return result || 'no document found!';
    }

    async create(data) {
        data.createdat = new date();
        data.updatedat = new date();
        let result = await this.collection.insertone(data);
        return `${result.insertedid} inserted successfully`;
    }

    async update(id, data) {
        let condition = await this.collection.findone({ _id: new objectid(id) });
        if (condition) {
            const result = await this.collection.updateone({ _id: new objectid(id) }, { $set: { ...data, updatedat: new date() } });
            return `${result.modifiedcount > 0} updated successfully!`;
        } else {
            return `no document found with ${id}`;
        }
    }

    async deleteone(id) {
        const condition = await this.collection.findone({ _id: new objectid(id) });
        if (condition) {
            const result = await this.collection.deleteone({ _id: new objectid(id) });
            return `${result.deletedcount > 0} deleted successfully!`;
        } else {
            return `no document found with ${id}`;
        }
    }
}

module.exports = appmodel;

const express = require('express');
const router = express.router();

const users = require('../controllers/usercontroller');

router.get("/users", users.findall);
router.post("/users", users.create);
router.put("/users", users.update);
router.get("/users/:id", users.findone);
router.delete("/users/:id", users.deleteone);

module.exports = router;

const { objectid } = require('mongodb');
const model = require('../models/model');

const model = new model('users');

let usercontroller = {
    async findall(req, res) {
        model.find()
            .then(data => res.send(data))
            .catch(err => res.status(500).send({ message: err.message }));
    },
    async findone(req, res) {
        let condition = { _id: new objectid(req.params.id) };
        model.findone(condition)
            .then(data => res.send(data))
            .catch(err => res.status(500).send({ message: err.message }));
    },
    create(req, res) {
        let data = req.body;
        model.create(data)
            .then(data => res.send(data))
            .catch(error => res.status(500).send({ message: error.message }));
    },
    update(req, res) {
        let id = req.body._id;
        let data = req.body;
        model.update(id, data)
            .then(data => res.send(data))
            .catch(error => res.status(500).send({ message: error.message }));
    },
    deleteone(req, res) {
        let id = new objectid(req.params.id);
        model.deleteone(id)
            .then(data => res.send(data))
            .catch(error => res.status(500).send({ message: error.message }));
    }
}

module.exports = usercontroller;

module.exports = {
    url: process.env.DB_CONFIG,
};