Node.js中Sequelize异步方法await调用无返回、查询失效问题

安全阿岳

2026-8-26

问题现象

运行基于Sequelize 6.21.0的Async/Await写法代码时，await异步数据库查询后的代码始终无法执行；同逻辑在Sequelize v3.22.0版本下用Promise写法可正常运行，升级版本改写为Async/Await后触发问题，复现代码如下：

locale ={};

locale.list=[];

locale.locale = async ()=>{
   locale.list=[];
   const findAllLocale = await global.db.Locale.findAll({
        attributes: {
            exclude: ['createdAt','updatedAt']
        },
        where: null 
    });


    findAllLocale.forEach(function(locale){
        global.locale.list.push(locale);
        
    });
}
locale.locale();
module.exports = locale;

产生原因

核心原因是异步调用未做错误捕获：await global.db.Locale.findAll()执行时只要抛出任何异常（常见为数据库连接失败、模型与表结构不匹配、数据库账号权限不足、Sequelize 6.x配置项和v3不兼容、参数校验不通过），会直接触发async函数返回的Promise reject，由于调用locale.locale()时没有挂载.catch()、函数内部也没有用try/catch包裹await逻辑，错误会成为未捕获的Promise异常，直接中断函数执行，await后续的代码自然不会运行。
存在时序逻辑问题：模块加载是同步过程，代码中直接在模块顶层调用异步方法locale.locale()后立刻执行module.exports = locale，此时异步查询还没执行完成，外部引入模块拿到locale对象时，list属性大概率还是空数组，和预期的“查询完成后list填充完成”的逻辑不符。
存在变量名冲突：forEach回调的形参命名为locale，和外层定义的locale对象重名，虽然当前代码里写的是global.locale.list.push暂时没触发作用域问题，但很容易在后续修改时出现作用域引用错误。

修复方案

给异步逻辑增加错误捕获，先定位具体报错原因：在async函数内部用try/catch包裹await逻辑，或是在调用async方法时追加.catch()，先把Sequelize抛出的具体错误打印出来，优先解决数据库连接、模型配置、参数合法性这类硬错误。
调整模块异步初始化逻辑，不要在模块加载阶段无等待触发异步查询：把初始化逻辑做成可等待的导出方法，外部使用模块前先等待初始化完成，再读取list数据，避免时序问题。
修正重名变量，避免作用域混淆，同时适配Sequelize 6.x的参数要求，不要传null作为where条件，改用空对象即可。

修复后的参考代码：

const locale = {};
locale.list = [];

// 初始化方法，返回Promise，外部可等待执行完成
locale.init = async () => {
  locale.list = [];
  try {
    const findAllLocale = await global.db.Locale.findAll({
      attributes: {
        exclude: ['createdAt','updatedAt']
      },
      where: {}
    });
    // 修正重名的形参
    findAllLocale.forEach(item => {
      locale.list.push(item);
    });
  } catch (err) {
    // 捕获并打印查询错误，避免静默失败
    console.error('加载语言配置失败:', err);
    throw err;
  }
}

module.exports = locale;

外部使用该模块时，先等待init方法执行完成再读取list数据：

const locale = require('./locale');
// 等待初始化完成
await locale.init();
// 后续再使用locale.list即可正常拿到查询结果
console.log(locale.list);

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