NodeJS回调无法获取记录：Postman传邮箱无法获取MongoDB数据求助

我帮你梳理下代码里的关键问题，一步步修复就能解决拿不到数据的情况：

1. 核心问题：MongoDB连接的异步处理缺失 #

你的connection()函数里，MongoClient.connect是异步操作，但函数没有等待连接完成就直接返回了。这会导致调用get()时，dbo可能还没被赋值（依然是null），自然查不到任何数据。

2. 数据库对象调用错误 #

你写的get().dbo.coll...存在语法问题：get()已经返回了数据库实例dbo，不需要再额外加.dbo，直接调用.collection()即可。

3. 查询逻辑未完整实现 #

exports.email函数没有完整实现根据邮箱过滤数据的逻辑，也没有处理异步查询的结果，无法正确返回或打印数据。

修正后的完整代码（mongoconnect.js） #

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
var dbo = null;

// 用Promise封装连接逻辑，确保连接完成后再操作数据库
exports.connection = function() {
  return new Promise((resolve, reject) => {
    if (dbo !== null) {
      resolve(dbo);
      return;
    }
    MongoClient.connect(url, function(err, db) {
      if (err) {
        reject(err);
        return;
      }
      dbo = db.db("hospital_api");
      resolve(dbo);
    });
  });
};

// 确保获取到可用的数据库实例
var get = function() {
  return exports.connection();
};

// 实现根据邮箱查询数据的函数，接收邮箱参数并返回查询结果
exports.getEmailData = async function(email) {
  try {
    const db = await get();
    // 替换成你实际的集合名称，比如假设集合叫"users"
    const collection = db.collection("users");
    // 根据邮箱查询单条数据，若要查多条可改用find().toArray()
    const data = await collection.findOne({ email: email });
    return data;
  } catch (err) {
    throw err;
  }
};

配套的请求处理代码（示例：Express路由） #

如果用Express处理Postman请求，需要这样写路由逻辑：

const express = require('express');
const router = express.Router();
const mongoConnect = require('./mongoconnect');

router.get('/fetch-by-email', async (req, res) => {
  try {
    // 从Postman的URL查询参数中获取邮箱，比如：http://localhost:3000/fetch-by-email?email=test@example.com
    const email = req.query.email;
    if (!email) {
      return res.status(400).send('请提供邮箱参数');
    }
    // 查询数据并打印到控制台
    const data = await mongoConnect.getEmailData(email);
    console.log('查询到的MongoDB数据:', data);
    // 将数据返回给Postman
    res.json(data);
  } catch (err) {
    console.error('查询出错:', err);
    res.status(500).send('服务器内部错误');
  }
});

module.exports = router;

Postman测试步骤 #

1. 选择GET请求，输入URL：http://localhost:你的服务端口/fetch-by-email?email=你要查询的邮箱地址
2. 点击「Send」，控制台会打印查询到的JSON数据，同时Postman界面也会返回对应结果

额外注意事项 #

• 确保MongoDB服务已启动（运行mongod命令）
• 确认hospital_api数据库存在，且目标集合中包含带email字段的数据
• 如果用POST请求传参，可将req.query.email改为req.body.email，并在Postman中选择「Body」->「x-www-form-urlencoded」或「raw JSON」传递参数

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