MongoDB

Question

我需要运行使用 node.js 驱动程序并行针对 MongoDB 的多个查询。

目前我正在使用一个计数器，它会在查询完成时减少。当计数器达到 0 时，这意味着所有查询都已完成，然后我关闭数据库连接。

在具有 2 个查询的简单情况下运行并行执行代码如下

var mongodb = require('mongodb');
var MongoClient = require('mongodb').MongoClient;
var db;

MongoClient.connect("mongodb://localhost:27017/company", function(err, database) {
    if(err) throw err;
    db = database;

    let collection = "resumes";
    let numberOfParallelQueries = 2;
    let result = [];
    let finalCallback = (err, resp) => {
        if (err) throw(err);
        numberOfParallelQueries = numberOfParallelQueries -1;
        result.push(resp);
        if (numberOfParallelQueries == 0) {
            console.log(result);
            db.close()
        };
    }
    db.collection(collection).find({"jobs": {$elemMatch: {"company": "CNA", position: "director"}}}).toArray(finalCallback);
    db.collection(collection).find({$and: [{"jobs.company": "CNA"}, {"jobs.position": "director"}]}).toArray(finalCallback);
});

我的问题是有没有更优雅的解决方案。我正在考虑 Observable.

的 forkJoin() 方法中的一些东西

提前致谢

Answer 1

这就是 Promises 的用途：

var mongodb = require('mongodb');
var MongoClient = require('mongodb').MongoClient;
var db;

MongoClient.connect("mongodb://localhost:27017/company", function(err, database) {
    if(err) throw err;
    db = database;

    let collection = "resumes";
    Promise.all([
        queryPromise(collection, {"jobs": {$elemMatch: {"company": "CNA", position: "director"}}}),
        queryPromise(collection, {$and: [{"jobs.company": "CNA"}, {"jobs.position": "director"}]})

    ]).then(function(result) {
        // result is an array of responses here
        db.close();
    }).catch(function(err) {
        console.log(err);
        db.close();
    });


    function queryPromise(collection, query) {
        return new Promise(function(resolve, reject) {
            db.collection(collection).find(query).toArray(function(err, resp) {
                if (err) {
                    reject(err);
                } else {
                    resolve(resp);
                }
            });
        })
    }
});

Answer 2

使用async/await更简单

var mongodb = require('mongodb');
var MongoClient = require('mongodb').MongoClient;
var db;

MongoClient.connect("mongodb://localhost:27017/company", function(err, database) {
    if(err) throw err;
    db = database;

    let collection = "resumes";

    let queries = [];
    queries.push(async()=>await db.collection(collection).find({"jobs": {$elemMatch: {"company": "CNA", position: "director"}}}).toArray());
    queries.push(async()=>await db.collection(collection).find({$and: [{"jobs.company": "CNA"}, {"jobs.position": "director"}]}).toArray());

    Promise.all( 
      queries
    ).then(function(result) {
        // result is an array of arrays of queries responses here
        db.close();
    }).catch(function(err) {
        console.log(err);
        db.close();
    });
});

MongoDB - 运行使用 nodejs 驱动程序并行查询并在最后一个查询完成时关闭数据库连接

MongoDB - running parallel queries with nodejs driver and close the db connection when the last query completes

node.js

observable

MongoDB - 运行 使用 nodejs 驱动程序并行查询并在最后一个查询完成时关闭数据库连接

MongoDB - running parallel queries with nodejs driver and close the db connection when the last query completes

mongodb

node.js

observable

MongoDB - 运行使用 nodejs 驱动程序并行查询并在最后一个查询完成时关闭数据库连接