如何获取Sequelize实际检索的SQL总行数（含关联查询）？

针对你遇到的大嵌套查询导致内存溢出的问题，以下是几种在Sequelize中获取数据库实际返回行数（含关联笛卡尔积行数，区别于Model.count()）的可行方案：

1. 监听Sequelize全局查询事件 #

Sequelize的query事件可以捕获所有执行的SQL查询，通过查询结果的元数据直接获取实际返回行数：

const sequelize = new Sequelize(/* 你的数据库连接配置 */);

// 设定行数阈值
const ROW_LIMIT = 1000;

sequelize.on('query', (queryObj) => {
  queryObj.promise
    .then(([results, metadata]) => {
      // Postgres下metadata.rowCount即为数据库实际返回的行数
      const actualRowCount = metadata.rowCount;
      if (actualRowCount > ROW_LIMIT) {
        console.warn(`[告警] 查询返回 ${actualRowCount} 行，超过阈值 ${ROW_LIMIT}`);
        // 可在此添加自定义逻辑：比如上报监控、终止后续解析等
      }
    })
    .catch(err => {
      // 处理查询错误，避免未捕获异常
    });
});

• 注意：该事件会监听所有SQL查询（包括Sequelize内部的关联查询、计数查询等），若需过滤特定查询，可通过queryObj.sql判断SQL内容（比如匹配包含JOIN的嵌套查询）。

2. 封装带行数检查的自定义查询函数 #

如果只需监控特定的大型嵌套查询，可封装专属查询方法，按需统计行数：

async function findWithRowCheck(model, options) {
  // 开启raw模式获取原始数据库返回行（未被Sequelize扁平化处理的笛卡尔积结果）
  const rawOptions = { ...options, raw: true };
  const rawResults = await model.findAll(rawOptions);
  const actualRowCount = rawResults.length;

  const ROW_LIMIT = 1000;
  if (actualRowCount > ROW_LIMIT) {
    console.warn(`[告警] 查询返回 ${actualRowCount} 行，超过阈值 ${ROW_LIMIT}`);
  }

  // 若业务需要嵌套对象结构，可手动转换回非raw格式
  if (!options.raw) {
    return model.bulkBuild(rawResults, options);
  }
  return rawResults;
}

• 优点：精准控制需监控的查询，无需全局监听；缺点：若业务依赖Sequelize的嵌套对象结果，需额外转换。

3. 补充：内存优化建议 #

除了告警，从根源解决内存溢出问题可尝试：

• 使用流式查询：Sequelize支持通过model.findAll({ stream: true })返回可读流，逐行处理结果，避免一次性加载所有数据到内存；
• 强制分页：给大型查询默认添加limit和offset，限制单次返回行数；
• 优化关联查询：避免不必要的include，或使用separate: true将关联查询拆分为独立SQL，减少笛卡尔积行数。

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