lightster/hodor

<?php
 
use Hodor\Database\Phpmig\Migration;
use Lstr\YoPdo\YoPdo;
 
class AddMutexId extends Migration
{
    /**
     * @param YoPdo $yo_pdo
     * @return void
     */
Method `transactionalUp` has 27 lines of code (exceeds 25 allowed). Consider refactoring.
    protected function transactionalUp(YoPdo $yo_pdo)
    {
        $sql = <<<SQL
ALTER TABLE buffered_jobs
    ADD COLUMN mutex_id VARCHAR DEFAULT 'hodor:' || currval('buffered_jobs_buffered_job_id_seq'::regclass);
ALTER TABLE queued_jobs
    ADD COLUMN mutex_id VARCHAR;
ALTER TABLE successful_jobs
    ADD COLUMN mutex_id VARCHAR;
ALTER TABLE failed_jobs
    ADD COLUMN mutex_id VARCHAR;
 
UPDATE buffered_jobs
SET mutex_id = 'hodor:' || buffered_job_id;
 
UPDATE queued_jobs
SET mutex_id = 'hodor:' || buffered_job_id;
 
UPDATE successful_jobs
SET mutex_id = 'hodor:' || buffered_job_id;
 
UPDATE failed_jobs
SET mutex_id = 'hodor:' || buffered_job_id;
 
ALTER TABLE buffered_jobs
    ALTER COLUMN mutex_id SET NOT NULL;
ALTER TABLE queued_jobs
    ALTER COLUMN mutex_id SET NOT NULL;
ALTER TABLE successful_jobs
    ALTER COLUMN mutex_id SET NOT NULL;
ALTER TABLE failed_jobs
    ALTER COLUMN mutex_id SET NOT NULL;
SQL;
 
        $yo_pdo->queryMultiple($sql);
    }
 
    /**
     * @param YoPdo $yo_pdo
     * @return void
     */
    protected function transactionalDown(YoPdo $yo_pdo)
    {
        $sql = <<<SQL
ALTER TABLE buffered_jobs
    DROP COLUMN mutex_id;
ALTER TABLE queued_jobs
    DROP COLUMN mutex_id;
ALTER TABLE successful_jobs
    DROP COLUMN mutex_id;
ALTER TABLE failed_jobs
    DROP COLUMN mutex_id;
SQL;
 
        $yo_pdo->queryMultiple($sql);
    }
}