MongoDB với Node.js: ví dụ driver find, insert, update

Để dùng MongoDB từ Node.js, hãy cài driver chính thức (npm install mongodb), kết nối bằng new MongoClient(uri), chọn database bằng client.db('name') và collection bằng db.collection('name'). Mọi thao tác (insertOne, find, updateOne, deleteOne) đều trả về promise, nên bạn await chúng. Document được ghi vào và đọc ra dưới dạng object JavaScript thuần.

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

Chương trình in ra [ 'Dune', 'Neuromancer', 'Hyperion' ]. Database shop và collection books trước đó chưa tồn tại: MongoDB tạo chúng ở lần thêm đầu tiên, và toArray() nạp mọi document mà cursor của find() trỏ tới.

Tìm document với bộ lọc và projection

Bộ lọc (filter) là một object mô tả các document bạn muốn. Giá trị thường thì khớp chính xác; các toán tử như $gt, $lt, $in và $regex nằm trong một object lồng bên trong. projection ở đối số thứ hai chọn những trường nào được trả về.

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 chứa hai cuốn sách mới nhất sau năm 1960, Hyperion rồi đến Neuromancer, chỉ với title và year; findOne trả về kết quả khớp đầu tiên (hoặc null), và countDocuments đếm được 2 cuốn có giá từ 10 trở lên. Đổi $gt: 1960 thành $gt: 1985 thì chỉ còn lại Hyperion.

Cập nhật và xóa

updateOne(filter, update) thay đổi document đầu tiên khớp bộ lọc. Phần cập nhật dùng toán tử: $set thay giá trị các trường, $inc cộng thêm vào một số, $unset xóa một trường và $push thêm phần tử vào cuối mảng. updateMany và deleteMany áp dụng cho mọi document khớp.

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

Lệnh cập nhật khớp và sửa một document, nên giờ Dune có giá 10 và còn 2 cuốn trong kho, còn việc xóa cuốn sách đã hết hàng để lại 1 cuốn. Lệnh cập nhật bắt buộc dùng toán tử: truyền { price: 10 } mà không có $set thì driver từ chối (replaceOne mới là lệnh thay thế cả document).

ObjectId và index

Mỗi document đều có một _id; khi bạn không tự đặt, driver sẽ tạo một ObjectId. Để tìm document theo một id đến dưới dạng chuỗi (ví dụ từ URL), hãy bọc nó trong new ObjectId(id). Index giúp tìm kiếm theo một trường nhanh hơn, còn unique index khiến MongoDB từ chối giá trị trùng lặp.

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

Dưới dạng chuỗi, một ObjectId gồm 24 ký tự hex, và tìm bằng chuỗi thường thì không thấy gì, nên dòng đó in ra null. Lần thêm thứ hai vi phạm unique index và thất bại với mã 11000, đây là cách bạn phát hiện "email đã được dùng".

Dùng MongoDB trong một API Express

Kết nối một lần khi server khởi động rồi dùng chung collection; đừng mở kết nối mới cho mỗi request. Driver giữ một pool kết nối và dùng lại chúng.

// 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 trả về cả hai cuốn sách, mỗi cuốn có một _id. Sao chép một id vào GET /books/<id> để lấy một cuốn, hoặc gửi POST /books với body JSON như {"title": "Foundation", "year": 1951} rồi liệt kê lại danh sách sách.

App thật đọc connection string từ process.env.MONGODB_URI thay vì viết thẳng vào code.

Nếu bạn muốn có schema và validation bên trên driver, Mongoose (npm install mongoose) sẽ bọc nó lại:

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

Lỗi thường gặp

Quên toArray(). find() trả về một cursor, không phải các document. In nó ra chỉ thấy một object cursor; hãy gọi toArray(), hoặc duyệt nó bằng for await.

Kết nối ở mỗi request. Mỗi new MongoClient mở một pool riêng. Hãy tạo một client lúc khởi động và dùng lại ở mọi nơi.

Không bao giờ đóng client trong script. Một client còn mở giữ tiến trình chạy tiếp sau khi code của bạn đã xong. Gọi await client.close() ở cuối script; còn server thì giữ nó mở suốt thời gian chạy.