Sunnysideup\MigrateData\Tasks\MigrateDataTask

Complexity

Total Complexity

6

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	21
Bugs	6	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	performMigration()	0	27	6

<?php

namespace Sunnysideup\MigrateData\Tasks;

use SilverStripe\Core\Config\Config;

class MigrateDataTask extends MigrateDataTaskBase
{
    protected $title = 'Migrate Data';

    protected $description = 'Migrates specific data defined in yml';

    protected $enabled = true;

    /**
     * an array that is formatted like this:
     *     Name => [
     *         pre_sql_queries: [
     *             - 'SELECT * FROM FOO'
     *         ],
     *         data => [
     *               [
     *                   'include_inserts' => true|false, #assumed true if not provided
     *                   'old_table' => 'foo',
     *                   'new_table' => 'bar' (can be the same!).
     *
     *                   'simple_move_fields' => ['A', 'B', 'C']
     *                       ---  OR ----
     *                   'complex_move_fields' => ['A' => 'Anew', 'B' => 'BBew', 'C2' => 'Cnew']
     *                ]
     *         ]
     *         publish_classes => [
     *             - MyClassName1
     *             - MyClassName2
     *         ]
     *         post_sql_queries => [
     *             - 'SELECT * FROM FOO'
     *         ]
     *
     *     ]
     *
     * @var array
     */
    private static $items_to_migrate = [];

    /**
     * Queries the config for Migrate definitions, and runs migrations
     * if you extend this task then overwrite it this method.
     */
    protected function performMigration()
    {
        $fullList = Config::inst()->get(self::class, 'items_to_migrate');
        foreach ($fullList as $item => $details) {
            $this->flushNow('<h2>Starting Migration for ' . $item . '</h2>');

            if (isset($details['pre_sql_queries'])) {
                $preSqlQueries = $details['pre_sql_queries'];
                $this->runSQLQueries($preSqlQueries, 'PRE');
            }

            if (isset($details['data'])) {
                $data = $details['data'];
                $this->runMoveData($data);
            }

            if (isset($details['publish_classes'])) {
                $publishClasses = $details['publish_classes'];
                $this->runPublishClasses($publishClasses);
            }

            if (isset($details['post_sql_queries'])) {
                $postSqlQueries = $details['post_sql_queries'];
                $this->runSQLQueries($postSqlQueries, 'POST');
            }

            $this->flushNow('<h2>Finish Migration for ' . $item . '</h2>');
        }
    }
}