daikon-cqrs / dbal

        return $executedMigrations;

    }

    private function migrateUp(int $version = null): MigrationList

    {

        $migrationList = $this->getMigrationList();

        $pendingMigrations = $migrationList->getPendingMigrations();

        $executedMigrations = $migrationList->getExecutedMigrations();

        if ($version && !$pendingMigrations->containsVersion($version)) {

            throw new MigrationException(sprintf('Target version %s not found in pending migrations.', $version));

        }

        $completedMigrations = [];

        $connector = $this->migrationAdapter->getConnector();

        foreach ($pendingMigrations as $migration) {

            $migration->execute($connector, MigrationInterface::MIGRATE_UP);

            $executedMigrations = $executedMigrations->push($migration);

            $this->migrationAdapter->write($this->name, $executedMigrations);

            $completedMigrations[] = $migration;

            if ($version && $migration->getVersion() === $version) {

                break;

            }

        }

        return new MigrationList($completedMigrations);

    }

    private function migrateDown(int $version = null): MigrationList

    {

        return new MigrationList($completedMigrations);

    }

    private function migrateDown(int $version = null): MigrationList

    {

        $migrationList = $this->getMigrationList();

        $executedMigrations = $migrationList->getExecutedMigrations();

        if ($version && !$executedMigrations->containsVersion($version)) {

            throw new MigrationException(sprintf('Target version %s not found in executed migrations.', $version));

        }

        $completedMigrations = [];

        $connector = $this->migrationAdapter->getConnector();

        foreach ($executedMigrations->reverse() as $migration) {

            if ($version && $migration->getVersion() === $version) {

                break;

            }

            $migration->execute($connector, MigrationInterface::MIGRATE_DOWN);

            $executedMigrations = $executedMigrations->remove($migration);

            if ($executedMigrations->count() > 0) {

                /*

                 * Do not write version info after reversing initial migration since we have

                 * an assumption that the database was deleted!

                 */

                $this->migrationAdapter->write($this->name, $executedMigrations);

            }

            $completedMigrations[] = $migration;

        }

        return new MigrationList($completedMigrations);

    }

}