如何避免Sequelize(MySQL)的Unknown column错误并返回NULL

核心思路 #

避免Sequelize直接生成包含不存在字段的SELECT语句，通过SQL的字段存在性判断逻辑，在生产环境中动态返回NULL而非抛出错误，同时保留开发环境的错误提示。

具体实现方案 #

1. 自定义SQL查询（快速解决单场景）

直接构造包含字段存在性判断的SQL语句，替代默认的findAll调用：

const fillials = await sequelize.query(`
  SELECT 
    \`ID\`,
    IF(EXISTS(SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = 's4y_fillials' AND COLUMN_NAME = 'free_delivery_sum'), \`free_delivery_sum\`, NULL) AS \`free_delivery_sum\`,
    \`other_field\`
  FROM \`s4y_fillials\`;
`, { model: FilialDBModel, mapToModel: true });

• 原理：通过information_schema.COLUMNS检查表中是否存在目标字段，存在则返回字段值，不存在则返回NULL。
• 优势：直接可控，无需修改模型结构，结果自动映射到模型实例。

2. 模型作用域（环境区分更优雅）

给模型添加环境专属作用域，开发环境保留原查询逻辑，生产环境自动处理缺失字段：

FilialDBModel.addScope('safeFindAll', {
  attributes: function() {
    if (process.env.NODE_ENV === 'production') {
      return [
        'ID',
        [sequelize.literal(`IF(EXISTS(SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = 's4y_fillials' AND COLUMN_NAME = 'free_delivery_sum'), \`free_delivery_sum\`, NULL)`), 'free_delivery_sum'],
        'other_field'
      ];
    }
    // 开发环境用原字段列表，保留错误提示
    return ['ID', 'free_delivery_sum', 'other_field'];
  }
});

使用时调用作用域：

const fillials = await FilialDBModel.scope('safeFindAll').findAll();

3. 全局钩子（批量处理多模型场景）

如果多个模型都有类似需求，可通过全局beforeFind钩子统一处理：

// 定义需要处理的字段列表，可根据模型扩展
const vulnerableFields = ['free_delivery_sum'];

sequelize.addHook('beforeFind', async (options) => {
  if (process.env.NODE_ENV !== 'production') return;
  
  const model = options.model;
  const tableName = model.getTableName();
  const rawAttrs = model.rawAttributes;
  const processedAttrs = [];

  for (const attr of Object.keys(rawAttrs)) {
    if (vulnerableFields.includes(attr)) {
      processedAttrs.push([
        sequelize.literal(`IF(EXISTS(SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = '${tableName}' AND COLUMN_NAME = '${attr}'), \`${attr}\`, NULL)`),
        attr
      ]);
    } else {
      processedAttrs.push(attr);
    }
  }

  options.attributes = processedAttrs;
});

• 原理：在查询执行前动态修改attributes配置，对指定字段添加存在性判断。
• 优势：一次配置，所有模型的查询都自动生效，适合多模型批量处理。

注意事项 #

• 确保生产环境数据库用户拥有information_schema.COLUMNS表的查询权限，否则存在性判断会失效。
• 若需处理多个字段，可扩展vulnerableFields数组，避免重复编写判断逻辑。
• 严格通过NODE_ENV区分环境，确保开发环境仍能收到字段缺失的错误提示，便于排查问题。

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