const { MongoClient } = require('mongodb'); const uri = "mongodb+srv://$username:$password@$cluster0.mongodb.net/test?retryWrites=true&w=majority"; const client = new MongoClient(uri, { useNewUrlParser: true });
async function connect() { try { // Connect to MongoDB await client.connect(); console.log('Connected to MongoDB'); } catch (err) { console.log(err); } }
connect();
const express = require('express'); const app = express(); const port = 3000;
// Set up express routes app.get('/api/data', async (req, res) => { try { // Access MongoDB with sufficient privileges const result = await db.collection('data').find().toArray(); res.json(result); } catch (err) { console.log(err); res.status(500).json({ error: err.message }); } });
app.listen(port, () => console.log(Listening on port ${port}
));
// Defining data model in API const mongoose = require('mongoose'); const dataSchema = new mongoose.Schema({ name: { type: String, required: true }, age: { type: Number, required: true } });
const Data = mongoose.model('Data', dataSchema);
// Saving data to MongoDB const newData = new Data({ name: 'John Doe', age: 30 });
newData.save() .then(() => console.log('Data saved to MongoDB')) .catch((err) => console.log(err));
上一篇:API调用和JSON解码