mongodbの別のオブジェクトにオブジェクトをプッシュするときにエラーが発生しました

debugcn 投稿 Dev

アレクサンドルベーリング

req.body.coursesには、特定のカテゴリに追加したいコースの複数のIDがあります。問題は、コードを実行すると、ループの数に応じて、コースが1回以上、場合によっては4〜5回保存されることです。します。

関数：

router.post('/categories/:cat_id/', function (req, res) {
    Categorie.findById(req.params.cat_id, function(err, categorie){
    if(err){
      console.log(err);
    } else {
      var courses = req.body.courses;
      courses.forEach(function (course){
          Course.findOne({  _id:  course }, function(err, foundCourse) {
              if(err){
                  console.log(err);
              } else {
                  categorie.courses.push(foundCourse._id);
                  categorie.save();
              }
          });
      });
    }
  });
  return res.redirect('/dash');
});

CategorieSchema：

var categorieSchema = mongoose.Schema({
   name: String,
   courses: [
        {
            type: mongoose.Schema.Types.ObjectId,
            ref: "Course"
        }    
    ]
});

カテゴリに4つのコースを追加しようとする例を次に示します。

{ "_id" : ObjectId("5a871964a6b4820ecf7abaa7"), "courses" : [ ObjectId("5a870a7374486e0b0d69f710"), ObjectId("5a870a7a74486e0b0d69f711"), ObjectId("5a870a6974486e0b0d69f70f"),   
 ObjectId("5a870a7374486e0b0d69f710"), ObjectId("5a870a7a74486e0b0d69f711"), ObjectId("5a870a6974486e0b0d69f70f"), 
 ObjectId("5a870a7374486e0b0d69f710"), ObjectId("5a870a7a74486e0b0d69f711"), ObjectId("5a870a6974486e0b0d69f70f") ], "name" : "test2", "__v" : 3 }

ラーフルシャルマ

Node.jsは非同期です。ループが完全に実行されるのを待たず、既存の配列に_idを追加するたびに、2〜3回追加されます。

これをテストしていない場合は、これを試してください。

const findOne = (course) => {
    return new Promise((resolve, reject) => {
        Course.findOne({
            _id: course
        }, (err, foundCourse) => {
            if (err)
                return reject(err);
            return resolve(foundCourse._id);
        });
    });
}

router.post('/categories/:cat_id/', function (req, res) {
    Categorie.findById(req.params.cat_id, function (err, categorie) {
        if (err) {
            console.log(err);
            res.status(400).json(err);
        } else {
            var courses = req.body.courses;

            Promise.all(courses.map((course) => {
                return findOne(course);
            })).then((data) => {
                // check if course id already there skip
                data = data.filter((course) => {
                    return !categorie.courses.includes(course);
                });
                categorie.courses = categorie.courses.concat(data);
                categorie.save();
                return res.redirect('/dash');
            }).catch((err) => {
                console.log(err);
                res.status(400).json(err);
            });
        }
    });
});

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]