MongoDBでカーソルを使用してコレクションをループ処理する方法

MongoDBでは、find()メソッドが返すカーソルを利用することで、コレクション内のドキュメントを1件ずつ効率的に反復処理できます。この記事では、カーソルの基本的な仕組みと、hasNext()およびnext()メソッドを使ったループ処理の具体的な手順を解説します。

カーソルでコレクションをループさせる基本構文

カーソルを使ってコレクションを反復処理する場合、基本的な構文は以下の通りです。

var anyVariableName1;
var anyVariableName2 = db.yourCollectionName.find();
while (yourVariableName2.hasNext()) {
    yourVariableName1 = yourVariableName2.next();
    printjson(yourVariableName1);
};

この構文のポイントは以下の3点です。

• hasNext(): カーソルにまだ未読のドキュメントが残っているかどうかを判定します。
• next(): カーソルから次のドキュメントを1件取得し、内部の位置を進めます。
• printjson(): 取得したドキュメントを見やすいJSON形式で出力します。

サンプルコレクションの作成

まずは動作確認用のコレクションを作成しましょう。以下のクエリを実行して、ドキュメントを挿入します。

> db.loopThroughCollectionDemo.insertOne({"StudentName":"John","StudentAge":23});
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5c9ca81f2d6669774125247f")
}
> db.loopThroughCollectionDemo.insertOne({"StudentName":"Larry","StudentAge":21});
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5c9ca8272d66697741252480")
}
> db.loopThroughCollectionDemo.insertOne({"StudentName":"Chris","StudentAge":25});
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5c9ca8462d66697741252481")
}
> db.loopThroughCollectionDemo.insertOne({"StudentName":"Robert","StudentAge":24});
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5c9ca8632d66697741252482")
}

これで、学生名（StudentName）と年齢（StudentAge）を含む4件のドキュメントが登録されました。

find()メソッドですべてのドキュメントを表示する

登録したドキュメントを確認するために、find()メソッドにpretty()を組み合わせて実行します。

> db.loopThroughCollectionDemo.find().pretty();

実行すると、以下のような出力が得られます。

{
    "_id" : ObjectId("5c9ca81f2d6669774125247f"),
    "StudentName" : "John",
    "StudentAge" : 23
}
{
    "_id" : ObjectId("5c9ca8272d66697741252480"),
    "StudentName" : "Larry",
    "StudentAge" : 21
}
{
    "_id" : ObjectId("5c9ca8462d66697741252481"),
    "StudentName" : "Chris",
    "StudentAge" : 25
}
{
    "_id" : ObjectId("5c9ca8632d66697741252482"),
    "StudentName" : "Robert",
    "StudentAge" : 24
}

カーソルを使った実際のループ処理

それでは、カーソルを使ってコレクションをループ処理してみましょう。以下のクエリを実行します。

> var allDocumentValue;
> var collectionName = db.loopThroughCollectionDemo.find();
> while (collectionName.hasNext()) {
...     allDocumentValue = collectionName.next();
...     printjson(allDocumentValue);
... }

まず変数collectionNameにfind()の結果として得られるカーソルを格納し、whileループ内でhasNext()がtrueを返す限り、next()でドキュメントを取り出しては出力していきます。

実行結果は以下の通りです。

{
    "_id" : ObjectId("5c9ca81f2d6669774125247f"),
    "StudentName" : "John",
    "StudentAge" : 23
}
{
    "_id" : ObjectId("5c9ca8272d66697741252480"),
    "StudentName" : "Larry",
    "StudentAge" : 21
}
{
    "_id" : ObjectId("5c9ca8462d66697741252481"),
    "StudentName" : "Chris",
    "StudentAge" : 25
}
{
    "_id" : ObjectId("5c9ca8632d66697741252482"),
    "StudentName" : "Robert",
    "StudentAge" : 24
}

このように、カーソルを経由することでコレクション内の全ドキュメントを1件ずつ順番に処理できることが確認できました。条件に応じた個別処理や集計など、柔軟なデータ操作に活用できます。