castopod/app/Database/Migrations/2021-12-25-150000_add_credits_view.php

<?php

declare(strict_types=1);

/**
 * @copyright  2020 Ad Aures
 * @license    https://www.gnu.org/licenses/agpl-3.0.en.html AGPL3
 * @link       https://castopod.org/
 */

namespace App\Database\Migrations;

use Override;

class AddCreditsView extends BaseMigration
{
    #[Override]
    public function up(): void
    {
        // Creates View for credit UNION query
        $viewName = $this->db->prefixTable('credits');
        $personsTable = $this->db->prefixTable('persons');
        $podcastPersonsTable = $this->db->prefixTable('podcasts_persons');
        $episodePersonsTable = $this->db->prefixTable('episodes_persons');
        $episodesTable = $this->db->prefixTable('episodes');
        $createQuery = <<<SQL
        CREATE VIEW `{$viewName}` AS
            SELECT `person_group`, `person_id`, `full_name`, `person_role`, `podcast_id`, NULL AS `episode_id` FROM `{$podcastPersonsTable}`
                INNER JOIN `{$personsTable}`
                    ON (`person_id`=`{$personsTable}`.`id`)
            UNION
            SELECT `person_group`, `person_id`, `full_name`, `person_role`, {$episodePersonsTable}.`podcast_id`, `episode_id` FROM `{$episodePersonsTable}`
                INNER JOIN `{$personsTable}`
                    ON (`person_id`=`{$personsTable}`.`id`)
                INNER JOIN `{$episodesTable}`
                    ON (`episode_id`=`{$episodesTable}`.`id`)
            WHERE `{$episodesTable}`.published_at <= UTC_TIMESTAMP()
            ORDER BY `person_group`, `full_name`, `person_role`, `podcast_id`, `episode_id`;
        SQL;
        $this->db->query($createQuery);
    }

    #[Override]
    public function down(): void
    {
        $viewName = $this->db->prefixTable('credits');
        $this->db->query("DROP VIEW IF EXISTS `{$viewName}`");
    }
}