MongoDB עם Node.js: דוגמאות driver ‏(find, insert, update)

כדי לעבוד עם MongoDB מ-Node.js, התקינו את ה-driver הרשמי (npm install mongodb), התחברו עם new MongoClient(uri), בחרו מסד נתונים עם client.db('name') ו-collection עם db.collection('name'). כל פעולה (insertOne, find, updateOne, deleteOne) מחזירה promise, כך שעושים לה await. documents נכנסים ויוצאים כאובייקטי 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 וה-collection ‏books לא היו קיימים קודם: MongoDB יוצר אותם בהוספה הראשונה, ו-toArray() טוען כל document שה-cursor של find() מצביע עליו.

חיפוש documents עם פילטרים ו-projection

פילטר הוא אובייקט שמתאר את ה-documents שאתם רוצים. ערכים רגילים מתאימים בדיוק; אופרטורים כמו $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) משנה את ה-document התואם הראשון. העדכון משתמש באופרטורים: $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();

העדכון התאים ל-document אחד ושינה אותו, כך ש-Dune עולה עכשיו 10 עם 2 במלאי, ומחיקת הספר שאין לו מלאי משאירה 1. עדכון חייב להשתמש באופרטורים: העבירו { price: 10 } בלי $set וה-driver ידחה אותו (‏replaceOne היא הקריאה שמחליפה document שלם).

ObjectId ואינדקסים

כל document מקבל _id; כשלא מגדירים אחד, ה-driver יוצר ObjectId. כדי למצוא document לפי id שהגיע כמחרוזת (מ-URL, למשל), עטפו אותו ב-new ObjectId(id). אינדקס הופך חיפוש לפי שדה למהיר, ואינדקס unique גורם ל-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. ההוספה השנייה שוברת את האינדקס ה-unique ונכשלת עם הקוד 11000, וכך מזהים "האימייל כבר תפוס".

שימוש ב-MongoDB ב-API של Express

התחברו פעם אחת כשהשרת עולה ושתפו את ה-collection; אל תפתחו חיבור חדש לכל בקשה. ה-driver מחזיק pool של חיבורים ומשתמש בהם שוב.

// 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. העתיקו id אחד ל-GET /books/<id> כדי להביא ספר בודד, או שלחו POST /books עם גוף JSON כמו {"title": "Foundation", "year": 1951} והציגו שוב את רשימת הספרים.

אפליקציה אמיתית קוראת את ה-connection string מתוך process.env.MONGODB_URI במקום לכתוב אותו בקוד.

אם אתם רוצים schemas וולידציה מעל ה-driver, ‏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, לא documents. הדפסה שלו מציגה אובייקט cursor; קראו ל-toArray(), או עברו עליו בלולאה עם for await.

התחברות בכל בקשה. כל new MongoClient פותח pool משלו. צרו client אחד בעלייה והשתמשו בו בכל מקום.

לא לסגור את ה-client בסקריפט. client פתוח משאיר את התהליך חי אחרי שהקוד שלכם סיים. קראו ל-await client.close() בסוף סקריפטים; שרת משאיר אותו פתוח לאורך כל חייו.