데이터베이스 페이지네이션

Coddy Node.js 여정의 MongoDB 데이터베이스 섹션에 포함된 레슨. 29개 중 27번째.

책 1만 권이 있는 서가의 내용을 한 번의 응답으로 모두 보낼 수는 없습니다. 클라이언트는 한 번에 한 페이지씩 요청하고, 데이터베이스는 해당 페이지에 있는 내용만 보내야 합니다.

skip(n)은 처음 n개의 일치 항목을 건너뛰고, limit(n)은 그다음 n개를 가져옵니다. 1페이지는 처음부터 시작하므로, p페이지는 (p - 1) * size만큼 건너뜁니다. 클라이언트가 페이지 수를 알 수 있도록, 페이지와 함께 같은 필터로 계산한 전체 개수도 보내세요.

// 오류 로그의 3페이지, 페이지당 20개 항목
const entries = await log
    .find({ level: 'error' })
    .skip((3 - 1) * 20)
    .limit(20)
    .toArray();
const total = await log.countDocuments({ level: 'error' });

챌린지

쉬움

책이 만 권 있는 책장은 한 번의 응답으로 모두 보낼 수 없습니다. 이제 GET /books는 한 번에 한 페이지씩 보냅니다. 또한 조건에 맞는 전체 책의 수도 알려 주므로, 클라이언트에서 "page 1 of 5"를 표시할 수 있습니다.

server.js에서 GET /books를 변경하세요. author, from, to 필터는 유지하세요.
?page=(기본값 1)와 ?limit=(기본값 10)을 읽으세요. 둘 중 하나라도 없거나 숫자가 아니면 기본값을 사용하세요. 페이지 1은 첫 번째 책부터 시작하므로, 페이지 p에서는 책을 (p - 1) * limit개 건너뛴 다음, 이어서 limit개의 책을 반환합니다. 건너뛰기와 자르기는 데이터베이스에서 처리하게 하세요.
같은 필터를 사용해 데이터베이스에서 total을 세세요. 이 값은 현재 페이지에 있는 책만이 아니라 조건에 맞는 모든 책을 셉니다.
배열이 아닌 객체를 상태 코드 200으로 응답하세요. GET /books?limit=2의 반환값:

{
  "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
}

직접 해 보기:

GET /books?limit=2

"total": 3

GET /books?limit=2&page=2

"total": 3

GET /books?limit=2&page=3

"items": []

"total": 3

GET /books?author=Jane%20Austen&limit=1

"total": 1

GET /books

items

직접 해보기

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

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

// 모든 오류는 { error: message } 형식으로 응답합니다.
function sendError(res, status, message) {
    res.status(status).json({ error: message });
}

// :id를 ObjectId로 반환하거나, 잘못된 id에 대해 400으로 응답한 뒤 null을 반환합니다.
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');
});

직접 연습해 보세요: Express 플레이그라운드

데이터베이스 페이지네이션

MongoDB 데이터베이스의 모든 레슨