node.js - 如何让 updatemany 验证每个修改文档的 Mongoose 模式？

Question

我在尝试验证 Model::updateMany(或 update + mutli:true)请求内修改的文档架构时遇到了 Mongoose 架构验证问题。我有以下架构:

  var BusinessesSchema = new Schema({
    label: {
      type: String,
      required: true
    },
    openingDate: {
      type: Date,
      required: true
    },
    endingDate: {
      type: Date,
      validate: function(value) {
        if (this.constructor.name === 'Query') {
          // Looks like this is a validation for update request
          var doc = null;
          switch (this.op) {
            case 'update':
            case 'updateMany': {
              doc = this._update.$set;
              break;
            }
            case 'findOneAndUpdate': {
              doc = this._update;
              break;
            }
            default:
            // keep null, will throw an error
          }
          return doc.openingDate < value;
        }
        else {
          return this.openingDate < value;
        }
      }
    }
  });

我想访问endingDate::validate函数中的修改文档值(“this”)，以确保每个修改文档的结束日期大于开始日期。

甚至，当使用 pre-hook(用于 update 和 updateMany，如下)时，我仍然找不到任何方法来访问修改后的文档值以在设置 multi 时(或调用 updateMany 时)执行检查。

BusinessesSchema.pre('update', function(next) {
  this.options.runValidators = true;
  this.options.context = 'query';
  next();
});

BusinessesSchema.pre('updateMany', function(next) {
  this.options.runValidators = true;
  this.options.context = 'query';
  next();
});

我可能错过了一些东西，非常感谢这里的帮助。

Answer 1

不能这样做。使用 updateMany 可以做的最好的事情就是从 this 捕获查询上下文，并分析更新。像这样的事情:

Schema.pre('updateMany', function (next) {
    const update = this.getUpdate();
    if (update.$set && update.$set && !validateUpdate(update.$set)) {
        throw new Error('Invalid Update');
    }
    next();
});

如果您想在更新之前使用 save Hook 对结果文档进行验证，您可以使用游标:

Schema.pre('save', function(next) {
    if (!validDoc(this)) {
        throw new Error('Invalid Doc');
    }
    next();
}
Schema.statics.updateManyWithValidation = async function(criteria, update) {
        const cursor = Model.find(criteria).cursor();
        let doc = null;
        do {
            doc = await cursor.next();
            Object.assign(doc, update);
            await doc.save();
         } while(doc != null);
    }

现在，请记住，这是一个昂贵得多的操作，因为您要获取文档、应用更改，然后单独保存它们。