如何通过表单使用UpdateOne批量更新多条MongoDB数据？

问题场景 #

需要通过单个按钮提交所有物料的编辑数据，以原始Descripcion作为匹配条件（隐藏字段DescripcionBusqueda）更新对应MongoDB文档，要求仅修改用户输入了值的字段，不覆盖未修改的内容，但当前前后端逻辑存在问题，导致更新逻辑混乱。

当前代码 #

前端表单代码 #

<form
  action="/EdicionMaterialesPost"
  method="POST"
  enctype="multipart/form-data"
>
  <% for (var a = 0; a < materiales.length; a++) { %>
  <tr>
    <th>
      <%=materiales[a].Descripcion%>
      <input
        type="text"
        class="form-control"
        placeholder="Descripcion"
        id="Descripcion"
        name="Descripcion"
      />
      <input
        type="hidden"
        class="form-control"
        id="DescripcionBusqueda"
        name="DescripcionBusqueda"
        value="<%=materiales[a].Descripcion%>"
      />
    </th>
    <th>
      <%=materiales[a].Codigo%>
      <input
        type="text"
        class="form-control"
        placeholder="Codigo"
        id="Codigo"
        name="Codigo"
      />
    </th>
    <th>
      <%=materiales[a].Unidad%>
      <input
        type="text"
        class="form-control"
        placeholder="Unidad"
        id="Unidad"
        name="Unidad"
      />
    </th>
    <th>
      <%=materiales[a].PrecioUnitario%>
      <input
        type="number"
        class="form-control"
        placeholder="PrecioUnitario"
        id="PrecioUnitario"
        name="PrecioUnitario"
      />
    </th>
    <th>
      <%=materiales[a].Familia%>
      <input
        type="text"
        class="form-control"
        placeholder="Familia"
        id="Familia"
        name="Familia"
      />
    </th>
    <th>
      <%=materiales[a].SubFam%>
      <input
        type="text"
        class="form-control"
        placeholder="SubFam"
        id="SubFam"
        name="SubFam"
      />
    </th>
  </tr>
  <% } %>
  <button type="submit" id="sendMessageButton">Guardar Cambios</button>
</form>

原后端代码 #

const material = require('../models/materiales.js');
const path = require('path');

module.exports = async (req, res) => {
  for (i = 0; i < req.body.DescripcionBusqueda.length; i++) {
    await material.updateOne(
      { Descripcion: req.body.DescripcionBusqueda[i] },
      {
        $set: {
          Descripcion: req.body.Descripcion[i],
          Codigo: req.body.Codigo[i],
          Unidad: req.body.Unidad[i],
          PrecioUnitario: req.body.PrecioUnitario[i],
          Familia: req.body.Familia[i],
          SubFam: req.body.SubFam[i],
        },
      },
      { upsert: false }
    );
  }

  res.redirect('/');
};

MongoDB文档示例 #

{
  _id: ObjectId('6396d947f3a8a9fa8c3c7727'),
  Descripcion: "Angulo 1/8\" x 1 1/4\" de 6.10 mts. (1.50 kg/mt)",
  Codigo: "AA-03",
  Unidad: "Pza.",
  PrecioUnitario: 260.84,
  Familia: "Aceros",
  SubFam: "Angulos",
  __v: 0
}

优化方案 #

1. 前端表单核心修改 #

• 结构化name属性：将表单控件的name改为materiales[<%=a%>].字段名，让后端直接拿到数组形式的物料数据，避免多个独立数组的索引匹配错误。
• 唯一化id属性：给每个输入框的id添加循环索引后缀（如Descripcion_<%=a%>），避免DOM中id重复导致的操作异常。
• 填充默认值：将原始数据填入输入框的value属性，用户未修改时提交原始值，也可留空配合后端判断是否需要更新。

修改后的前端表单关键部分：

<% for (var a = 0; a < materiales.length; a++) { %>
<tr>
  <th>
    <%=materiales[a].Descripcion%>
    <input
      type="text"
      class="form-control"
      placeholder="Descripcion"
      id="Descripcion_<%=a%>"
      name="materiales[<%=a%>].Descripcion"
      value="<%=materiales[a].Descripcion%>"
    />
    <input
      type="hidden"
      id="DescripcionBusqueda_<%=a%>"
      name="materiales[<%=a%>].DescripcionBusqueda"
      value="<%=materiales[a].Descripcion%>"
    />
  </th>
  <!-- 其他字段同理修改name和id -->
</tr>
<% } %>

2. 后端逻辑优化 #

• 处理结构化请求数据：直接遍历req.body.materiales数组，每个元素对应一条物料的编辑数据。
• 动态构建更新字段：仅将用户有输入（或与原始值不同）的字段加入$set，避免覆盖未修改内容。
• 异步操作优化：用Promise.all批量执行更新提升性能，添加错误处理避免服务器崩溃。

优化后的后端代码：

const material = require('../models/materiales.js');
const path = require('path');

module.exports = async (req, res) => {
  try {
    const materiales = req.body.materiales;
    await Promise.all(
      materiales.map(async (item) => {
        const updateFields = {};
        // 仅添加需要更新的字段
        if (item.Descripcion && item.Descripcion !== item.DescripcionBusqueda) {
          updateFields.Descripcion = item.Descripcion;
        }
        if (item.Codigo) updateFields.Codigo = item.Codigo;
        if (item.Unidad) updateFields.Unidad = item.Unidad;
        // 数字类型需特殊判断，避免0被判定为空
        if (item.PrecioUnitario !== undefined) {
          updateFields.PrecioUnitario = parseFloat(item.PrecioUnitario);
        }
        if (item.Familia) updateFields.Familia = item.Familia;
        if (item.SubFam) updateFields.SubFam = item.SubFam;

        // 有更新字段才执行操作
        if (Object.keys(updateFields).length > 0) {
          await material.updateOne(
            { Descripcion: item.DescripcionBusqueda },
            { $set: updateFields },
            { upsert: false }
          );
        }
      })
    );
    res.redirect('/');
  } catch (error) {
    console.error('更新物料失败:', error);
    res.status(500).send('更新物料时发生错误');
  }
};

关键优化点说明 #

• 解决索引匹配问题：结构化数组避免了原代码中多个独立数组索引不一致导致的更新错误。
• 精准更新字段：动态构建updateFields，只修改用户输入的内容，不覆盖未改动的字段。
• 提升性能与稳定性：Promise.all并行执行更新，添加try-catch捕获异常，避免服务器崩溃。

内容的提问来源于stack exchange，提问作者Aaron Rodriguez