使用多个参考数据库问题更新数据库

Question

我对猫鼬/快递很陌生。我正在努力尝试从 html 表单更新新数据并将其保存到具有引用的数据库中。我有一个位置参考位置模型的商业模型。这是代码。

edit.ejs

<div class="container">
    <div class="form-container">
        <form action="/<%= bus._id %>?_method=PUT" method="POST">
            <!-- business info -->
            <h3>Business Information</h3>
            <input class="form-input" type="input" name="bus[logo]" value="<%= bus.logo %>">
            <input class="form-input" type="input" name="bus[name]" value="<%= bus.name %>">
            <% bus.location.forEach(function(location) { %>
            <input class="form-input" type="input" name="bus.location[street]" value="<%= location.street %>">
            <input class="form-input" type="input" name="bus.location[city]" value="<%= location.city %>">
            <div class="state-input">
                <select class="form-inline" name="bus.location[state]">
                    <option value="" disabled selected><%= location.state %></option>
                    <option value="AL">Alabama</option>
                    ...
                    <option value="WY">Wyoming</option>
                </select>   
            </div><!--State-input -->
            <input class="form-inline" type="input" name="bus.location[zipcode]" value="<%= location.zipcode %>">
            <% }) %>
            <!--Contact info-->
            <h4>Contact Information</h4>
            <% bus.contact.forEach(function(contact) { %>
            <input class="form-input" type="url" name="bus[url]" value="<%= bus.url %>">
            <input class="form-input" type="email" name="bus.contact[email]" value="<%= contact.email %>">
            <input class="form-input" type="tel" name="bus.contact[phone]" value="<%= contact.phone %>">
            <input class="form-input" type="input" name="bus.contact[twitter]" value= "<%= contact.twitter %>">
            <input class="form-input" type="input" name="bus.contact[facebook]" value="<%= contact.facebook %>">
            <input class="form-input" type="input" name="bus.contact[instagram]" value="<%= contact.instagram %>">
            <% }) %>

index.js - 编辑路线

//(edit.ejs) Edit Route 
app.get('/:id/edit', function(req, res) {
    Business.findById(req.params.id)
    .populate('location')
    .populate('contact')
    .populate('images')
    .exec(function(err, bus) {
        if(err) {
            console.log(err);
        } else {
            res.render('edit', {bus:bus});
        }
    });
});
app.put('/:id', function(req, res) {
    Business.findByIdAndUpdate(req.params.id, req.body.bus, function(err, bus) {
        if(err) {
            console.log(err);
            res.redirect('/' + req.params.id + '/edit');
        } else {
            res.redirect('/' + req.params.id);
        }
    });
});

业务（巴士）更新良好，但 bus.location 没有更新。 商业模式

//----------------------------------------------------------------------------\\
var mongoose = require('mongoose');
//----------------------------------------------------------------------------\\
var busSchema = new mongoose.Schema({
    name: String,
    type: String,
    logo: String,
    desc: String,
    subs: Number,
    video: String,
    url: String,
    firstRun: Boolean,
    location:[ 
      {
         type: mongoose.Schema.Types.ObjectId,
         ref: 'Location'
      }
    ],
    contact:[
      {
         type: mongoose.Schema.Types.ObjectId,
         ref: 'Contact'
      }
    ],
    images:[
      {
         type: mongoose.Schema.Types.ObjectId,
         ref: 'Image'
      }
    ],
    comments:[
      {
         type: mongoose.Schema.Types.ObjectId,
         ref: 'Comment'
      }   
    ],
    created: {
       type: Date, default: Date.now
    }
});
//----------------------------------------------------------------------------\\
module.exports = mongoose.model('Business', busSchema);

位置模型

//----------------------------------------------------------------------------\\
var mongoose = require('mongoose');
//----------------------------------------------------------------------------\\
var locSchema = new mongoose.Schema(
    {
        street: String,
        city: String,
        state: String,
        zipcode: Number
    }  
);
//----------------------------------------------------------------------------\\
module.exports = mongoose.model('Location', locSchema);

Answer 1

Business、Location 和 Contact 是不同的集合。

findByIdAndUpdate 只更新一个集合，特别是您的集合Business。为了更新其他集合，您需要对这些集合执行操作。

如果您尝试更新“现有”位置和联系人，那么您还需要提供他们的 ID。此外，您有一个“数组”位置和联系人，因此您需要在姓名中添加 []。

<% bus.location.forEach(function(location, i) { %>
    <input type="hidden" name="location[<?= i ?>][id]" value="<%= location.id %>">
    <input class="form-input" type="input" name="location[<?= i ?>][street]" value="<%= location.street %>">
    <!-- etc -->
<% }) %>

<% bus.contact.forEach(function(contact, i) { %>
    <input type="hidden" name="contact[<?= i ?>][id]" value="<%= contact.id %>">
    <input class="form-input" type="email" name="contact[<?= i ?>][email]" value="<%= contact.email %>">
    <!-- etc -->
<% }) %>

根据我（和others）的经验，我认为不可能一次更新多个文档。这意味着，在您的路由处理程序中，您将需要遍历给定数组中的每个项目并逐一更新它们。不过，另一篇文章中的答案不太正确，因为您不应该使用同步 forEach 来执行异步猫鼬操作，因为它会导致意外行为。

您需要完成三项主要任务：更新业务、更新其现有位置以及更新其现有联系人。

我喜欢使用async.js 来执行多个异步操作。在您的特定情况下，我将使用 async.series 执行每个任务，并使用 async.eachSeries 对数组的每个元素执行操作。

警告这是未经测试的，但看起来像这样：

app.put('/:id', function(req, res) {

    console.log(req.body.bus);
    console.log(req.body.location); // should be an array of objects
    console.log(req.body.contact); // should be an array of objects

    // perform each task one by one
    async.series([
        function updateBusiness (done) {
            // you need to always call the callback i.e. done to indicate the task is "done"
            // - if you pass an error as an argument, it means the task failed and stop everything
            // - otherwise, move onto the next task

            /*Business.findByIdAndUpdate(req.params.id, req.body.bus, function (err) {
                if (err) {
                    return done(err); // task failed and stop everything
                }
                done(); // task went well and proceed to the next task
            });*/

            // simplified
            Business.findByIdAndUpdate(req.params.id, req.body.bus, done);
        },
        function updateLocations (done) {
            // find and update each location
            async.eachSeries(req.body.location || [], function (location, done2) {
                Location.findByIdAndUpdate(location.id, location, done2);
            }, done);
        },
        function updateContacts (done) {
            // find and update each contact
            async.eachSeries(req.body.contact || [], function (contact, done2) {
                Contact.findByIdAndUpdate(contact.id, contact, done2);
            }, done);
        }
    ], function allDone (err) {
        // a task failed somewhere
        if (err) {
            console.log(err);
            res.redirect('/' + req.params.id + '/edit');
        // all tasks were completed
        } else {
            res.redirect('/' + req.params.id);
        }
    });
});

如果有错误，请查看控制台日志。