몽구스 채우기 ObjectId 배열 찾기

Question

몽구스로 찾기를 수행 할 때 ObjectId 배열을 채우려고합니다. 여기

는 models/comment.js이다 : 여기

var mongoose = require('mongoose'); 
var Schema = mongoose.Schema; 
var Comment = require('./comment'); 


// set up a mongoose model 
var QuestionSchema = new Schema({ 
    title: { 
     type: String, 
     unique: false, 
     required: true 
    }, 
    question: { 
     type: String, 
     required: true 
    }, 
    plus: { 
     type: Number, 
     required: true, 
     default: 0 
    }, 
    minus: { 
     type: Number, 
     required: true, 
     default: 0 
    }, 
    date: { 
     type: Date, 
     default: new Date() 
    }, 
    comments:[ 
     {type: Schema.Types.ObjectId, ref: 'Comment'} 
    ] 
}); 

module.exports = mongoose.model('Question', QuestionSchema); 

index.js

var express  = require('express'); 
var app   = express(); 
var request  = require('request-promise'); 
var bodyParser = require('body-parser'); 
var morgan  = require('morgan'); 
var mongoose = require('mongoose'); 
var passport  = require('passport'); 
var config  = require('./config/database'); // get db config file 
var User  = require('./models/user'); // get the mongoose model 
var Room  = require('./models/room'); // get the mongoose model 
var Comment = require('./models/comment'); // get the mongoose model 
var Question = require('./models/question'); // get the mongoose model 
var port  = process.env.PORT || 5000; 
var jwt   = require('jwt-simple'); 
var http  = require('http'); 
var io   = require('socket.io'); 
var server  = http.createServer(app); 
var io   = io.listen(server); 



// get our request parameters 
app.use(bodyParser.urlencoded({ extended: false })); 
app.use(bodyParser.json()); 

// log to console 
app.use(morgan('dev')); 

// Use the passport package in our application 
app.use(passport.initialize()); 

// Set the port 
app.set('port', port); 

//App files located in /public 
app.use(express.static(__dirname + '/public')); 

// views is the directory for all template files 
app.set('views', __dirname + '/views'); 
app.set('view engine', 'ejs'); 

// The root url of the website serves the Angular app 
app.get('/', function (request, response) { 
    response.render('pages/index'); 
}); 

// connect to database 
mongoose.connect(config.database); 

// pass passport for configuration 
require('./config/passport')(passport); 

var roomService = require('./controllers/roomservice.js'); 
roomService.setup(io); 

// connect the api routes under /api/* 
app.use('/api', apiRoutes); 

// Start the Express app 
server.listen(app.get('port'), function() { 
    console.log('Node app is running on port', app.get('port')); 
}); 

여기

controllers/roomservice.js

이다 : 여기

var mongoose = require('mongoose'); 
var Schema = mongoose.Schema; 

// set up a mongoose model 
var CommentSchema = new Schema({ 
    comment: { 
     type: String, 
     unique: false, 
     required: true 
    }, 
    date: { 
     type: Date, 
     default: new Date() 
    }, 
}); 

module.exports = mongoose.model('Comment', CommentSchema); 

은 models/question.js이고

