如何不使用回调函数获取Mongoose查询结果？

我完全懂你这种被嵌套回调折磨的心情——本来想通过index > routes > endpoints > core的分层让代码更模块化、更容易适配数据库变更，结果Mongoose的回调逻辑反而把core层搞得臃肿又难读，完全违背了简化代码的初衷。别担心，咱们用Promise + Async-Await就能彻底解决这个问题，这也是当前Node.js处理异步操作的标准方案，能让你的分层架构真正发挥作用。

为什么回调会拖垮你的分层 #

先复盘一下问题：原来的core层用回调获取Mongoose查询结果，会导致代码嵌套层级深、错误处理分散，比如这样：

// 糟糕的回调式core层
const getUserById = (userId, callback) => {
  User.findById(userId, (err, user) => {
    if (err) {
      console.error("DB error:", err);
      return callback(err);
    }
    if (!user) {
      return callback(new Error("User not found"));
    }
    callback(null, user);
  });
};

这种写法不仅不简洁，而且当你需要修改数据库操作（比如换ORM、调整查询逻辑）时，还要同时修改回调结构，完全达不到“适配数据库变更”的分层目的。

第一步：把Mongoose查询改成Promise风格 #

其实Mongoose从4.0版本开始就原生支持Promise，不需要额外引入任何库。你只需要去掉回调参数，直接返回Mongoose查询对象（或者用.exec()确保返回标准Promise，更稳妥）：

// 清爽的Promise风格core层
const getUserById = (userId) => {
  // 直接返回查询的Promise，Mongoose会自动处理异步逻辑
  return User.findById(userId).exec();
};

// 带业务逻辑的示例：比如查询后做简单处理
const getActiveUsers = () => {
  return User.find({ isActive: true })
    .select("-password") // 排除敏感字段
    .sort({ createdAt: -1 })
    .exec();
};

这样core层就彻底专注于数据库操作本身，没有多余的回调嵌套，逻辑一目了然。

第二步：在Endpoints层用Async-Await调用 #

Endpoints层负责处理请求和响应，用async-await可以把异步代码写成“同步”风格，错误处理也能通过try/catch统一管理，非常简洁：

// endpoints层的异步处理
const getUserEndpoint = async (req, res) => {
  try {
    // 像同步代码一样调用core层的Promise函数
    const user = await core.getUserById(req.params.userId);
    
    if (!user) {
      return res.status(404).json({ message: "用户不存在" });
    }
    
    res.status(200).json(user);
  } catch (err) {
    // 统一捕获数据库错误或其他异常
    res.status(500).json({ 
      message: "数据库查询失败", 
      error: process.env.NODE_ENV === "production" ? "服务器内部错误" : err.message 
    });
  }
};

对比回调写法，这种代码完全没有嵌套，可读性和可维护性提升了不止一个档次。

进阶：封装通用操作，更好适配数据库变更 #

为了进一步实现“适配数据库变更”的目标，你可以在core层封装通用的数据库操作函数，这样以后如果要更换ORM（比如从Mongoose换成Prisma）或者数据库，只需要修改这些通用函数，业务相关的core代码不用动：

// core层通用数据库操作封装
const genericFindById = (Model, id) => {
  return Model.findById(id).exec();
};

const genericFind = (Model, query, options = {}) => {
  return Model.find(query, options.select)
    .sort(options.sort)
    .limit(options.limit)
    .exec();
};

// 业务相关的core函数，基于通用封装实现
const getUserById = (userId) => {
  return genericFindById(User, userId);
};

const getActiveUsers = () => {
  return genericFind(User, { isActive: true }, {
    select: "-password",
    sort: { createdAt: -1 }
  });
};

这样一来，整个分层的解耦度就非常高了：endpoints层只关心请求响应，core层的业务函数只关心业务逻辑，通用封装层负责和数据库打交道，变更数据库时只需要修改通用层即可。

最终的分层效果 #

• routes层：只负责路由映射，比如router.get('/users/:id', endpoints.getUserEndpoint)
• endpoints层：处理请求参数、调用core层、返回响应，无数据库逻辑
• core层：分为通用数据库操作和业务专属操作，完全和HTTP请求解耦，适配变更更轻松

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