Node.js导入MongoDB具体操作步骤

npm install mongodb

const { MongoClient } = require('mongodb');
const uri = 'mongodb://localhost:27017';
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });
async function connect() {
    try {
        await client.connect();
        console.log('Connected to MongoDB');
    } catch (error) {
        console.error('Error connecting to MongoDB', error);
    }
}
connect();

async function connect() {
    try {
        await client.connect();
        console.log('Connected to MongoDB');
        const database = client.db('testdb');
        const collection = database.collection('testcollection');
        // 在这里进行CRUD操作
    } catch (error) {
        console.error('Error connecting to MongoDB', error);
    }
}
connect();
​

async function insertDocument() {
    const database = client.db('testdb');
    const collection = database.collection('testcollection');
    const doc = { name: 'John Doe', age: 30, address: '123 Main St' };
    const result = await collection.insertOne(doc);
    console.log(`New document inserted with _id: ${result.insertedId}`);
}
insertDocument();
​

async function findDocuments() {
    const database = client.db('testdb');
    const collection = database.collection('testcollection');
    const query = { name: 'John Doe' };
    const document = await collection.findOne(query);
    console.log('Found document:', document);
    const cursor = collection.find({});
    const results = await cursor.toArray();
    console.log('Found documents:', results);
}
findDocuments();

async function updateDocument() {
    const database = client.db('testdb');
    const collection = database.collection('testcollection');
    const filter = { name: 'John Doe' };
    const updateDoc = { $set: { age: 31 } };
    const result = await collection.updateOne(filter, updateDoc);
    console.log(`Matched ${result.matchedCount} documents and modified ${result.modifiedCount} documents`);
}
updateDocument();

async function deleteDocument() {
    const database = client.db('testdb');
    const collection = database.collection('testcollection');
    const query = { name: 'John Doe' };
    const result = await collection.deleteOne(query);
    console.log(`Deleted ${result.deletedCount} documents`);
}
deleteDocument();