Sequelize按列分组限制关联模型内容的查询问题

你的核心问题在于直接在include选项里添加group: ['sourceId']是错误的——Sequelize会把这个分组条件应用到整个主查询（products表）上，而不是仅过滤关联的prices数据，这会导致产品结果不符合预期，甚至丢失数据。

想要实现「每个产品关联的prices中，按sourceId分组，仅保留每个sourceId的最新记录」的需求，可以通过关联子查询过滤来实现，下面是具体的解决方案：

方案1：用SQL子查询筛选每个sourceId的最新价格记录 #

直接在include的where条件中嵌入子查询，筛选出每个sourceId下最新的那条价格记录（这里假设你想要的是createdAt最晚的记录）：

models.products.findAll({ 
  where: Sequelize.where(
    Sequelize.fn('CONCAT_WS', ' ', Sequelize.col('brand'), Sequelize.col('name')),
    { $like: `%${searchQuery}%` }
  ), 
  limit: limit, 
  offset: offset, 
  include: [{ 
    model: models.prices, 
    where: Sequelize.literal(`
      (sourceId, createdAt) IN (
        SELECT sourceId, MAX(createdAt) 
        FROM prices 
        GROUP BY sourceId
      )
    `),
    // 如果允许产品没有关联价格，设置为false；如果必须有价格，设为true
    required: false 
  }], 
  order: [ ['name', 'desc'], [models.prices, 'createdAt', 'desc'] ], 
});

原理说明 #

• 子查询SELECT sourceId, MAX(createdAt) FROM prices GROUP BY sourceId会先找出每个sourceId对应的最新创建时间
• 外层通过(sourceId, createdAt) IN (...)匹配，只保留符合条件的价格记录，这样每个sourceId只会有一条最新的价格被关联到产品上

方案2：基于主键的简化版（如果id是自增主键） #

如果你的prices表使用自增主键id，且最新的价格记录id最大，那么可以用更高效的子查询：

include: [{ 
  model: models.prices, 
  where: Sequelize.literal(`
    id IN (
      SELECT MAX(id) 
      FROM prices 
      GROUP BY sourceId
    )
  `),
  required: false
}]

这种方式避免了同时匹配两个字段，性能会更好一些。

为什么原查询不行？ #

Sequelize的include选项中的group参数会被合并到主查询的GROUP BY子句中，导致整个查询按products表的字段 + sourceId分组，这会把相同品牌+名称的产品合并，或者丢失大量数据，完全不符合你想要的「仅过滤关联价格」的需求。

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