PostgreSQL更新数组字段报错，求Sequelize正确模型配置方法

开发点赞系统更新PostgreSQL的audios表likes数组字段时，出现错误：

execution (default) UPDATE "audios" SET "likes"=$1, "updated_at"=$2 WHERE "id" = $3 malformed array literal: "The id"

错误原因 #

1. 模型与数据库字段类型不匹配：数据库中likes是ARRAY(STRING)类型，但Model里定义成了Sequelize.STRING，Sequelize无法正确处理数组数据，导致生成的SQL把单个字符串当作数组字面量传入，触发格式错误。
2. 更新值类型错误：直接将单个userId字符串赋值给likes字段，而数组字段需要接收数组类型的值，而非单一字符串。
3. 代码冗余：更新逻辑中重复定义const likes，属于不良编码习惯。

修复步骤 #

1. 修正Model配置

将likes字段类型改为Sequelize.ARRAY(Sequelize.STRING)，与数据库定义保持一致：

import Sequelize, { Model } from "sequelize"

class Audio extends Model {
  static init(sequelize) {
    super.init(
      {
        name: Sequelize.STRING,
        path: Sequelize.STRING,
        url: {
          type: Sequelize.VIRTUAL,
          get(){
            return `http://localhost:3000/product-file/${this.path}`
          }
        },
        likes: Sequelize.ARRAY(Sequelize.STRING) // 修正字段类型
      },
      {
        sequelize,
      }
    )
    return this
  }
}
export default Audio

2. 修正更新逻辑

需要将userId追加到现有likes数组中，同时避免重复点赞。提供两种实现方式：

方式一：先查询再更新（直观易读）

async update(request, response) {
  try {
    const { id } = request.params
    const userId = request.userId.toString() // 确保类型匹配数据库字符串数组

    // 查询目标音频
    const audio = await Audio.findByPk(id)
    if (!audio) {
      return response.status(404).json('音频不存在')
    }

    // 处理数组：为空则初始化，避免重复添加
    let updatedLikes = audio.likes || []
    if (!updatedLikes.includes(userId)) {
      updatedLikes.push(userId)
    }

    // 执行更新
    await Audio.update(
      { likes: updatedLikes },
      { where: { id } }
    )

    return response.json({ ok: true, likes: updatedLikes })
  } catch (err) {
    console.log(err.message)
    return response.status(500).json('server error')
  }
}

方式二：直接使用PostgreSQL数组操作符（无需提前查询）

async update(request, response) {
  try {
    const { id } = request.params
    const userId = request.userId.toString()

    // 用PostgreSQL内置函数实现：先移除旧值（避免重复）再追加新值
    await Audio.update(
      { 
        likes: Sequelize.fn(
          'array_append', 
          Sequelize.fn('array_remove', Sequelize.col('likes'), userId), 
          userId
        )
      },
      { where: { id } }
    )

    return response.json({ ok: true })
  } catch (err) {
    console.log(err.message)
    return response.status(500).json('server error')
  }
}

3. 确认迁移文件

你的迁移文件已经正确定义了likes字段类型，确保迁移已执行：

'use strict'

module.exports = {
  async up (queryInterface, Sequelize) {
   await queryInterface.addColumn('audios', 'likes', {
     type: Sequelize.ARRAY(Sequelize.STRING)
    })
  },

  async down (queryInterface) {
   await queryInterface.removeColumn('audios', 'likes')
  }
}

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