如何使用Mongoose实现多条件查询及新增数据去重校验

嗨，我来帮你搞定这个问题！你现在用嵌套回调的方式分别校验邮箱和用户名是否重复，不仅容易陷入“回调地狱”，代码可读性差，还可能存在并发场景下的竞态问题（比如两个请求同时校验通过，最终插入重复数据）。下面给你几种更优雅且可靠的实现方案：

方案一：利用MongoDB唯一索引（推荐，最可靠高效） #

最稳妥的方式是直接在Mongoose Schema层面给需要唯一的字段添加唯一索引，让数据库层面直接拦截重复数据，同时我们可以通过捕获索引冲突错误来返回对应的提示。

步骤1：在Schema中配置唯一约束 #

const mongoose = require('mongoose');

const userSchema = new mongoose.Schema({
  email: {
    type: String,
    required: true,
    unique: true // 标记邮箱为唯一字段
  },
  username: {
    type: String,
    required: true,
    unique: true // 标记用户名为唯一字段
  },
  // 其他字段（如密码、昵称等）...
});

const User = mongoose.model('User', userSchema);

步骤2：保存时捕获重复错误并返回对应提示 #

当插入重复数据时，MongoDB会返回错误码11000，我们可以通过解析错误对象里的keyPattern来判断是哪个字段重复：

app.post('/register', async (req, res) => {
  try {
    const newUser = new User(req.body);
    await newUser.save();
    res.send('用户创建成功！');
  } catch (err) {
    // 处理唯一索引冲突错误
    if (err.code === 11000) {
      const duplicateField = Object.keys(err.keyPattern)[0];
      if (duplicateField === 'email') {
        return res.send('该邮箱已被使用，请更换其他邮箱！');
      } else if (duplicateField === 'username') {
        return res.send('该用户名已被占用，请更换其他用户名！');
      }
    }
    // 处理其他未知错误
    res.send('出现了一些错误，请稍后重试！');
  }
});

这种方案的优势是原子性，数据库会保证校验和插入是一个原子操作，完全避免并发竞态问题，性能也比手动查询高很多。

方案二：用Async/Await避免嵌套回调（适合自定义校验逻辑） #

如果你需要更灵活的校验逻辑（比如除了唯一性还要加其他规则），可以用async/await来扁平化代码，代替嵌套回调：

app.post('/register', async (req, res) => {
  try {
    // 先检查邮箱是否存在
    const existingEmail = await User.findOne({ email: req.body.email });
    if (existingEmail) {
      return res.send('该邮箱已被使用，请更换其他邮箱！');
    }

    // 再检查用户名是否存在
    const existingUsername = await User.findOne({ username: req.body.username });
    if (existingUsername) {
      return res.send('该用户名已被占用，请更换其他用户名！');
    }

    // 校验通过，保存新用户
    const newUser = new User(req.body);
    await newUser.save();
    res.send('用户创建成功！');
  } catch (err) {
    res.send('出现了一些错误，请稍后重试！');
  }
});

方案三：用Promise.all并行查询（提升查询效率） #

如果想让邮箱和用户名的校验并行执行，节省时间，可以用Promise.all：

app.post('/register', (req, res) => {
  // 同时发起两个查询请求
  const checkEmailPromise = User.findOne({ email: req.body.email });
  const checkUsernamePromise = User.findOne({ username: req.body.username });

  Promise.all([checkEmailPromise, checkUsernamePromise])
    .then(([existingEmail, existingUsername]) => {
      if (existingEmail) {
        return res.send('该邮箱已被使用，请更换其他邮箱！');
      }
      if (existingUsername) {
        return res.send('该用户名已被占用，请更换其他用户名！');
      }

      // 校验通过，保存用户
      const newUser = new User(req.body);
      return newUser.save();
    })
    .then(() => res.send('用户创建成功！'))
    .catch(err => res.send('出现了一些错误，请稍后重试！'));
});

注意事项 #

• 方案二和三虽然代码更清晰，但无法完全避免并发竞态问题（比如两个请求同时通过校验，最终插入重复数据），所以如果对数据唯一性要求很高，优先选方案一。
• 如果你是在已有数据库上添加唯一索引，需要确保现有数据没有重复值，否则索引创建会失败。

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