Sequelize Migration With Updates

sequelize-migration-with-updates.js

'use strict';

const tags = {
  Negocios: 'business',
  Social: 'social',
  Familiar: 'familiar',
  Personal: 'personal'
};

module.exports = {
  up(queryInterface, Sequelize) {
    return queryInterface.sequelize.transaction(async t => {
      await queryInterface.addColumn('Types', 'tag', {
          type: Sequelize.STRING(90),
          required: false,
          allowNull: true
        }, { transaction: t }),
      for await (const query of runUpdates(
        queryInterface,
        'ServiceTypes',
        tags,
        t
      )) {}
    });
  },

  down(queryInterface) {
    return queryInterface.removeColumn('Types', 'tag');
  }
};

function* runUpdates(queryInterface, table, updates, transaction) {
  for (const name in updates) {
    const tag = updates[name];

    yield queryInterface.sequelize.query(
      `UPDATE "public"."${table}" SET tag='${tag}' WHERE name='${name}'`,
      { transaction, logging: console.log }
    );
  }
}