20170728020000_migrate_datalists_to_config.php

Go to the documentation of this file.

<?php

use Phinx\Db\Adapter\MysqlAdapter;
use Phinx\Migration\AbstractMigration;

class MigrateDatalistsToConfig extends AbstractMigration {

    public function validate() {

        $prefix = $this->getAdapter()->getOption('table_prefix');

        $duplicates = $this->fetchAll("
            SELECT name
            FROM {$prefix}datalists
            WHERE name IN (SELECT name FROM {$prefix}config)
            AND name NOT IN ('processed_upgrades', 'version')
        ");


        if (!empty($duplicates)) {
            $duplicates_array = [];
            foreach ($duplicates as $duplicate) {
                $duplicates_array[] = $duplicate['name'];
            }
            $duplicates = implode(', ', $duplicates_array);
            throw new InstallationException("Found names ({$duplicates}) in datalist that also exist in config. Don't know how to merge.");
        }

    }

    public function up() {

        if (!$this->hasTable('datalists') || !$this->hasTable('config')) {
            return;
        }

        $prefix = $this->getAdapter()->getOption('table_prefix');
        $rows = $this->fetchAll("
            SELECT * FROM {$prefix}datalists
            WHERE name NOT IN ('version')
        ");

        foreach ($rows as $row) {
            $value = $row['value'];
            if ($row['name'] !== 'processed_upgrades') {
                $value = serialize($row['value']);
            }

            $this->insert('config', [
                'name' => $row['name'],
                'value' => $value,
            ]);
        }

        // all data migrated, so drop the table
        $this->dropTable('datalists');
    }

    public function down() {

        if ($this->hasTable("datalists")) {
            return;
        }

        $table = $this->table("datalists", [
            'id' => false,
            'primary_key' => ["name"],
            'engine' => "MyISAM",
            'encoding' => "utf8",
            'collation' => "utf8_general_ci",
        ]);

        $table->addColumn('name', 'string', [
            'null' => false,
            'limit' => MysqlAdapter::TEXT_SMALL,
        ]);

        $table->addColumn('value', 'text', [
            'null' => false,
            'limit' => MysqlAdapter::TEXT_REGULAR,
        ]);

        $table->save();

    }
}