Sequelize修改列类型的转换定义：BLOB转TEXT如何指定JS转换

我之前也碰到过一模一样的需求，Sequelize的迁移机制确实没提供直接的字段转换钩子，但咱们可以通过先处理数据、再修改列类型的两步走方式来实现，完全用JS逻辑控制转换过程。下面是具体的实现步骤和代码示例：

核心思路 #

Sequelize迁移的up和down方法支持直接执行自定义查询和数据操作，我们可以：

1. 先遍历目标表的所有记录，将BLOB字段的二进制数据转换为UTF-8编码的字符串并更新回数据库
2. 再修改该列的类型从BLOB改为TEXT

同理，回滚（down方法）时则反向操作：先改回BLOB类型，再把字符串转回二进制数据。

完整迁移代码示例 #

假设你的表名为documents，要转换的字段是content，迁移文件可以这么写：

'use strict';

module.exports = {
  async up(queryInterface, Sequelize) {
    // 1. 先处理BLOB到UTF-8字符串的转换
    const documents = await queryInterface.sequelize.query(
      'SELECT id, content FROM documents',
      { type: Sequelize.QueryTypes.SELECT }
    );

    // 遍历每条记录，转换BLOB为UTF-8字符串并更新
    for (const doc of documents) {
      if (doc.content) {
        // 把Buffer（BLOB在Sequelize中返回为Buffer）转成UTF-8字符串
        const textContent = doc.content.toString('utf8');
        await queryInterface.sequelize.query(
          'UPDATE documents SET content = ? WHERE id = ?',
          { replacements: [textContent, doc.id] }
        );
      }
    }

    // 2. 修改列类型为TEXT
    await queryInterface.changeColumn('documents', 'content', {
      type: Sequelize.TEXT,
      allowNull: true // 保持原字段的null约束
    });
  },

  async down(queryInterface, Sequelize) {
    // 回滚时先把列改回BLOB
    await queryInterface.changeColumn('documents', 'content', {
      type: Sequelize.BLOB,
      allowNull: true
    });

    // 再把TEXT转回BLOB二进制数据
    const documents = await queryInterface.sequelize.query(
      'SELECT id, content FROM documents',
      { type: Sequelize.QueryTypes.SELECT }
    );

    for (const doc of documents) {
      if (doc.content) {
        // 把字符串转成Buffer存回BLOB
        const blobContent = Buffer.from(doc.content, 'utf8');
        await queryInterface.sequelize.query(
          'UPDATE documents SET content = ? WHERE id = ?',
          { replacements: [blobContent, doc.id] }
        );
      }
    }
  }
};

注意事项 #

• 事务处理：如果你的表数据量较大，建议把整个up/down逻辑包裹在事务中，避免中途失败导致数据不一致：

  const transaction = await queryInterface.sequelize.transaction();
  try {
    // 所有操作放在这里
    await transaction.commit();
  } catch (err) {
    await transaction.rollback();
    throw err;
  }
  

• 空值处理：代码中已经判断了doc.content是否存在，避免转换空值时出错
• 数据库兼容性：不同数据库对BLOB/TEXT的处理略有差异（比如PostgreSQL的BYTEA对应BLOB），请根据你的数据库调整字段类型
• 性能优化：如果表数据量极大，遍历单条更新可能效率低，可以考虑用批量更新或者数据库原生的转换函数（比如MySQL的CONVERT(content USING utf8)），但JS转换的好处是能完全自定义处理逻辑（比如处理编码异常）

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