function RoomService(){ 
    var socketio; 
    var Comment = require('../models/comment'); // get the mongoose model 
    var Question = require('../models/question'); // get the mongoose model 
    var Room = require('../models/room'); // get the mongoose model 

    function setup(io){ 
     socketio = io; 
     socketio.on("connection", function(socket){ 
      socket.on('joinRoom', function(msg){ 
       console.log("joinRoom"); 
       socket.join(msg.room) 
       Question.find({}) 
        .exec(function(err, questions) { 
         for(var question in questions){ 
          for(var comment in questions[question].comments){ 
           questions[question].comments[comment] = Comment.find({ "_id": questions[question].comments[comment]}); 
          } 
         } 
         socket.emit("listQuestions", questions) 
       }); 
      }); 
      socket.on('addQuestion', function(msg){ 
       console.log("addQuestion"); 
       var question = new Question({ 
        title: msg.title, 
        question: msg.question 
       }); 
       // save the question 
       question.save(function(err) { 
        if (err) throw err; 
        io.to(msg.room).emit("addQuestion", question); 
       }); 
      }); 
      socket.on('addComment', function(msg){ 
       var comment = new Comment({ 
        comment: msg.comment 
       }); 
       // save the comment 
       Question.findOne({_id: msg.question}, function(err, question){ 
        if (err) throw err; 
        question.comments.push(comment); 
        question.save(function(err) { 
         if (err) throw err; 
         io.to(msg.room).emit("addComment", comment); 
         console.log(question); 
        }); 
       }); 
      }); 
      socket.on('addPlus', function(msg){ 
       // save the comment 
       Question.findOne({_id: msg.question}, function(err, question){ 
        if (err) throw err; 
        question.plus = question.plus + 1; 
        question.save(function(err) { 
         if (err) throw err; 
         io.to(msg.room).emit("addPlus", question); 
        }); 
       }); 
      }); 
      socket.on('addMinus', function(msg){ 
       // save the comment 
       Question.findOne({_id: msg.question}, function(err, question){ 
        if (err) throw err; 
        question.minus = question.minus + 1; 
        question.save(function(err) { 
         if (err) throw err; 
         io.to(msg.room).emit("addMinus", question); 
        }); 
       }); 
      }); 
     }); 
    } 

    return{ 
     setup: setup 
    } 
} 

module.exports = new RoomService(); 

질문 목록을 반환 할 때 주석 배열을 채우려고합니다. Mongoose에서 populate 메서드로 시도했지만 주석 배열이 반환됩니다.

[{"title": "test", "comments": ["1253454", "654654747"]}, 
{"title": "test", "comments": ["1253454", "654654747"]}] 

그러나 나는 이런 식으로 뭔가 원하는 : 내가 잘못

[{"title": "test", "comments": [{"comment": "test"}, {"comment": "test2"}]}, 
{"title": "test", "comments": [{"comment": "test"}, {"comment": "test2"}]}] 

를하고있는 중이 야 무엇을

Question.find({}).populate("comments") 
        .exec(function(err, questions) { 

         socket.emit("questions", questions) 
       }); 

나는 이런 식으로 뭔가를 얻을 수 채우기 방법을 넣어하지 않는 경우?

Answer 1

당신의 몽구스 버전은 무엇입니까? 버전 4.7.1 나를 위해 괜찮 :

import { connDb } from './base'; 
import { model, Schema, SchemaTypes, disconnect } from 'mongoose'; 

const Question = model<any>('Question', new Schema({ 
    title : SchemaTypes.String, 
    comments: [ 
    { 
     type: SchemaTypes.ObjectId, 
     ref : 'Comment', 
    }, 
    ], 
})) 
const Comment = model<any>('Comment', new Schema({ 
    comment: SchemaTypes.String, 
})) 

connDb().then(() => Promise.all([ 
    Comment.remove({}), 
    Question.remove({}), 
])).then(() => Comment.insertMany([ 
    { 
    comment: 'hello', 
    }, 
    { 
    comment: 'world', 
    } 
])).then((data: any[]) => Question.insertMany([ 
    { 
    title : 'question', 
    comments: data.map((item: any) => item._id), 
    } 
])).then(() => Question.find({}).populate('comments').exec()).then((d) => { 
    console.log(JSON.stringify(d)) 
}).then(() => disconnect()) 

결과는 다음`mongoose.model` 부분에서

+ ts-node ./src/__test__/pop_comment.ts 
[{"_id":"5846322e69db6c1ec86ac5fd","__v":0,"title":"question","comments":[{"_id":"5846322e69db6c1ec86ac5fb","__v":0,"comment":"hello"},{"_id":"5846322e69db6c1ec86ac5fc","__v":0,"comment":"world"}]}]