MongoDB阻止重复值录入问题：重复注册拦截失效

嘿，我看你在做用户注册功能的时候遇到重复注册的问题了，咱们一步步拆解解决这个事儿～

首先得指出你代码里一个容易被忽略的严重问题：你把router.post('/form')嵌套在router.get('/')的回调里了！这会导致每次用户访问首页（GET /）时，都会重复注册一次post路由，时间久了同一个请求会被多次处理，肯定会出各种奇怪的问题，先把这个结构调整过来，把post路由移到get路由外面，这是基础！

接下来回到重复注册的核心问题：你之前尝试的createIndex/ensureIndex和find方法本身是对的，但大概率是没在正确的时机执行，或者异步逻辑没处理好，导致没生效。咱们分两步来解决：

第一步：给邮箱字段创建唯一索引（数据库层面的保障） #

不管代码逻辑怎么写，数据库层面的唯一索引是阻止重复数据的最后一道防线。你需要在启动应用时（或者第一次连接数据库时）创建这个索引，而不是在注册请求里临时创建。比如在你的路由文件里添加这段代码（放在路由定义之外）：

// 只执行一次，给Email字段创建唯一索引
mongo.connect(url, function(err, db) {
  if (err) throw err;
  db.collection('user').createIndex(
    { Email: 1 },
    { unique: true },
    function(err, indexName) {
      if (err) {
        console.log("唯一索引创建失败（可能已存在）：", err);
      } else {
        console.log("唯一索引创建成功：", indexName);
      }
      db.close();
    }
  );
});

第二步：修改注册逻辑，先检查用户是否存在再插入 #

你原代码是直接插入用户，完全没做前置检查，咱们改成先查询邮箱是否已注册，再决定是否插入：

var express = require('express');
var router = express.Router();
var mongo = require('mongodb').MongoClient;
var request = require('request');
var bodyParser = require('body-parser');
var url = 'mongodb://localhost/ibs';
var async = require('async');
var session = require('express-session');
var code = require('./verificationCode');

// 正确的路由结构：GET和POST路由分开定义
router.get('/', function (req, res, next) {
  res.render('information');
});

router.post('/form', function (req, res) {
  var name = req.body.name;
  var surname = req.body.surname;
  var phone = req.body.phone;
  var email = req.body.email;
  var verCode = code.code();

  mongo.connect(url, function(err, db) {
    if (err) {
      console.error("数据库连接失败：", err);
      return res.status(500).send("数据库连接出错，请稍后重试");
    }

    var userCollection = db.collection('user');

    // 用findOne查询是否存在该邮箱的用户，异步操作必须在回调里处理结果
    userCollection.findOne({ Email: email }, function(err, existingUser) {
      if (err) {
        console.error("查询用户失败：", err);
        db.close();
        return res.status(500).send("查询用户信息出错");
      }

      if (existingUser) {
        // 邮箱已注册，返回提示
        db.close();
        return res.send("该邮箱已经注册过啦，请换个邮箱试试～");
      }

      // 用户不存在，准备插入数据
      var person = {
        Name: name,
        Surname: surname,
        Phone: phone,
        Email: email,
        verCode: verCode
      };

      // 用insertOne替代旧的insert方法，语义更明确
      userCollection.insertOne(person, function(err, result) {
        db.close();
        if (err) {
          console.error("插入用户失败：", err);
          // 针对唯一索引冲突的错误，给出精准提示
          if (err.code === 11000) {
            return res.send("该邮箱已经注册过啦");
          }
          return res.status(500).send("注册失败，请稍后重试");
        }
        res.redirect('/congratulations');
      });
    });
  });
});

module.exports = router;

为什么你之前的方法没成功？ #

• 关于Promise { <pending> }：如果你用了新版驱动的Promise API，但没加await或者.then()等待异步操作完成，就会得到pending的Promise。比如db.collection('user').find({Email: email})返回的是游标，不是Promise，而find().toArray()会返回Promise，必须等待它resolve才能拿到结果。
• 关于拿到完整文档：如果用find()而不是findOne()，它返回的是游标对象，直接打印会显示很多无关信息，需要用toArray()转换成数组才能拿到实际的用户数据。

最后提个小建议：尽量升级到新版MongoDB驱动（v4+），它支持async/await语法，异步逻辑会更清晰，不容易出错～

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