我有一个结构化的应用程序:索引 > 路由 > 端点 > 核心,其中端点处理请求以发送响应,核心访问数据库。将 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 替代品可以推荐?
最佳答案
使用 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 没有时间解决
https://stackoverflow.com/questions/48601249/
相关文章:
node.js - Mongoose 类型错误 : User is not a constructo
mongodb - 要将一条记录与 MongoDB 中的另一条记录相关联,可以使用 slug 吗?
java - Mongo 将 Document 转换为 DBObject
c# - ReadBsonType 只能在 State 为 Type 时调用,不能在 State 为
java - Spring MongoTemplate - 将聚合结果映射到集合(例如 List 和
mongodb - 使用 mongodb 聚合的多个字段的不同计数
json - 使用 Python 从 MongoDB 文档创建 JSON 文件
node.js - 使用 winston-mongodb 和 express-winston 进行日