MongoDB w Node.js: przykłady ze sterownikiem (find, insert)

Żeby używać MongoDB z Node.js, zainstaluj oficjalny sterownik (npm install mongodb), połącz się przez new MongoClient(uri), wybierz bazę przez client.db('name') i kolekcję przez db.collection('name'). Każda operacja (insertOne, find, updateOne, deleteOne) zwraca promise, więc czekasz na nią przez await. Dokumenty wchodzą i wychodzą jako zwykłe obiekty 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();

Wypisuje [ 'Dune', 'Neuromancer', 'Hyperion' ]. Baza shop i kolekcja books wcześniej nie istniały: MongoDB tworzy je przy pierwszym dodaniu, a toArray() wczytuje każdy dokument, na który wskazuje kursor find().

Wyszukiwanie z filtrami i projekcją

Filtr to obiekt opisujący dokumenty, których szukasz. Zwykłe wartości pasują dokładnie; operatory takie jak $gt, $lt, $in i $regex idą do zagnieżdżonego obiektu. projection w drugim argumencie wybiera, które pola wracają.

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 zawiera dwie najnowsze książki po 1960 roku, najpierw Hyperion, potem Neuromancer, tylko z title i year; findOne zwraca pierwsze dopasowanie (albo null), a countDocuments liczy 2 książki kosztujące 10 lub więcej. Zmień $gt: 1960 na $gt: 1985, a zostanie tylko Hyperion.

Aktualizacja i usuwanie

updateOne(filter, update) zmienia pierwszy pasujący dokument. Aktualizacja używa operatorów: $set zastępuje pola, $inc dodaje do liczby, $unset usuwa pole, a $push dopisuje do tablicy. updateMany i deleteMany działają na każdym dopasowaniu.

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();

Aktualizacja dopasowała i zmieniła jeden dokument, więc Dune kosztuje teraz 10, a w magazynie są 2 sztuki, a usunięcie książki bez zapasu zostawia 1. Aktualizacja musi używać operatorów: przekaż { price: 10 } bez $set, a sterownik ją odrzuci (cały dokument zastępuje wywołanie replaceOne).

ObjectId i indeksy

Każdy dokument dostaje _id; jeśli go nie ustawisz, sterownik tworzy ObjectId. Żeby znaleźć dokument po id, które przyszło jako string (np. z URL), opakuj je w new ObjectId(id). Indeks przyspiesza wyszukiwanie po polu, a indeks unikalny sprawia, że MongoDB odrzuca duplikaty.

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 jako string ma 24 znaki szesnastkowe, a wyszukiwanie po zwykłym stringu nic nie znajduje, więc ta linia wypisuje null. Drugie dodanie łamie indeks unikalny i kończy się błędem z kodem 11000, i tak właśnie wykrywasz "e-mail jest już zajęty".

MongoDB w API Express

Połącz się raz przy starcie serwera i współdziel kolekcję; nie otwieraj nowego połączenia na każde żądanie. Sterownik trzyma pulę połączeń i używa ich ponownie.

// 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 zwraca obie książki, każdą z _id. Skopiuj jedno id do GET /books/<id>, żeby pobrać pojedynczą książkę, albo wyślij POST /books z body w JSON, np. {"title": "Foundation", "year": 1951}, i ponownie wylistuj książki.

Prawdziwa aplikacja czyta connection string z process.env.MONGODB_URI zamiast wpisywać go w kod.

Jeśli chcesz mieć schematy i walidację nad sterownikiem, opakowuje go Mongoose (npm install mongoose):

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

Częste błędy

Zapominanie o toArray(). find() zwraca kursor, nie dokumenty. Gdy go zalogujesz, zobaczysz obiekt kursora; wywołaj toArray() albo przejdź po nim pętlą for await.

Łączenie się przy każdym żądaniu. Każdy new MongoClient otwiera własną pulę. Utwórz jednego klienta przy starcie i używaj go wszędzie.

Niezamykanie klienta w skrypcie. Otwarty klient utrzymuje proces przy życiu, gdy twój kod już skończył. Na końcu skryptów wywołuj await client.close(); serwer trzyma go otwartego przez cały czas działania.