1#@!#!123s

: / opt / psa / admin / plib / modules / composer / vendor / plesk / db-upgrader / tests / php / Db /
Filename : MigrationTest.php
back
<?php

namespace {
    // Copyright 1999-2022. Parallels IP Holdings GmbH. All Rights Reserved.
    use PleskExt\Upgrader\Migration;
    use PleskExt\Upgrader\Versions;
    use PleskExt\Upgrader\Exception;
    class Db_MigrationTest extends PHPUnit\Framework\TestCase
    {
        const START_DB_VERSION = '201512310101';
        private $_dbAdapter = null;
        public function setUp() : void
        {
            $this->_dbAdapter = \Zend_Db::factory('Pdo_Sqlite', array('dbname' => ':memory:'));
            $this->_dbAdapter->query(<<<QUERY
CREATE TABLE IF NOT EXISTS `version` (
  `id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
  `dbVersion` TEXT NOT NULL
)
QUERY
);
            $this->_dbAdapter->query("INSERT INTO `version` (`dbVersion`) VALUES ('" . static::START_DB_VERSION . "');");
        }
        public function tearDown() : void
        {
            $this->_dbAdapter = null;
        }
        private function _getDatabaseDump(\Zend_Db_Adapter_Abstract $dbAdapter, array $skipTables = ['sqlite_sequence', 'version'])
        {
            $dump = [];
            foreach ($dbAdapter->listTables() as $table) {
                if (\in_array($table, $skipTables)) {
                    continue;
                }
                $dump[$table] = ['structure' => $dbAdapter->describeTable($table), 'rows' => $dbAdapter->fetchAssoc("SELECT * FROM `{$table}`")];
            }
            return $dump;
        }
        /**
         * @param $expectations
         * @dataProvider failedMigrations
         */
        public function testFailedMigration($expectations)
        {
            $migration = new Migration($expectations['migrationFile']);
            $versionsBroker = new Versions(['db' => $this->_dbAdapter]);
            $this->assertEquals(static::START_DB_VERSION, $versionsBroker->getDbVersion());
            $exceptionFlag = \false;
            try {
                $migration->run($this->_dbAdapter);
            } catch (Exception $e) {
                $exceptionFlag = \true;
            }
            $this->assertEquals($expectations['resultDbVersion'], $versionsBroker->getDbVersion());
            $dump = $this->_getDatabaseDump($this->_dbAdapter);
            $this->assertEquals($expectations['resultSchema'], $dump);
            $this->assertEquals($expectations['wasException'], $exceptionFlag);
        }
        private static function _getMigrationsDir()
        {
            return __DIR__ . "/../../data/Migrations/failingMigrations";
        }
        public static function failedMigrations()
        {
            return [[['migrationFile' => static::_getMigrationsDir() . '/201602020202_FailingMigration1.sql', 'resultDbVersion' => static::START_DB_VERSION, 'resultSchema' => [], 'wasException' => \true]], [['migrationFile' => static::_getMigrationsDir() . '/201602020203_FailingMigration2.sql', 'resultDbVersion' => static::START_DB_VERSION, 'resultSchema' => [], 'wasException' => \true]], [['migrationFile' => static::_getMigrationsDir() . '/201601010101_Migration.sql', 'resultDbVersion' => '201601010101', 'resultSchema' => ['table1' => ['structure' => ['id' => ['SCHEMA_NAME' => '', 'TABLE_NAME' => 'table1', 'COLUMN_NAME' => 'id', 'COLUMN_POSITION' => 1, 'DATA_TYPE' => 'INTEGER', 'DEFAULT' => null, 'NULLABLE' => \false, 'LENGTH' => null, 'SCALE' => null, 'PRECISION' => null, 'UNSIGNED' => null, 'PRIMARY' => \true, 'PRIMARY_POSITION' => 1, 'IDENTITY' => \true], 'col1' => ['SCHEMA_NAME' => '', 'TABLE_NAME' => 'table1', 'COLUMN_NAME' => 'col1', 'COLUMN_POSITION' => 2, 'DATA_TYPE' => 'TEXT', 'DEFAULT' => null, 'NULLABLE' => \false, 'LENGTH' => null, 'SCALE' => null, 'PRECISION' => null, 'UNSIGNED' => null, 'PRIMARY' => \false, 'PRIMARY_POSITION' => null, 'IDENTITY' => \false]], 'rows' => []]], 'wasException' => \false]]];
        }
    }
}