MongoDB com Node.js: exemplos do driver (find, insert)

Para usar o MongoDB no Node.js, instale o driver oficial (npm install mongodb), conecte com new MongoClient(uri), escolha um banco com client.db('name') e uma collection com db.collection('name'). Toda operação (insertOne, find, updateOne, deleteOne) retorna uma promise, então você dá await. Os documentos entram e saem como objetos JavaScript comuns.

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

Ele imprime [ 'Dune', 'Neuromancer', 'Hyperion' ]. O banco shop e a collection books não existiam antes: o MongoDB cria os dois no primeiro insert, e toArray() carrega todos os documentos para os quais o cursor do find() aponta.

Buscar documentos com filtros e projection

Um filtro é um objeto que descreve os documentos que você quer. Valores simples batem exatamente; operadores como $gt, $lt, $in e $regex ficam em um objeto aninhado. A projection do segundo argumento escolhe quais campos voltam.

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 guarda os dois livros mais novos depois de 1960, Hyperion e depois Neuromancer, só com title e year; findOne retorna o primeiro resultado (ou null), e countDocuments conta 2 livros que custam 10 ou mais. Troque $gt: 1960 por $gt: 1985 e só Hyperion sobra.

Atualizar e apagar

updateOne(filter, update) altera o primeiro documento que corresponde. O update usa operadores: $set substitui campos, $inc soma a um número, $unset remove um campo e $push adiciona a um array. updateMany e deleteMany agem em todos os que correspondem.

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

O update encontrou e alterou um documento, então Dune agora custa 10 com 2 em estoque, e apagar o livro sem estoque deixa 1. Um update precisa usar operadores: passe { price: 10 } sem $set e o driver recusa (replaceOne é a chamada que substitui um documento inteiro).

ObjectId e índices

Todo documento recebe um _id; quando você não define um, o driver cria um ObjectId. Para encontrar um documento por um id que chegou como string (de uma URL, por exemplo), envolva com new ObjectId(id). Um índice deixa a busca por um campo rápida, e um índice único faz o MongoDB recusar duplicados.

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

Um ObjectId como string tem 24 caracteres hexadecimais, e buscar com a string pura não encontra nada, então aquela linha imprime null. O segundo insert viola o índice único e falha com o código 11000, que é como você detecta um "e-mail já cadastrado".

Usar MongoDB em uma API Express

Conecte uma vez quando o servidor sobe e compartilhe a collection; não abra uma conexão nova a cada requisição. O driver mantém um pool de conexões e as reutiliza.

// 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 retorna os dois livros, cada um com um _id. Copie um id para GET /books/<id> para buscar um único livro, ou envie POST /books com um body JSON como {"title": "Foundation", "year": 1951} e liste os livros de novo.

Um app real lê a connection string de process.env.MONGODB_URI em vez de escrevê-la no código.

Se você quer schemas e validação por cima do driver, o Mongoose (npm install mongoose) o envolve:

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

Erros comuns

Esquecer o toArray(). find() retorna um cursor, não documentos. Imprimir mostra um objeto cursor; chame toArray(), ou percorra com for await.

Conectar a cada requisição. Cada new MongoClient abre o próprio pool. Crie um client na inicialização e reutilize em todo lugar.

Nunca fechar o client em um script. Um client aberto mantém o processo vivo depois que seu código termina. Chame await client.close() no fim dos scripts; um servidor o mantém aberto a vida inteira.