Node.js如何提取Promise解析数据并传递给Express渲染页面？

我是Node.js新手，正在学习异步概念与Promise。我想确保Web服务器渲染页面时数据库数据已经就绪。目前我的代码好像实现了正确的时机——数据就绪时会调用buildhtml函数，这是我研究一晚后的首个成果。但现在我卡在了把数据传递给Web服务器/Express的正确方式上，我需要的数据被封装在Promise对象里没法直接用，查了好多帖子都没找到适配我这个情况的解决方案。

问题：以可消费的方式传递数据（也就是去掉外层的Promise封装）的最佳实践是什么？我的思路完全错了还是只差一步？

我的代码： #

//DB Load Users
const promise = new Promise((resolve, reject) => {
    db.connect(function(err) {
        if (err) throw err;
        console.log("Connected!");
        var sql = "SELECT username, useremail, userage, useruniqueid FROM users";
        db.query(sql, function(err, result) {
            if (err) throw err;
            const jsonresult = JSON.parse(JSON.stringify(result)); //to clear RowDatePacket
            resolve(jsonresult);
        });
    })
})

promise
    .then(buildhtml)

//Render (express) HTML with promise resolve after DB-query
function buildhtml() {
    app.get("/", function(req, res) {
        res.render("home", {
            data: promise
        })
    })
}

console.log(promise)的输出： #

Connected!
Promise {
  [
    {
      username: 'admin',     
      useremail: '888883895',
      userage: '33',
      useruniqueid: 1        
    },
    {
      username: 'admin',     
      useremail: '888883895',
      userage: '22',
      useruniqueid: 2
    },
    {
      username: 'admin',
      useremail: '888883895',
      userage: '22',
      useruniqueid: 3
    },
    {
      username: 'admin',
      useremail: '888883895',
      userage: '22',
      useruniqueid: 4
    },
    {
      username: 'pushy boi',
      useremail: 'pb@gmail.com',
      userage: '65',
      useruniqueid: 5
    },
    {
      username: 'push attempt',
      useremail: 'pb@gmail.com',
      userage: '65',
      useruniqueid: 6
    },
    {
      username: 'instead of push db',
      useremail: 'db@gmail.com',
      userage: '37',
      useruniqueid: 104
    },
    {
      username: '111',
      useremail: '111',
      userage: '11',
      useruniqueid: 111
    },
    {
      username: null,
      useremail: null,
      userage: null,
      useruniqueid: 112
    },
    {
      username: 'Max Mustermann',
      useremail: 'MM@gmail.com',
      userage: '44',
      useruniqueid: 333
    }
  ]
}

解决方案 #

你当前的核心问题有两个：一是直接把Promise对象传给了模板，但模板需要的是Promise解析完成后的实际数据；二是当前写法只会在服务器启动时查询一次数据库，后续用户访问拿到的都是旧数据（如果数据库内容更新了，页面不会同步）。下面是两种符合最佳实践的解决方式：

方案1：每次请求都查询最新数据（推荐） #

这是绝大多数场景的正确做法，保证用户每次访问都能拿到最新的数据库内容。

首先把数据库查询逻辑封装成一个返回Promise的函数：

// 封装数据库查询为可复用的Promise函数
function getUsers() {
  return new Promise((resolve, reject) => {
    db.connect(function(err) {
      if (err) return reject(err); // 用reject抛出错误，不要直接throw
      console.log("数据库连接成功");
      const sql = "SELECT username, useremail, userage, useruniqueid FROM users";
      db.query(sql, function(err, result) {
        if (err) return reject(err);
        // 转换为普通JSON对象，清除RowDataPacket标记
        const jsonResult = JSON.parse(JSON.stringify(result));
        resolve(jsonResult);
      });
    });
  });
}

然后在Express路由处理函数中，用async/await（代码更简洁易读）或者.then()处理异步逻辑：

async/await写法（优先选择）

// 注册路由，每次请求触发时查询数据库
app.get("/", async function(req, res) {
  try {
    const users = await getUsers(); // 等待Promise解析拿到实际数据
    res.render("home", { data: users }); // 把实际数据传给模板
  } catch (err) {
    // 捕获并处理错误，避免服务器崩溃
    console.error("查询用户数据失败:", err);
    res.status(500).send("服务器内部错误");
  }
});

.then()写法

app.get("/", function(req, res) {
  getUsers()
    .then(users => {
      res.render("home", { data: users });
    })
    .catch(err => {
      console.error("查询用户数据失败:", err);
      res.status(500).send("服务器内部错误");
    });
});

方案2：预加载数据（仅服务器启动时查询一次） #

如果你确定数据不会更新，或者不需要实时数据，可以在服务器启动时预加载一次，之后所有请求都用这份缓存数据：

// 预加载用户数据的Promise
const preloadedUsers = new Promise((resolve, reject) => {
  db.connect(function(err) {
    if (err) return reject(err);
    console.log("数据库连接成功");
    const sql = "SELECT username, useremail, userage, useruniqueid FROM users";
    db.query(sql, function(err, result) {
      if (err) return reject(err);
      const jsonResult = JSON.parse(JSON.stringify(result));
      resolve(jsonResult);
    });
  });
});

// 等待数据加载完成后再注册路由
preloadedUsers.then(users => {
  app.get("/", function(req, res) {
    res.render("home", { data: users }); // 直接传解析后的实际数据
  });
}).catch(err => {
  console.error("预加载用户数据失败:", err);
  // 加载失败时可以选择退出服务器，避免提供错误服务
  process.exit(1);
});

关键注意事项 #

• 永远不要直接把Promise对象传给模板，必须等待它解析完成拿到实际值
• 优先使用async/await处理异步代码，比.then()更易读和维护
• 数据库连接建议使用连接池（大多数Node.js数据库库都自带），避免每次请求都重新建立连接，提升性能
• 必须捕获Promise的错误（用try/catch或者.catch()），否则未处理的Promise拒绝会导致服务器崩溃

内容的提问来源于stack exchange，提问作者IoT-Practitioner