Node.js中操作MongoDB的CRUD操作指南

更新時(shí)間：2024年01月14日 08:31:50 作者：慕仲卿

在Node.js中操作MongoDB常見的庫有mongodb原生驅(qū)動(dòng)和mongoose等,本文將使用mongodb官方驅(qū)動(dòng)包來進(jìn)行示例,在開始之前,請確保已經(jīng)安裝了MongoDB數(shù)據(jù)庫并且在本地啟動(dòng)了MongoDB服務(wù),需要的朋友可以參考下

首先，需要安裝mongodb驅(qū)動(dòng)：

npm install mongodb

接著，可以創(chuàng)建一個(gè)連接到MongoDB的客戶端：

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

const url = 'mongodb://localhost:27017';  // MongoDB服務(wù)地址
const dbName = 'mydatabase';  // 數(shù)據(jù)庫名稱
const client = new MongoClient(url);

async function main() {
    await client.connect();
    console.log('Connected successfully to server');
    const db = client.db(dbName);
    
    // 等待在這里執(zhí)行CRUD操作

    client.close();
}

main().catch(console.error);

基礎(chǔ)版

1. 創(chuàng)建(Create)

插入單條數(shù)據(jù)

async function createDocument(collectionName, doc) {
    const collection = db.collection(collectionName);
    const result = await collection.insertOne(doc);
    console.log(result);
}

// 使用示例
createDocument('users', { name: 'Tom', age: 25 });

插入多條數(shù)據(jù)

async function createMultipleDocuments(collectionName, docs) {
    const collection = db.collection(collectionName);
    const result = await collection.insertMany(docs);
    console.log(result);
}

// 使用示例
createMultipleDocuments('users', [
    { name: 'Alice', age: 23 },
    { name: 'Bob', age: 27 }
]);

2. 讀取(Read)

查詢單條數(shù)據(jù)

async function findOneDocument(collectionName, query) {
    const collection = db.collection(collectionName);
    const doc = await collection.findOne(query);
    console.log(doc);
}

// 使用示例
findOneDocument('users', { name: 'Tom' });

查詢多條數(shù)據(jù)

async function findMultipleDocuments(collectionName, query) {
    const collection = db.collection(collectionName);
    const docs = await collection.find(query).toArray();
    console.log(docs);
}

// 使用示例
findMultipleDocuments('users', { age: { $gt: 20 } });

3. 更新(Update)

更新單條數(shù)據(jù)

async function updateOneDocument(collectionName, filter, updateDoc) {
    const collection = db.collection(collectionName);
    const result = await collection.updateOne(filter, { $set: updateDoc });
    console.log(result);
}

// 使用示例
updateOneDocument('users', { name: 'Tom' }, { age: 28 });

更新多條數(shù)據(jù)

async function updateMultipleDocuments(collectionName, filter, updateDoc) {
    const collection = db.collection(collectionName);
    const result = await collection.updateMany(filter, { $set: updateDoc });
    console.log(result);
}

// 使用示例
updateMultipleDocuments('users', { age: { $lt: 30 } }, { active: true });

4. 刪除(Delete)

刪除單條數(shù)據(jù)

async function deleteOneDocument(collectionName, query) {
    const collection = db.collection(collectionName);
    const result = await collection.deleteOne(query);
    console.log(result);
}

// 使用示例
deleteOneDocument('users', { name: 'Tom' });

刪除多條數(shù)據(jù)

async function deleteMultipleDocuments(collectionName, query) {
    const collection = db.collection(collectionName);
    const result = await collection.deleteMany(query);
    console.log(result);
}

// 使用示例
deleteMultipleDocuments('users', { active: true });

完成上面的操作后，確保關(guān)閉數(shù)據(jù)庫連接。

client.close();

在使用以上代碼時(shí)，請通過替換collectionName、query和updateDoc的值以適配你的實(shí)際需求。

這個(gè)指南涵蓋了在Node.js中使用MongoDB進(jìn)行基本的CRUD操作的代碼示例。在實(shí)際應(yīng)用開發(fā)中，你可能需要根據(jù)實(shí)際業(yè)務(wù)邏輯對其進(jìn)行更復(fù)雜的操作和封裝。

在MongoDB中執(zhí)行更高級(jí)的查詢和修改操作通常涉及更復(fù)雜的查詢條件、聚合操作以及對更新操作的細(xì)致控制。我將在此為您提供一些進(jìn)階使用示例。

進(jìn)階版

高級(jí)查詢

查詢時(shí)可以使用更復(fù)雜的操作符，比如$and, $or, $in, $not, $type, $regex等來構(gòu)建復(fù)雜的查詢語句。

使用邏輯運(yùn)算符

async function findWithLogicalOperators(collectionName) {
    const collection = db.collection(collectionName);
    // 查詢年齡大于20并且名字以'A'開頭的用戶
    const query = { $and: [{ age: { $gt: 20 } }, { name: { $regex: /^A/ } }] };
    const docs = await collection.find(query).toArray();
    console.log(docs);
}

findWithLogicalOperators('users');

使用數(shù)組查詢

async function findUsersWithSpecificInterests(collectionName) {
    const collection = db.collection(collectionName);
    // 查詢興趣中包含閱讀的用戶
    const query = { interests: "閱讀" };
    const docs = await collection.find(query).toArray();
    console.log(docs);
}

findUsersWithSpecificInterests('users');

使用聚合框架(Aggregation Framework)

MongoDB提供的聚合框架可以執(zhí)行更復(fù)雜的數(shù)據(jù)處理任務(wù)，比如分組、排序、計(jì)算字段等。

分組和計(jì)算平均年齡

async function averageAgeByInterest(collectionName) {
    const collection = db.collection(collectionName);
    const pipeline = [
        { $unwind: "$interests" },
        { $group: { _id: "$interests", averageAge: { $avg: "$age" } } },
        { $sort: { averageAge: -1 } }
    ];
    const result = await collection.aggregate(pipeline).toArray();
    console.log(result);
}

averageAgeByInterest('users');

高級(jí)更新

更新操作可以包括修改字段、添加新字段以及使用更新操作符如$inc, $push等。

更新并同時(shí)增加新字段

async function updateAndAddField(collectionName, userId, incrementValue) {
    const collection = db.collection(collectionName);
    const filter = { _id: userId };
    const updateDoc = {
        $set: { lastActive: new Date() },
        $inc: { loginCount: incrementValue }
    };
    const result = await collection.updateOne(filter, updateDoc);
    console.log(result);
}

updateAndAddField('users', "someUserId", 1);

向數(shù)組中添加元素

async function addInterestToUser(collectionName, userId, newInterest) {
    const collection = db.collection(collectionName);
    const filter = { _id: userId };
    const updateDoc = { $push: { interests: newInterest } };
    const result = await collection.updateOne(filter, updateDoc);
    console.log(result);
}

addInterestToUser('users', "someUserId", "游泳");

刪除操作

刪除操作同樣可以是條件化的，你可以根據(jù)條件批量刪除記錄。

刪除年齡在一定范圍內(nèi)的用戶

async function deleteUserByAgeRange(collectionName, minAge, maxAge) {
    const collection = db.collection(collectionName);
    const query = { age: { $gte: minAge, $lte: maxAge } };
    const result = await collection.deleteMany(query);
    console.log(result);
}

deleteUserByAgeRange('users', 18, 30);

以上就是Node.js中操作MongoDB的CRUD操作指南的詳細(xì)內(nèi)容，更多關(guān)于Node.js操作MongoDB的CRUD的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: