Node.js ile MongoDB Kullanımı: find, insert, update

MongoDB'yi Node.js'ten kullanmak için resmi driver'ı kur (npm install mongodb), new MongoClient(uri) ile bağlan, client.db('name') ile bir veritabanı ve db.collection('name') ile bir collection seç. Her işlem (insertOne, find, updateOne, deleteOne) bir promise döndürür, yani onu await edersin. Dökümanlar düz JavaScript nesneleri olarak girer ve çıkar.

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

Program [ 'Dune', 'Neuromancer', 'Hyperion' ] yazdırır. shop veritabanı ve books collection'ı daha önce yoktu: MongoDB onları ilk eklemede oluşturur, toArray() de find() cursor'ının gösterdiği her dökümanı yükler.

Filtre ve projection ile döküman bulmak

Filtre, istediğin dökümanları tarif eden bir nesnedir. Düz değerler birebir eşleşir; $gt, $lt, $in ve $regex gibi operatörler iç içe bir nesneye yazılır. İkinci argümandaki projection hangi alanların geri geleceğini seçer.

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'tan sonraki en yeni iki kitabı, önce Hyperion sonra Neuromancer'ı, yalnızca title ve year ile tutar; findOne ilk eşleşmeyi (ya da null) döndürür, countDocuments ise 10 ya da daha pahalı 2 kitap sayar. $gt: 1960'ı $gt: 1985 yaparsan yalnızca Hyperion kalır.

Güncelleme ve silme

updateOne(filter, update) eşleşen ilk dökümanı değiştirir. Güncelleme operatör kullanır: $set alanları değiştirir, $inc bir sayıya ekler, $unset bir alanı kaldırır ve $push bir diziye eleman ekler. updateMany ve deleteMany her eşleşme üzerinde çalışır.

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

Güncelleme bir dökümanla eşleşti ve onu değiştirdi, yani Dune artık 10 tutuyor ve stokta 2 tane var; stoğu olmayan kitabı silmek de geriye 1 bırakıyor. Bir güncelleme operatör kullanmak zorundadır: $set olmadan { price: 10 } geçirirsen driver onu reddeder (bütün bir dökümanı değiştiren çağrı replaceOne'dır).

ObjectId ve index'ler

Her döküman bir _id alır; sen ayarlamazsan driver bir ObjectId oluşturur. String olarak gelen bir id ile (örneğin bir URL'den) bir döküman bulmak için onu new ObjectId(id) ile sar. Bir index bir alanda aramayı hızlandırır, unique bir index de MongoDB'nin tekrarları reddetmesini sağlar.

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

Bir ObjectId string olarak 24 hex karakterdir ve düz string ile arama hiçbir şey bulmaz, bu yüzden o satır null yazdırır. İkinci ekleme unique index'i ihlal eder ve 11000 koduyla başarısız olur; "bu e-posta zaten kullanılıyor" durumunu böyle tespit edersin.

MongoDB'yi bir Express API'de kullanmak

Sunucu başlarken bir kez bağlan ve collection'ı paylaş; her istek için yeni bağlantı açma. Driver bir bağlantı havuzu tutar ve bağlantıları yeniden kullanır.

// 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, her biri bir _id taşıyan iki kitabı da döndürür. Tek bir kitabı almak için bir id'yi GET /books/<id> içine kopyala ya da {"title": "Foundation", "year": 1951} gibi bir JSON body ile POST /books gönder ve kitapları yeniden listele.

Gerçek bir uygulama connection string'i koda yazmak yerine process.env.MONGODB_URI'den okur.

Driver'ın üstünde schema ve doğrulama istiyorsan Mongoose (npm install mongoose) onu sarar:

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

Sık yapılan hatalar

toArray()'i unutmak. find() döküman değil, bir cursor döndürür. Onu loglamak bir cursor nesnesi gösterir; toArray() çağır ya da for await ile üzerinde dön.

Her istekte bağlanmak. Her new MongoClient kendi havuzunu açar. Başlangıçta tek bir client oluştur ve her yerde onu kullan.

Bir script'te client'ı hiç kapatmamak. Açık bir client, kodun bittikten sonra da süreci canlı tutar. Script'lerin sonunda await client.close() çağır; bir sunucu ise onu tüm ömrü boyunca açık tutar.