问题:如何在不回调的情况下返回 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。如果我想做的事情是不可能的,在这种情况下是否有推荐的猫鼬替代品?

解答

使用异步/等待语法:

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

const userSteve = findUser({firstName: Steve})

每次需要使用查询中的信息时,请在async函数中使用await前缀。这将允许您在需要该查询结果继续的同步代码中使用 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 中的两个查询都位于不同的端点,您还可以构造两个针对两个端点的获取请求,并使用 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 未给定时间解决的未决承诺