如何在没有回调的情况下返回Mongoose查询结果

Question

我有一个结构化的应用程序:index> routes> endpoints> core,其中端点处理发送响应的请求,核心访问数据库.将控制器划分为这两个组件的部分原因是为了在数据库更改后使工作正常工作,并部分简化我的代码.问题是我只能通过回调在我的模块中获得mongoose查询函数的结果,这根本不会简化我的代码.
我想要的是:

var user = coreModule.findUser({id:123}) //return user
var posts = coreModule.findPosts({author:123}) //return posts array
res.render("home", {user:user, posts:posts})

通过做:

//core module example
findUser: function(params){
   User.findOne(params, function(err,docs){
      if(err){
         return err
      }else{
         return docs
      }
   }
}

但相反,我必须使用一堆回调函数,这些函数首先会破坏核心模块的一半用途.我已经看到你可以用SQL和Knex做到这一点,但它不适用于mongoose.如果我想做的事情是不可能的,那么在这种情况下是否会推荐使用猫鼬替代品？

Answer 1

使用Async/Await语法:

const findUser = async function (params) { 
    try {  return await User.findOne(params)
    } catch(err) { console.log(err) }
}

const userSteve = findUser({firstName: Steve})

每次需要使用Query中的信息时,请await在async函数中使用前缀.这将允许您在需要查询结果继续的同步代码中使用Mongoose查询的异步特性.

对于你的代码:

coreModule.findUser  = async function (userId) { 
    return await User.findOne({id:_userId})
}

coreModule.findPosts = async function(authorId) {
    return await Posts.find({postedBy: authorId})
}

const foundUser = coreModule.findUser(123);
const foundPosts = coreModule.findPosts(123);
res.send({user: foundUser, posts: foundPosts}) 

如果您希望同时启动两个查询,则可以使用 Promise.all()

coreModule.findUser  =  function (userId) { 
    return User.findOne({id:_userId})
}

coreModule.findPosts = function(authorId) {
    return Posts.find({postedBy: authorId})
}

const [foundUser, foundPosts] = 
   await Promise.all(
         [coreModule.findUser(123), coreModule.findPosts(123)]
   ); 

res.send({user: foundUser, posts: foundPosts})

如果您的API中的两个查询都位于不同的EndPoints,您还可以构建两个针对两个端点的获取请求,并使用Promise.all()在客户端同时触发这些请求

我希望这有帮助!

编辑:我已经使用我在API中测试的这个工作示例编辑了我的帖子:

module.exports.test = async function(req, res, next) {
    const module1 = function(params) {
        return ShoppingCartModel.find({_id: params})
    }
    const module2 = function(params) {
        return User.find({_id: params})
    }
    const array = [module1('5a739dbc45424d2904faca5b'), module2('5a739dbc45524d2904faca5b')]
    const promise = await Promise.all(array)
    res.json(promise)
}

一些错误回报的例子:

不正确:

const array = [ShoppingCartModel.find({}), ShoppingCartModel.find({})]
// console.log(array) = Mongoose Query Constructors
const promise = Promise.all(array)
// console.log(promise) = Promise { <pending> }

正确:

const array = [ShoppingCartModel.find({}), ShoppingCartModel.find({})]
const promise = await Promise.all(array)

不正确:

// Return full fledged promise from Mongoose query using .exec()
const array = [ShoppingCartModel.find({}).exec(), ShoppingCartModel.find({}).exec()]
// console.log(array) = [ Promise { <pending> }, Promise { <pending> } ]
const promise = Promise.all(array)
// console.log(promise) = Promise { <pending> }

正确:

const array = [ShoppingCartModel.find({}).exec(), ShoppingCartModel.find({}).exec()]    
const promise = await Promise.all(array)

您必须等待结果Promise.all,否则您的函数将通过函数调用,将空JSON对象发送回前端,以及未给予时间解决的console.log待处理承诺