$groupでグループ化する
CoddyのNode.jsジャーニー「MongoDBによるデータベース」セクションの一部。レッスン 21/29。
1つのジャンルを数えるのは1回のクエリです。すべてのジャンルを一度に数えるには、データベースで本をグループに分類する必要があります。
aggregate はパイプラインを実行します。パイプラインはステージの配列で、各ステージは出力を次のステージに渡します。$group ステージは、_id の値が異なるものごとに1つの出力ドキュメントを作成します。ここでの _id はドキュメントの ID ではありません。何を基準にグループ化するかを示し、各出力ドキュメントではその値が _id に格納されます。フィールド名の前に $ を付けた '$team' は、「このドキュメントにあるそのフィールドの値」を意味します。付けなければ、'team' はすべてのドキュメントで同じテキストなので、すべて1つのグループに入ります。$sum: 1 はドキュメントごとに1を加算します。
await players
.aggregate([{ $group: { _id: '$team', players: { $sum: 1 } } }])
.toArray();
// [{ _id: 'red', players: 4 }, { _id: 'blue', players: 3 }]グループ化の結果には、その _id と、アキュムレーターが計算したフィールドだけが含まれます。入力ドキュメントのその他のフィールドは引き継がれません。
チャレンジ
簡単このステップでは、Counting Documents のプロジェクトファイル（server.js を含む）ではなく、コース用に用意された本棚 API プロジェクトを開きます。以前の作業は、前のレッスンにそのまま残っています。server.js を編集する前に、提供されたファイルを読んでください。このコピーには、本棚の CRUD ルート、一意な ISBN インデックス、GET /books のフィルター、GET /stats の件数が含まれています。
ジャンルのページでは、1 回のクエリですべてのジャンルの本の数を表示します。誰も想定していなかったジャンルも含まれます。
server.jsにGET /stats/genresルートを追加します。booksに対して、$groupステージを 1 つ使って集計を実行します。ジャンルごとに 1 つの結果を作り、そのジャンルの本の数を含めます。- ステータス 200 と、集計で返される配列を応答として返します。各項目では、ジャンルが
_idに、本の数がcountに格納されます。$group内の_idは ObjectId ではなく、本をグループ化する基準となった値です。項目の順序は任意です。スターターの本を使った場合、応答は次のようになります：試してみましょう：[ { "_id": "scifi", "count": 2 }, { "_id": "classic", "count": 1 } ]GET /stats/genresを送信すると、上記の 2 つの項目が返されます。{ "title": "Leaves of Grass", "author": "Walt Whitman", "year": 1855, "isbn": "9780140421996", "genre": "poetry" }を含むPOST /booksを送信すると、201 が返されます。もう一度GET /stats/genresを送信すると、{ "_id": "poetry", "count": 1 }という 3 つ目の項目が表示されます。
自分で試してみよう
import express from 'express';
import { MongoClient, ObjectId } from 'mongodb';
const client = new MongoClient('mongodb://localhost:27017');
const db = client.db('shelf');
const books = db.collection('books');
const ratings = db.collection('ratings');
await books.createIndex({ isbn: 1 }, { unique: true });
await books.insertMany([
{ title: 'Dune', author: 'Frank Herbert', year: 1965, isbn: '9780441013593', genre: 'scifi' },
{ title: 'Kindred', author: 'Octavia E. Butler', year: 1979, isbn: '9780807083697', genre: 'scifi' },
{ title: 'Emma', author: 'Jane Austen', year: 1815, isbn: '9780141439587', genre: 'classic' },
]);
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.listen(3000, () => {
console.log('Bookshelf is running on port 3000');
});
MongoDBによるデータベースのすべてのレッスン
自分で練習してみよう: Expressプレイグラウンド