MongoDB dengan Node.js: Contoh Driver (find, insert, update)

Untuk memakai MongoDB dari Node.js, install driver resminya (npm install mongodb), hubungkan dengan new MongoClient(uri), pilih database dengan client.db('name') dan collection dengan db.collection('name'). Setiap operasi (insertOne, find, updateOne, deleteOne) mengembalikan promise, jadi kamu meng-await-nya. Dokumen masuk dan keluar sebagai object JavaScript biasa.

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

Hasilnya [ 'Dune', 'Neuromancer', 'Hyperion' ]. Database shop dan collection books belum ada sebelumnya: MongoDB membuatnya saat insert pertama, dan toArray() memuat setiap dokumen yang ditunjuk cursor find().

Mencari dokumen dengan filter dan projection

Filter adalah object yang menggambarkan dokumen yang kamu inginkan. Nilai biasa dicocokkan persis; operator seperti $gt, $lt, $in, dan $regex ditaruh di object bersarang. projection di argumen kedua memilih field mana yang dikembalikan.

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 berisi dua buku terbaru setelah 1960, Hyperion lalu Neuromancer, hanya dengan title dan year; findOne mengembalikan kecocokan pertama (atau null), dan countDocuments menghitung 2 buku yang harganya 10 atau lebih. Ganti $gt: 1960 menjadi $gt: 1985 dan hanya Hyperion yang tersisa.

Update dan delete

updateOne(filter, update) mengubah dokumen pertama yang cocok. Update-nya memakai operator: $set mengganti field, $inc menambah angka, $unset menghapus field, dan $push menambah ke array. updateMany dan deleteMany bekerja pada setiap dokumen yang cocok.

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

Update-nya cocok dengan satu dokumen dan mengubahnya, jadi Dune sekarang berharga 10 dengan stok 2, dan menghapus buku yang stoknya habis menyisakan 1. Update harus memakai operator: berikan { price: 10 } tanpa $set dan driver menolaknya (replaceOne adalah panggilan untuk mengganti seluruh dokumen).

ObjectId dan index

Setiap dokumen mendapat _id; kalau kamu tidak mengaturnya, driver membuat sebuah ObjectId. Untuk mencari dokumen berdasarkan id yang datang sebagai string (misalnya dari URL), bungkus dengan new ObjectId(id). Index membuat pencarian pada sebuah field menjadi cepat, dan unique index membuat MongoDB menolak duplikat.

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

Sebagai string, ObjectId terdiri dari 24 karakter hex, dan mencari dengan string biasa tidak menemukan apa pun, jadi baris itu mencetak null. Insert kedua melanggar unique index dan gagal dengan kode 11000, begitulah cara kamu mendeteksi "email sudah dipakai".

Memakai MongoDB di API Express

Hubungkan sekali saat server dimulai dan bagikan collection-nya; jangan membuka koneksi baru per request. Driver menyimpan pool koneksi dan memakainya ulang.

// 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 mengembalikan kedua buku, masing-masing dengan _id. Salin satu id ke GET /books/<id> untuk mengambil satu buku, atau kirim POST /books dengan body JSON seperti {"title": "Foundation", "year": 1951} lalu tampilkan daftar bukunya lagi.

Aplikasi sungguhan membaca connection string dari process.env.MONGODB_URI, bukan menuliskannya di kode.

Kalau kamu ingin schema dan validasi di atas driver, Mongoose (npm install mongoose) membungkusnya:

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

Kesalahan umum

Lupa toArray(). find() mengembalikan cursor, bukan dokumen. Mencetaknya hanya menampilkan object cursor; panggil toArray(), atau ulangi dengan for await.

Membuat koneksi di setiap request. Setiap new MongoClient membuka pool-nya sendiri. Buat satu client saat startup dan pakai ulang di mana saja.

Tidak pernah menutup client di script. Client yang terbuka membuat proses tetap hidup setelah kodemu selesai. Panggil await client.close() di akhir script; server membiarkannya terbuka sepanjang hidupnya.