MongoDB مع Node.js: أمثلة find وinsert وupdate

لاستخدام MongoDB من Node.js، ثبّت برنامج التشغيل الرسمي (npm install mongodb)، واتصل بـ new MongoClient(uri)، واختر قاعدة بيانات بـ client.db('name') ومجموعة بـ db.collection('name'). كل عملية (insertOne وfind وupdateOne وdeleteOne) تعيد وعدًا، فتنتظرها بـ await. تدخل المستندات وتخرج ككائنات JavaScript عادية.

import { MongoClient } from 'mongodb';

const client = new MongoClient('mongodb://localhost:27017');
await client.connect();

const books = client.db('shop').collection('books');

await books.insertMany([
    { title: 'Dune', author: 'Herbert', year: 1965, price: 12 },
    { title: 'Neuromancer', author: 'Gibson', year: 1984, price: 9 },
    { title: 'Hyperion', author: 'Simmons', year: 1989, price: 11 },
]);

const all = await books.find().toArray();
console.log(all.map((b) => b.title));

await client.close();

يطبع [ 'Dune', 'Neuromancer', 'Hyperion' ]. لم تكن قاعدة البيانات shop ولا المجموعة books موجودتين من قبل: ينشئهما MongoDB عند أول إضافة، وتحمّل toArray() كل مستند يشير إليه مؤشر find().

البحث عن المستندات مع المرشحات والإسقاط

المرشح (filter) كائن يصف المستندات التي تريدها. القيم العادية تطابق بالضبط؛ والعوامل مثل $gt و$lt و$in و$regex توضع في كائن متداخل. ويختار projection في الوسيط الثاني الحقول التي تعود.

import { MongoClient } from 'mongodb';

const client = new MongoClient('mongodb://localhost:27017');
const books = client.db('shop').collection('books');

await books.insertMany([
    { title: 'Dune', author: 'Herbert', year: 1965, price: 12 },
    { title: 'Neuromancer', author: 'Gibson', year: 1984, price: 9 },
    { title: 'Hyperion', author: 'Simmons', year: 1989, price: 11 },
    { title: 'Foundation', author: 'Asimov', year: 1951, price: 8 },
]);

const recent = await books
    .find({ year: { $gt: 1960 } }, { projection: { _id: 0, title: 1, year: 1 } })
    .sort({ year: -1 })
    .limit(2)
    .toArray();
recent.forEach((b) => console.log(b));

const cheap = await books.findOne({ price: { $lt: 10 }, author: 'Asimov' });
console.log(cheap.title);

console.log(await books.countDocuments({ price: { $gte: 10 } }));

await client.close();

تحمل recent أحدث كتابين بعد 1960، Hyperion ثم Neuromancer، مع title وyear فقط؛ وتعيد findOne أول تطابق (أو null)، وتعدّ countDocuments كتابين، 2، ثمن كل منهما 10 أو أكثر. غيّر $gt: 1960 إلى $gt: 1985 فلا يبقى إلا Hyperion.

التحديث والحذف

تغيّر updateOne(filter, update) أول مستند مطابق. يستخدم التحديث عوامل: $set يستبدل حقولًا، و$inc يضيف إلى رقم، و$unset يحذف حقلًا، و$push يُلحق بمصفوفة. وتعمل updateMany وdeleteMany على كل التطابقات.

import { MongoClient } from 'mongodb';

const client = new MongoClient('mongodb://localhost:27017');
const books = client.db('shop').collection('books');

await books.insertMany([
    { title: 'Dune', price: 12, stock: 3 },
    { title: 'Neuromancer', price: 9, stock: 0 },
]);

const res = await books.updateOne(
    { title: 'Dune' },
    { $set: { price: 10 }, $inc: { stock: -1 } }
);
console.log(res.matchedCount, res.modifiedCount);

const dune = await books.findOne({ title: 'Dune' });
console.log(dune.price, dune.stock);

const del = await books.deleteOne({ stock: 0 });
console.log('deleted', del.deletedCount, 'left', await books.countDocuments());

await client.close();

طابق التحديث مستندًا واحدًا وعدّله، فصار ثمن Dune الآن 10 والمخزون 2، وحذف الكتاب الذي لا مخزون له يترك 1. يجب أن يستخدم التحديث عوامل: مرّر { price: 10 } دون $set فيرفضه برنامج التشغيل (replaceOne هو الاستدعاء الذي يستبدل مستندًا كاملًا).

