我有一个函数调用连接到我数据库中的两个集合，它将它存储在两个数组中，但我无法访问它

Question

我建立了一个连接到两个集合并将其存储在两个数组中，但我无法访问它，因为它是异步的。

此外，我还想执行类似于从学生中选择滚动的操作

db.student.find（{},{roll:1,_id:0}）；

但实现这一点并不奏效，它只是从集合中获取所有内容。

我试过使用Async/Await，但它不起作用。

我尝试实现async（npm模块），并使用async.Series方法，但没有成功。

对console.log使用setTimeout记录值，但我需要执行一些比较，因此没有帮助。

    let collectionOneArr = [];
    let collectionTwoArr = [];

    let db = client.db('job');

    db.collection('one').find({}, {field:1, name: 0}).toArray((err, data) => {
        data.forEach(val => collectionOneArr.push(val))
    });

    db.collection('two').find({}).toArray((err,data) => {
        data.forEach(val => collectionTwoArr.push(val))
    });

   console.log(collectionOneArr) // returns []
   console.log(collectionTwoArr) // returns []

//    setTimeout(() => console.log(collectionTwoArr, collectionOneArr), 1000);

    client.close();    
});

Answer 1

了解存储在数据库中的对象是什么样子会很有帮助，但无论如何，我将尝试回答这个问题。

有两个问题，我可以看到。

1. 您没有正确查询
2. 您需要使用JavaScript的异步特性:)

1.mongo过滤不正确

您似乎没有按照正确的顺序向find方法提供参数，实际上也没有告诉mongo根据任何内容进行筛选。

mongodb find方法的第一个参数是filter对象。这将正确地过滤：

db.collection('one').find({field:1, name: 0}).toArray((err, 
  data.forEach(val => collectionOneArr.push(val))
});

2.异步问题

例如，我们可以使用readyforcompute标志来确保只在两个数据库查询完成后运行compute方法。这是一个非常原始的解决方案，不能很好地扩展，但仅足以执行2个查询。

let readyForCompute = false;
let arr1 = [];
let arr2 = [];

let db = client.db('job');

db.collection('one').find({name: "value_to_filter_name_field_by"}).toArray((err, data) => {
    arr1 = data;
    if (readyForCompute) compute();
    readyForCompute = true;
});

db.collection('two').find({}).toArray((err,data) => {
    arr2 = data;
    if (readyForCompute) compute();
    readyForCompute = true;
});

function compute() {
    client.close();
    console.log(arr1);
    console.log(arr2);
    // do your computation...
}