节点js eachOf循环中的mongodb查询

const async = require('async');
const MongoClient = require('mongodb').MongoClient;

// MongoDB连接URL
const url = 'mongodb://localhost:27017/mydatabase';

// 定义要查询的集合和查询条件
const collectionName = 'mycollection';
const query = { name: 'John' };

// 执行eachOf循环
async.eachOf(query, (value, key, callback) => {
  // 连接到MongoDB数据库
  MongoClient.connect(url, (err, client) => {
    if (err) {
      callback(err);
      return;
    }

    // 获取集合
    const db = client.db();
    const collection = db.collection(collectionName);

    // 执行查询
    collection.find({ [key]: value }).toArray((err, result) => {
      if (err) {
        callback(err);
        return;
      }

      // 处理查询结果
      console.log(result);

      // 关闭数据库连接
      client.close();

      // 调用回调函数，表示当前迭代完成
      callback();
    });
  });
}, (err) => {
  if (err) {
    console.error(err);
    return;
  }

  console.log('All queries completed.');
});