Mongoose存储用户专属药品后，无法按用户维度拉取对应药品的问题

核心问题根因 #

• MedsSchema 未声明 userId 字段是最主要的触发原因
  Mongoose 默认会过滤Schema定义外的字段，当查询时传入未在Schema中声明的userId作为匹配条件，该条件会被直接忽略，查询退化为全量拉取所有药品文档，自然返回所有用户的数据。
• 保存逻辑异步流程混乱：当前代码在newMed.save()的回调中直接返回接口响应，后续更新用户关联档案的逻辑未纳入统一异步流程，极易出现关联关系写入失败、数据不一致的问题。

具体调整步骤 #

1. 补全MedsSchema字段定义
   现有代码在新增药品时传入了userId，但如果Schema中未声明该字段，Mongoose会自动过滤该写入值，查询时也不会识别对应的过滤条件。需在药品Schema中补充如下定义：

const medsSchema = new mongoose.Schema({
  userId: {
    type: mongoose.Schema.Types.ObjectId,
    ref: 'User',
    required: true,
    index: true // 为单用户查询加索引，提升检索性能
  },
  medName: String,
  medDescription: String,
  dose: String,
  medType: String,
  date: String,
  time: String
});
const MedsSchema = mongoose.model('MedsSchema', medsSchema);

2. 修正药品保存的异步流程
   调整原逻辑的执行顺序，确保所有数据库操作完成后再返回接口响应，避免提前返回导致的关联写入异常：

const {userId, medName, medDescription, dose, medType, date, time} = req.body;
try {
  // 第一步：持久化药品数据，拿到带合法_id的新文档
  const newMed = await MedsSchema.create({
    userId,
    medName,
    medDescription,
    dose,
    medType,
    date,
    time,
  });

  // 第二步：更新对应用户的药品关联数组，仅存药品ObjectId即可，无需存整个文档
  await User.findByIdAndUpdate(
    userId,
    { $push: { medicines: newMed._id } },
    { new: true }
  );

  // 全流程完成后再返回成功响应
  res.send({response: 'ok'});
} catch (err) {
  res.status(500).send(err.message);
}

原代码修正点：

• 移除提前返回响应的逻辑，等所有关联操作执行完成后再返回结果
• 用户的medicines数组仅存储药品的_id，由后续populate操作自动拉取完整药品数据，避免冗余存储整个文档造成的数据不一致
• 移除冗余的findOne + populate测试日志逻辑，减少无意义的数据库查询

3. 修正药品列表查询接口
   保证查询条件完全匹配，避免参数或类型不匹配导致的过滤失效。可根据业务关联设计选择两种查询方式：

• 方式一：基于Meds表的userId字段过滤（和现有代码逻辑对齐）

router.get('/getMeds/:userId', async (req, res) => {
  // 先校验入参是否为合法MongoDB ObjectId，避免非法查询
  if (!mongoose.isValidObjectId(req.params.userId)) {
    return res.status(400).send('非法用户ID');
  }
  try {
    // 按userId严格过滤，仅返回当前用户的药品
    const meds = await MedsSchema.find({ userId: req.params.userId }).sort({date: -1, time: -1});
    res.send(meds);
  } catch (err) {
    res.status(500).send(err.message);
  }
});

• 方式二：基于用户档案的关联数组拉取（和UserSchema的populate设计对齐）

router.get('/getMeds/:userId', async (req, res) => {
  if (!mongoose.isValidObjectId(req.params.userId)) {
    return res.status(400).send('非法用户ID');
  }
  try {
    const user = await User.findById(req.params.userId).populate('medicines');
    res.send(user.medicines);
  } catch (err) {
    res.status(500).send(err.message);
  }
});

额外排查校验点 #

• 接口调用时确认路由参数传入的用户ID和当前登录用户ID一致，避免前端传参错误
• 比对数据库中Meds表实际存储的userId值和查询入参的类型、格式是否完全匹配，避免出现类型不匹配导致的过滤失效
• 长期维护建议避免双写冗余关联：如果采用Meds表存userId做隔离的方案，可移除UserSchema中的medicines数组字段，减少不必要的写入开销

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