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

Поиск документов с фильтрами и projection

Фильтр это объект, который описывает нужные документы. Обычные значения сравниваются на точное совпадение; операторы вроде $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. Чтобы найти документ по id, который пришёл строкой (например, из 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, так и определяют ситуацию "email уже занят".

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. Скопируйте один 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() возвращает курсор, а не документы. В логе будет объект курсора; вызовите toArray() или пройдите по нему через for await.

Подключение на каждый запрос. Каждый new MongoClient открывает свой пул. Создайте один клиент при запуске и используйте его везде.

Клиент не закрыт в скрипте. Открытый клиент не даёт процессу завершиться, когда ваш код уже отработал. Вызывайте await client.close() в конце скриптов; сервер держит его открытым всё время работы.