ObjectId والفهارس

كل مستند يحصل على _id؛ وحين لا تضبطه بنفسك ينشئ برنامج التشغيل ObjectId. للعثور على مستند بمعرّف وصل كنص (من عنوان URL مثلًا)، غلّفه بـ new ObjectId(id). يجعل الفهرس البحث في حقل سريعًا، ويجعل الفهرس الفريد MongoDB يرفض التكرارات.

import { MongoClient, ObjectId } from 'mongodb';

const client = new MongoClient('mongodb://localhost:27017');
const users = client.db('app').collection('users');

await users.createIndex({ email: 1 }, { unique: true });

const { insertedId } = await users.insertOne({ email: 'ada@example.com' });
const idString = insertedId.toString();
console.log(idString.length);

const found = await users.findOne({ _id: new ObjectId(idString) });
console.log(found.email);
console.log(await users.findOne({ _id: idString }));

try {
    await users.insertOne({ email: 'ada@example.com' });
} catch (err) {
    console.log('duplicate, error code', err.code);
}

await client.close();

يتكوّن ObjectId كنص من 24 محرفًا ست عشريًا، والبحث بالنص العادي لا يجد شيئًا، فيطبع ذلك السطر null. وتخالف الإضافة الثانية الفهرس الفريد فتفشل بالرمز 11000، وهكذا تكتشف أن "البريد مستخدم مسبقًا".

استخدام MongoDB في واجهة API بـ Express

اتصل مرة واحدة حين يبدأ الخادم وشارك المجموعة؛ لا تفتح اتصالًا جديدًا مع كل طلب. يحتفظ برنامج التشغيل بمجموعة من الاتصالات ويعيد استخدامها.

// GET /books
import express from 'express';
import { MongoClient, ObjectId } from 'mongodb';

const client = new MongoClient('mongodb://localhost:27017');
const books = client.db('shop').collection('books');

// Setup: seed two books
await books.insertMany([
    { title: 'Dune', year: 1965 },
    { title: 'Hyperion', year: 1989 },
]);

const app = express();
app.use(express.json());

app.get('/books', async (req, res) => {
    const list = await books.find().sort({ year: 1 }).toArray();
    res.json(list);
});

app.get('/books/:id', async (req, res) => {
    if (!ObjectId.isValid(req.params.id)) {
        return res.status(400).json({ error: 'Bad id' });
    }
    const book = await books.findOne({ _id: new ObjectId(req.params.id) });
    if (!book) return res.status(404).json({ error: 'Not found' });
    res.json(book);
});

app.post('/books', async (req, res) => {
    const { insertedId } = await books.insertOne({ title: req.body.title, year: req.body.year });
    res.status(201).json({ _id: insertedId });
});

app.listen(3000);

يعيد GET /books الكتابين، لكل منهما _id. انسخ أحد المعرّفات إلى GET /books/<id> لجلب كتاب واحد، أو أرسل POST /books مع جسم JSON مثل {"title": "Foundation", "year": 1951} ثم اسرد الكتب مرة أخرى.

التطبيق الحقيقي يقرأ سلسلة الاتصال من process.env.MONGODB_URI بدلًا من كتابتها في الشيفرة.

إذا أردت مخططات وتحققًا فوق برنامج التشغيل، فإن Mongoose (npm install mongoose) يغلّفه:

const Book = mongoose.model('Book', new mongoose.Schema({ title: String, year: Number }));
await Book.create({ title: 'Dune', year: 1965 });

أخطاء شائعة

نسيان toArray(). تعيد find() مؤشرًا (cursor) لا مستندات. طباعته تُظهر كائن مؤشر؛ استدعِ toArray()، أو مرّ عليه بـ for await.

الاتصال مع كل طلب. كل new MongoClient يفتح مجموعة اتصالات خاصة به. أنشئ عميلًا واحدًا عند بدء التشغيل وأعد استخدامه في كل مكان.

عدم إغلاق العميل أبدًا في سكربت. العميل المفتوح يُبقي العملية حية بعد انتهاء شيفرتك. استدعِ await client.close() في نهاية السكربتات؛ أما الخادم فيُبقيه مفتوحًا طوال عمره.