カーソルからデータにアクセスする

非同期反復

Cursors implement the AsyncIterator interface, which allows you to use cursors in for await...of loops:

  const cursor = myColl.find({});
  console.log("async");
  for await (const doc of cursor) {
    console.log(doc);
  }

手動反復

hasNext() メソッドを使用して、カーソルがさらにデータを取得できるかどうかを確認し、次に next() メソッドを使用して、カーソルの次の要素を取得します。

  const cursor = myColl.find({});
  while (await cursor.hasNext()) {
    console.log(await cursor.next());
  }

すべてのドキュメントの配列を返す

For use cases that require all documents matched by a query to be held in memory at the same time, use the toArray() method. Note that large numbers of matched documents can cause performance issues or failures if the operation exceeds memory constraints. Consider using the for await...of syntax to iterate through results rather than returning all documents at once.

  const cursor = myColl.find({});
  const allValues = await cursor.toArray();

ストリーム API

カーソルは、ノード読み取り可能ストリームに変換するための stream() メソッドを公開します。これらのストリームは オブジェクト モードで 動作し、バッファーや文字列ではなく JavaScript オブジェクトをパイプラインに渡します。

  const cursor = myColl.find({});
  cursor.stream().on("data", doc => console.log(doc));

イベント API

読み取り可能なストリームとして、カーソルは Event API の close、 data、 end、および readable イベントもサポートしています。

  const cursor = myColl.find({});
  // the "data" event is fired once per document
  cursor.on("data", data => console.log(data));

巻き戻す

返されたドキュメントのセット内のカーソルを最初の位置にリセットするには、rewind(). を使用します。

  const cursor = myColl.find({});
  const firstResult = await cursor.toArray();
  console.log("First count: " + firstResult.length);
  await cursor.rewind();
  const secondResult = await cursor.toArray();
  console.log("Second count: " + secondResult.length);

閉じる

カーソルは、クライアントアプリケーションとMongoDBの接続インスタンスの両方でメモリーとネットワーク リソースを消費します。次の例に示すように、 close() を使用して、クライアントアプリケーションとMongoDB Server の両方でカーソルのリソースを解放します。

  await cursor.close();

リソースリークを防ぐために、アプリケーションが使用しなくなったカーソルを手動で閉じることをお勧めします。

中止

中止シグナルを使用してカーソル操作をキャンセルできます。これにより、カーソルが使用していたメモリやネットワーク リソースが不要になった場合に解放され、リソースを管理しやすくなります。

signal コマンドを次のメソッドに渡すことができます。

• collection.find()

• collection.findOne()

• collection.aggregate()

• collection.countDocuments()

• db.listCollections()

• db.command()

中止信号を使用するには、AbortController インスタンスを作成し、コントローラーから signal を抽出します。このコード例では、プロセスは SIGINT（Ctrl+C）をリッスンして abort() メソッドをトリガーします。シグナルがトリガーされた場合にカーソル操作を中止するには、次の例に示すように、signal オプションを find() メソッドに渡すことができます。

  const controller = new AbortController();
  const { signal } = controller;
  process.on('SIGINT', () => controller.abort(new Error('^C pressed')));
  try {
    const cursor = myColl.find({}, { signal });
    for await (const doc of cursor) {
      console.log(doc);
    }
  } catch (error) {
    if (error === signal.reason) {
      console.error('Operation aborted:', error);
    } else {
      console.error('Unexpected error:', error);
    }
  }