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

Question

我有一个结构化的应用程序:索引 > 路由 > 端点 > 核心，其中端点处理请求以发送响应，核心访问数据库。将 Controller 分为这两个组件的目的部分是为了在数据库更改后使事情正常工作，部分是为了简化我的代码。问题是我只能通过回调在我的模块中获取 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。如果我想做的事情是不可能的，在这种情况下是否有 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})

每次您需要使用查询中的信息时，请在 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 待处理的 promise 没有时间解决