使用Sequelize查询JSON格式tagId列中包含指定标签ID的行

核心问题分析 #

你遇到的空数据问题，大概率是数据库JSON类型不匹配或者查询值类型与存储值不匹配导致的，不同数据库对JSON数组的查询语法差异很大，下面分场景给出解决方案：

场景1：使用PostgreSQL数据库 #

情况A：tagId列是JSONB类型（推荐使用该类型，支持原生contains操作）

确保查询的元素类型和存储的一致（比如存的是数字数组，就用数字查询，别用字符串）：

const { Op } = require('sequelize');

const response = await db.UserTag.findAll({
  where: { tagId: { [Op.contains]: [1] } }, // 用数字1匹配存储的[1,2]数字数组
});
return response;

情况B：tagId列是JSON类型（非JSONB）

JSON类型不支持直接用@>操作符，需要先转成JSONB再判断：

const { Op, fn, col } = require('sequelize');

// 方式1：通过Sequelize函数调用实现
const response = await db.UserTag.findAll({
  where: fn('jsonb_contains', fn('cast', col('tagId'), 'jsonb'), '[1]'),
});

// 方式2：直接写原生SQL条件
const response = await db.UserTag.findAll({
  where: {
    [Op.raw]: 'tagId::jsonb @> \'[1]\''
  }
});
return response;

场景2：使用MySQL数据库 #

MySQL需要用JSON_CONTAINS函数来查询：

const { fn, col } = require('sequelize');

// 方式1：调用MySQL原生函数
const response = await db.UserTag.findAll({
  where: fn('JSON_CONTAINS', col('tagId'), '1', '$'),
});

// 方式2：用Sequelize的Op.jsonContains（v6及以上版本支持）
const { Op } = require('sequelize');
const response = await db.UserTag.findAll({
  where: { tagId: { [Op.jsonContains]: 1 } },
});
return response;

关键检查项 #

1. 确认数据库列类型：先查看数据库中tagId列是JSON还是JSONB（PostgreSQL），或是JSON（MySQL）
2. 匹配元素类型：如果存储的是[1,2]（数字数组），查询时别传["1"]（字符串数组），类型不匹配会导致查不到数据
3. 模型定义正确：确保UserTag模型里tagId的类型是DataTypes.JSON或DataTypes.JSONB：

// UserTag模型示例
module.exports = (sequelize, DataTypes) => {
  const UserTag = sequelize.define('UserTag', {
    tagId: {
      type: DataTypes.JSONB, // PostgreSQL用JSONB；MySQL用DataTypes.JSON
      allowNull: false
    }
  });
  return UserTag;
};

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