mongoose多层嵌套查询,怎么变为链式操作或者编程不嵌套
如果mongoose的查询需要嵌套多层(下面我只写了3层),并且下一层的查找需要上一层的查询结果,可能还会有其他操作,这样写起来会很乱,不易维护,怎么去变为链式的调用,避免多层嵌套。
var Article = mongoose.model('Article');
var User = mongoose.model('User');
var Comment = mongoose.model('Comment');
app.get("/article/:id",function(req,res,next){
Article.find({_id:req.parems.id},function(err,article){
if(err){console.log(err)}
User.findOne({_id:article.author},function(err,user){
if(err){console.log(err)}
Comment.find({userId:user._id},function(err,comment){
if(err){console.log(err)}
res.redirect("/")
})
})
})
})
我尝试这么去写
var Article = mongoose.model('Article');
var User = mongoose.model('User');
var Comment = mongoose.model('Comment');
app.get("/article/:id",function(req,res,next){
var funMain = function(){//主函数
Article.find({_id:req.parems.id},function(err,article){
if(err){console.log(err)}
fun2(article.author)
})
}
var fun2 = function(author){//根据文章作者id查询用户
User.findOne({_id:author},function(err,user){
if(err){console.log(err)}
fun3(user._id)
})
}
var fun3 = function(userId){//根据用户id查询评论
Comment.find({userId:userId},function(err,comment){
if(err){console.log(err)}
res.redirect("/") //重定向
})
}
funMain()
})
不知道有没有其他更好的方法
3 回复
这个是 Node.js 本身的回调问题,跟 Mongoose 关系不太大,使用 Mongoose 关联查询可以将有关系的表查询结构简化一下,归根到底是要解决回调问题,现有很多方式,自行搜索吧。
thenjs / async 就是干这事的
来自酷炫的 CNodeMD
Promise
var Article = mongoose.model('Article');
var User = mongoose.model('User');
var Comment = mongoose.model('Comment');
app.get("/article/:id", (req, res, next) => {
Article.find({_id:req.parems.id})
.then((article) => {
return User.findOne({_id:article.author})
})
.then((user) => {
return omment.find({userId:user._id})
})
.then((comment) => {
res.redirect("/")
})
.catch((err) => {
console.log(err);
res.status(500).json(err);
})
})
Mongoose本身就是支持Promise的,不过像现在的话使用Co+Generator或者Async/Await是更加愉快的写法
var Article = mongoose.model('Article');
var User = mongoose.model('User');
var Comment = mongoose.model('Comment');
app.get("/article/:id", (req, res, next) => {
co(function* (){
let article = yield Article.find({_id:req.parems.id})
let user = User.findOne({_id:article.author})
return yield comment.find({userId:user._id})
})
.then((comment) => {
res.redirect("/")
})
.catch((err) => {
console.log(err);
res.status(500).json(err);
})
})