在Node.js中使用Sequelize实现COALESCE函数的问题咨询

嘿，我来帮你搞定这个问题！你的原始SQL嵌套了不少子查询和聚合逻辑，用Sequelize的常规查询构造器拼接会有点绕，但其实有两种实用的方式可以实现，我给你拆解一下：

方式一：用sequelize.literal()嵌入原生SQL片段 #

这种方式既贴合Sequelize的模型查询习惯，又能直接复用你原始SQL里的复杂计算逻辑，是处理这类场景的常用方案。

步骤说明： #

1. 先单独获取uforigem值（两个子查询都用到它，单独查询能让代码更简洁高效）；
2. 处理日期参数（注意JavaScript的月份是0开始的，要转换成SQL的1-based格式）；
3. 在查询的attributes里用literal()把整个COALESCE+ROUND的计算逻辑嵌进去，作为投影字段；
4. 最后匹配原始SQL的WHERE条件即可。

代码示例： #

const { Op } = require('sequelize');
// 假设你已经初始化了sequelize实例，且定义了Baseprodutos和Feriados模型

// 1. 获取uforigem的值
const ufOrigemRow = await Baseprodutos.findOne({
  attributes: ['uforigem'],
  where: { Empresa: 'test' },
  raw: true
});
const ufOrigem = ufOrigemRow?.uforigem;

// 2. 处理当前月份和日期（适配SQL的格式）
const currentDate = new Date();
const currentMonth = currentDate.getMonth() + 1; // JS月份从0开始，SQL是1开始
const currentDay = currentDate.getDate();

// 3. 构建主查询
const projectionResult = await Baseprodutos.findOne({
  attributes: [
    [
      sequelize.literal(`
        COALESCE(
          ROUND(
            SUM(vdamesatual) / 
            (SELECT COUNT(*) FROM feriados WHERE MONTH(data) = :currentMonth AND DAY(data) < :currentDay AND diadasemana IN(2,3,4,5,6) AND feriadonacional = 0 AND uf <> :ufOrigem) * 
            (SELECT COUNT(*) FROM feriados WHERE MONTH(data) = :currentMonth AND DAY(data) >= :currentDay AND diadasemana IN(2,3,4,5,6) AND feriadonacional = 0 AND uf <> :ufOrigem)
          ),
          0
        )
      `),
      'projecao'
    ]
  ],
  where: {
    Empresa: 'test',
    UFDest: 'uf',
    Fabricante: 'sample'
  },
  // 用bind传递参数，避免SQL注入风险
  bind: {
    currentMonth,
    currentDay,
    ufOrigem
  },
  raw: true // 获取原始结果对象，方便直接取值
});

console.log('投影结果:', projectionResult.projecao);

方式二：直接执行原生SQL查询 #

如果不想折腾Sequelize的查询构造器，完全可以直接把你写好的SQL作为原生查询执行，这种方式最省心，适合特别复杂的SQL语句。

代码示例： #

const rawQuery = `
SELECT COALESCE(ROUND(SUM(vdamesatual) / 
  (SELECT COUNT(*) FROM feriados WHERE MONTH(data) = MONTH(CURRENT_DATE) AND DAY(data) < DAY(CURRENT_DATE) AND diadasemana IN(2,3,4,5,6) AND feriadonacional = 0 AND uf <> (SELECT DISTINCT uforigem FROM baseprodutos WHERE Empresa = 'test')) * 
  (SELECT COUNT(*) FROM feriados WHERE MONTH(data) = MONTH(CURRENT_DATE) AND DAY(data) >= DAY(CURRENT_DATE) AND diadasemana IN(2,3,4,5,6) AND feriadonacional = 0 AND uf <> (SELECT DISTINCT uforigem FROM baseprodutos WHERE Empresa = 'test'))), 0) AS projecao 
FROM baseprodutos 
WHERE Empresa = 'test' AND UFDest = 'uf' AND Fabricante = 'sample';
`;

// 执行原生查询
const [result] = await sequelize.query(rawQuery, {
  type: sequelize.QueryTypes.SELECT
});

console.log('投影结果:', result.projecao);

重要提醒：SQL注入风险 #

如果你的参数（比如Empresa、UFDest这些）是来自用户输入的动态值，一定要用参数绑定的方式（比如方式一里的bind，或者方式二里用$1、:param占位符），绝对不要直接拼接字符串，避免SQL注入漏洞。

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