MongoDB修改City集合时自动更新Customer中嵌入BaseCity字段方案咨询

MongoDB本身没有原生机制能自动同步嵌入到其他集合的文档与源集合数据，因为嵌入是数据冗余存储，而非实时关联引用。针对你用Mongoose + TypeScript的场景，以下是几种可行的实现方案：

方案一：Mongoose 后置中间件自动同步 #

利用Mongoose的post中间件，在City文档完成修改（保存/更新）后，批量更新所有关联该City的Customer文档中的BaseCity字段。

修改你的City.schema，添加后置中间件：

@Schema({ collection: 'city', virtuals: true, _id: false })
export class City {
  @Prop({ type: String })
  imageName: string;
  @Prop({ index: true, type: String })
  enName: string;
  @Prop({ type: String, unique: true })
  instagram: string;
}

// 获取City的Mongoose模型
const CityModel = model(City.name, schemaFactory.createForClass(City));

// 添加post-save中间件，处理文档新增/修改后的同步
CityModel.post('save', async function(doc) {
  // 更新所有关联该City的Customer文档
  await model(Customer.name).updateMany(
    { 'city._id': doc._id }, // 匹配Customer中city的_id等于当前City的_id
    { 
      $set: {
        'city.enName': doc.enName // 同步更新enName字段
      }
    }
  );
});

// 添加post-update中间件，处理批量更新后的同步
CityModel.post('updateOne', async function() {
  // 获取更新后的City文档数据
  const updatedCity = await this.model.findOne(this.getQuery());
  if (!updatedCity) return;
  
  await model(Customer.name).updateMany(
    { 'city._id': updatedCity._id },
    { $set: { 'city.enName': updatedCity.enName } }
  );
});

注意：

• 中间件需要确保Customer模型已经被正确注册，避免找不到模型的问题。
• 如果你的City有多个需要同步的字段，只需在$set中添加对应字段即可。
• 批量更新可能会有性能开销，若数据量极大，建议给city._id字段添加索引优化查询。

方案二：改用引用而非嵌入（避免同步需求） #

如果业务场景允许，可以将Customer中的city字段改为引用City集合的ObjectId，而非嵌入BaseCity。这样查询Customer时通过populate获取最新的City数据，无需手动同步：

修改Customer.schema：

@Schema({ collection: 'customer', validateBeforeSave: true, timestamps: true })
export class Customer extends Document {
  // ...其他字段保持不变
  
  @Prop({ ref: City.name, type: Types.ObjectId }) // 改为引用City模型
  cityId: Types.ObjectId;
}

// 查询时获取完整City数据
const customerWithCity = await model(Customer.name)
  .findOne({ _id: customerId })
  .populate('cityId', 'enName _id'); // 只返回需要的字段，对应原BaseCity的内容

这种方式的优势是无需维护数据同步，始终获取最新的City数据，但查询时会多一次关联查询，适合对数据实时性要求高、但查询频率不极端的场景。

方案三：业务层手动触发同步 #

如果你的City修改操作集中在特定业务逻辑里，可以在修改City的代码后，直接调用Customer的更新逻辑，这种方式更灵活，适合小范围的修改场景：

// 修改City的业务代码
async function updateCity(cityId: string, updateData: Partial<City>) {
  const updatedCity = await model(City.name).findByIdAndUpdate(
    cityId,
    updateData,
    { new: true } // 返回更新后的文档
  );
  
  if (updatedCity) {
    // 同步更新Customer中的对应字段
    await model(Customer.name).updateMany(
      { 'city._id': cityId },
      { $set: { 'city.enName': updatedCity.enName } }
    );
  }
  
  return updatedCity;
}

内容的提问来源于stack exchange，提问作者Amir Mohammad Beheshti