Paginasi di database

Termasuk bagian Database dengan MongoDB dalam perjalanan Node.js di Coddy. Pelajaran 27 dari 29.

Rak berisi sepuluh ribu buku tidak bisa dikirim dalam satu respons. Client meminta satu halaman setiap kali, dan database sebaiknya hanya mengirim halaman itu.

skip(n) melewati n hasil pertama, dan limit(n) mengambil n hasil berikutnya. Halaman 1 dimulai dari awal, jadi halaman p melewati (p - 1) * size. Kirim totalnya bersama halaman, dihitung dengan filter yang sama, agar client tahu ada berapa halaman.

// halaman 3 dari log error, 20 entri per halaman
const entries = await log
    .find({ level: 'error' })
    .skip((3 - 1) * 20)
    .limit(20)
    .toArray();
const total = await log.countDocuments({ level: 'error' });

Tantangan

Mudah

Rak berisi sepuluh ribu buku tidak bisa dikirim dalam satu respons. GET /books sekarang mengirim satu halaman setiap kali. Responsnya juga menyebutkan jumlah semua buku yang cocok, sehingga client bisa menampilkan "page 1 of 5".

Di server.js, ubah GET /books. Pertahankan filter author, from, dan to.
Baca ?page= (nilai bawaan 1) dan ?limit= (nilai bawaan 10). Jika salah satunya tidak ada atau bukan angka, gunakan nilai bawaannya. Halaman 1 dimulai dari buku pertama, jadi halaman p melewati (p - 1) * limit buku, lalu mengembalikan limit buku berikutnya. Biarkan database yang melewati dan membatasi hasilnya.
Hitung total di database dengan menggunakan filter yang sama. Jumlah ini menghitung semua buku yang cocok, bukan hanya buku di halaman ini.
Berikan respons dengan status 200 dan sebuah object, bukan array. GET /books?limit=2 mengembalikan:
```
{
  "items": [
    { "_id": "6720a1f4c2b9e81d3a5f0c11", "title": "Dune", "author": "Frank Herbert", "year": 1965, "isbn": "9780441013593", "genre": "scifi" },
    { "_id": "6720a1f4c2b9e81d3a5f0c12", "title": "Kindred", "author": "Octavia E. Butler", "year": 1979, "isbn": "9780807083697", "genre": "scifi" }
  ],
  "total": 3
}
```
Coba: Kirim GET /books?limit=2: kamu mendapatkan Dune dan Kindred, dengan "total": 3. Kirim GET /books?limit=2&page=2: kamu hanya mendapatkan Emma, tetap dengan "total": 3. Kirim GET /books?limit=2&page=3: kamu mendapatkan "items": [] dan "total": 3. Kirim GET /books?author=Jane%20Austen&limit=1: kamu mendapatkan Emma, dengan "total": 1. Kirim GET /books: kamu mendapatkan ketiga buku di dalam items.

Coba sendiri

import express from 'express';
import { ObjectId } from 'mongodb';
import { books, ratings } from './db.js';

const app = express();
app.use(express.json());

// Setiap error mengembalikan { error: message }.
function sendError(res, status, message) {
    res.status(status).json({ error: message });
}

// Ubah :id menjadi ObjectId, atau kembalikan null setelah mengirim respons 400 untuk id yang tidak valid.
function parseId(req, res) {
    if (ObjectId.isValid(req.params.id)) {
        return new ObjectId(req.params.id);
    }
    sendError(res, 400, 'Not a valid id');
    return null;
}

app.get('/', (req, res) => {
    res.send('Bookshelf API');
});

app.get('/books', async (req, res) => {
    const filter = {};
    if (req.query.author) {
        filter.author = req.query.author;
    }
    if (req.query.from || req.query.to) {
        filter.year = {};
        if (req.query.from) {
            filter.year.$gte = Number(req.query.from);
        }
        if (req.query.to) {
            filter.year.$lte = Number(req.query.to);
        }
    }
    const list = await books.find(filter).toArray();
    res.json(list);
});

app.post('/books', async (req, res) => {
    const book = req.body;
    try {
        await books.insertOne(book);
    } catch (err) {
        if (err.code === 11000) {
            return sendError(res, 409, 'That ISBN is already on the shelf');
        }
        throw err;
    }
    res.status(201).json(book);
});

app.get('/books/newest', async (req, res) => {
    const n = Number(req.query.n) || 3;
    const list = await books
        .find({}, { projection: { title: 1, year: 1, _id: 0 } })
        .sort({ year: -1 })
        .limit(n)
        .toArray();
    res.json(list);
});

app.get('/books/:id', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const book = await books.findOne({ _id: id });
    if (!book) {
        return sendError(res, 404, 'No such book');
    }
    res.json(book);
});

app.patch('/books/:id', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const result = await books.updateOne({ _id: id }, { $set: req.body });
    if (result.matchedCount === 0) {
        return sendError(res, 404, 'No such book');
    }
    res.json(await books.findOne({ _id: id }));
});

app.post('/books/:id/copies', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const result = await books.updateOne({ _id: id }, { $inc: { copies: 1 } });
    if (result.matchedCount === 0) {
        return sendError(res, 404, 'No such book');
    }
    res.json(await books.findOne({ _id: id }));
});

app.post('/books/:id/tags', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const result = await books.updateOne({ _id: id }, { $push: { tags: req.body.tag } });
    if (result.matchedCount === 0) {
        return sendError(res, 404, 'No such book');
    }
    res.json(await books.findOne({ _id: id }));
});

app.delete('/books/:id', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const result = await books.deleteOne({ _id: id });
    if (result.deletedCount === 0) {
        return sendError(res, 404, 'No such book');
    }
    res.status(204).end();
});

app.put('/books/:id/ratings', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const { user, stars } = req.body;
    await ratings.updateOne({ bookId: id, user }, { $set: { stars } }, { upsert: true });
    res.json({ user, stars });
});

app.get('/books/:id/ratings', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    res.json(await ratings.find({ bookId: id }).toArray());
});

app.get('/stats', async (req, res) => {
    const filter = req.query.genre ? { genre: req.query.genre } : {};
    res.json({
        books: await books.countDocuments(filter),
        ratings: await ratings.countDocuments(),
    });
});

app.get('/stats/genres', async (req, res) => {
    const genres = await books
        .aggregate([{ $group: { _id: '$genre', count: { $sum: 1 } } }])
        .toArray();
    res.json(genres);
});

app.get('/stats/top', async (req, res) => {
    const top = await ratings
        .aggregate([
            { $group: { _id: '$bookId', avg: { $avg: '$stars' }, count: { $sum: 1 } } },
            { $match: { count: { $gte: 2 } } },
            { $sort: { avg: -1 } },
            { $limit: 3 },
        ])
        .toArray();
    res.json(top);
});

app.get('/books/:id/full', async (req, res) => {
    const id = parseId(req, res);
    if (!id) return;
    const [book] = await books
        .aggregate([
            { $match: { _id: id } },
            {
                $lookup: {
                    from: 'authors',
                    localField: 'author',
                    foreignField: 'name',
                    as: 'authorInfo',
                },
            },
        ])
        .toArray();
    if (!book) {
        return sendError(res, 404, 'No such book');
    }
    res.json(book);
});

app.listen(3000, () => {
    console.log('Bookshelf is running on port 3000');
});

Latihan sendiri: Playground Express

Paginasi di database

Semua pelajaran di Database dengan MongoDB