62 lines
2.3 KiB
JavaScript
62 lines
2.3 KiB
JavaScript
"use strict";
|
|
|
|
module.exports = {
|
|
async up(queryInterface, Sequelize) {
|
|
// 1) Add character_name column to notification table
|
|
await queryInterface.sequelize.query(`
|
|
ALTER TABLE IF EXISTS falukant_log.notification
|
|
ADD COLUMN IF NOT EXISTS character_name text;
|
|
`);
|
|
|
|
// 2) Create helper function to populate character_name from character_id
|
|
await queryInterface.sequelize.query(`
|
|
CREATE OR REPLACE FUNCTION falukant_log.populate_notification_character_name()
|
|
RETURNS TRIGGER AS $function$
|
|
DECLARE
|
|
v_first_name TEXT;
|
|
v_last_name TEXT;
|
|
BEGIN
|
|
IF NEW.character_name IS NULL AND NEW.character_id IS NOT NULL THEN
|
|
SELECT pf.name, pl.name
|
|
INTO v_first_name, v_last_name
|
|
FROM falukant_data.character c
|
|
LEFT JOIN falukant_predefine.firstname pf ON pf.id = c.first_name
|
|
LEFT JOIN falukant_predefine.lastname pl ON pl.id = c.last_name
|
|
WHERE c.id = NEW.character_id;
|
|
|
|
IF v_first_name IS NOT NULL OR v_last_name IS NOT NULL THEN
|
|
NEW.character_name := COALESCE(v_first_name, '') || CASE WHEN v_first_name IS NOT NULL AND v_last_name IS NOT NULL THEN ' ' ELSE '' END || COALESCE(v_last_name, '');
|
|
ELSE
|
|
-- Fallback to placeholder with id
|
|
NEW.character_name := ('#' || NEW.character_id::text);
|
|
END IF;
|
|
END IF;
|
|
RETURN NEW;
|
|
END;
|
|
$function$ LANGUAGE plpgsql;
|
|
`);
|
|
|
|
// 3) Create trigger that runs before insert to populate the column
|
|
await queryInterface.sequelize.query(`
|
|
DROP TRIGGER IF EXISTS trg_populate_notification_character_name ON falukant_log.notification;
|
|
CREATE TRIGGER trg_populate_notification_character_name
|
|
BEFORE INSERT ON falukant_log.notification
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION falukant_log.populate_notification_character_name();
|
|
`);
|
|
},
|
|
|
|
async down(queryInterface, Sequelize) {
|
|
await queryInterface.sequelize.query(`
|
|
DROP TRIGGER IF EXISTS trg_populate_notification_character_name ON falukant_log.notification;
|
|
`);
|
|
await queryInterface.sequelize.query(`
|
|
DROP FUNCTION IF EXISTS falukant_log.populate_notification_character_name();
|
|
`);
|
|
await queryInterface.sequelize.query(`
|
|
ALTER TABLE IF EXISTS falukant_log.notification
|
|
DROP COLUMN IF EXISTS character_name;
|
|
`);
|
|
}
|
|
};
|