如何使用MongoDB开发一个简单的智能家居系统

mkdir smart-home-system
cd smart-home-system
npm init -y
npm install express mongodb

const { MongoClient } = require('mongodb');

async function connect() {
    try {
        const client = await MongoClient.connect('mongodb://localhost:27017');
        const db = client.db('smart-home-system');
        console.log('Connected to the database');
        return db;
    } catch (error) {
        console.log('Failed to connect to the database');
        throw error;
    }
}

module.exports = { connect };

const express = require('express');
const { ObjectId } = require('mongodb');
const { connect } = require('../db');

const router = express.Router();

router.get('/', async (req, res) => {
    try {
        const db = await connect();
        const devices = await db.collection('devices').find().toArray();
        res.JSON(devices);
    } catch (error) {
        res.status(500).json({ error: error.message });
    }
});

router.post('/', async (req, res) => {
    try {
        const { name, type, status, user_id } = req.body;
        const db = await connect();
        const result = await db.collection('devices').insertOne({
            name,
            type,
            status,
            user_id: ObjectId(user_id),
        });
        res.json(result.ops[0]);
    } catch (error) {
        res.status(500).json({ error: error.message });
    }
});

module.exports = router;

const { connect } = require('../db');

async function getDevices() {
    try {
        const db = await connect();
        const devices = await db.collection('devices').find().toArray();
        return devices;
    } catch (error) {
        throw error;
    }
}

async function createDevice(device) {
    try {
        const db = await connect();
        const result = await db.collection('devices').insertOne(device);
        return result.ops[0];
    } catch (error) {
        throw error;
    }
}

module.exports = {
    getDevices,
    createDevice,
};

const express = require('express');
const devicesRouter = require('./routes/devices');

const app = express();

app.use(express.json());

app.use('/devices', devicesRouter);

app.listen(3000, () => {
    console.log('Server is running on port 3000');
});