+use phpbb\db\output_handler\migrator_output_handler_interface;

+<?php

+/**

+*

+* This file is part of the phpBB Forum Software package.

+*

+* @copyright (c) phpBB Limited <https://www.phpbb.com>

+* @license GNU General Public License, version 2 (GPL-2.0)

+*

+* For full copyright and license information, please see

+* the docs/CREDITS.txt file.

+*

+*/

+namespace phpbb\console\command\db;

+

+use Symfony\Component\Console\Input\InputInterface;

+use Symfony\Component\Console\Input\InputOption;

+use Symfony\Component\Console\Output\OutputInterface;

+use Symfony\Component\Console\Style\SymfonyStyle;

+

+class list_command extends \phpbb\console\command\db\migration_command

+{

+ protected function configure()

+ {

+ $this

+ ->setName('db:list')

+ ->setDescription($this->user->lang('CLI_DESCRIPTION_DB_LIST'))

+ ->addOption(

+ 'available',

+ 'u',

+ InputOption::VALUE_NONE,

+ $this->user->lang('CLI_MIGRATIONS_ONLY_AVAILABLE')

+ )

+ ;

+ }

+

+ protected function execute(InputInterface $input, OutputInterface $output)

+ {

+ $io = new SymfonyStyle($input, $output);

+

+ $show_installed = !$input->getOption('available');

+ $installed = $available = array();

+

+ foreach ($this->load_migrations() as $name)

+ {

+ if ($this->migrator->migration_state($name) !== false)

+ {

+ $installed[] = $name;

+ }

+ else

+ {

+ $available[] = $name;

+ }

+ }

+

+ if ($show_installed)

+ {

+ $io->section($this->user->lang('CLI_MIGRATIONS_INSTALLED'));

+

+ if (!empty($installed))

+ {

+ $io->listing($installed);

+ }

+ else

+ {

+ $io->text($this->user->lang('CLI_MIGRATIONS_EMPTY'));

+ $io->newLine();

+ }

+ }

+

+ $io->section($this->user->lang('CLI_MIGRATIONS_AVAILABLE'));

+ if (!empty($available))

+ {

+ $io->listing($available);

+ }

+ else

+ {

+ $io->text($this->user->lang('CLI_MIGRATIONS_EMPTY'));

+ $io->newLine();

+ }

+ }

+}

+use phpbb\db\output_handler\log_wrapper_migrator_output_handler;

+use Symfony\Component\Console\Style\SymfonyStyle;

+class migrate extends \phpbb\console\command\db\migration_command

+ /** @var \phpbb\filesystem\filesystem_interface */

+ protected $filesystem;

+

+ /** @var \phpbb\language\language */

+ protected $language;

+

+ public function __construct(\phpbb\user $user, \phpbb\language\language $language, \phpbb\db\migrator $migrator, \phpbb\extension\manager $extension_manager, \phpbb\config\config $config, \phpbb\cache\service $cache, \phpbb\log\log $log, \phpbb\filesystem\filesystem_interface $filesystem, $phpbb_root_path)

+ $this->language = $language;

+ $this->filesystem = $filesystem;

+ parent::__construct($user, $migrator, $extension_manager, $config, $cache);

+ $this->language->add_lang(array('common', 'install', 'migrator'));

+ ->setDescription($this->language->lang('CLI_DESCRIPTION_DB_MIGRATE'))

+ $io = new SymfonyStyle($input, $output);

+

+ $this->migrator->set_output_handler(new log_wrapper_migrator_output_handler($this->language, new console_migrator_output_handler($this->user, $output), $this->phpbb_root_path . 'store/migrations_' . time() . '.log', $this->filesystem));

+ $io->error($e->getLocalisedMessage($this->user));

+ $io->success($this->language->lang('INLINE_UPDATE_SUCCESSFUL'));

+<?php

+/**

+*

+* This file is part of the phpBB Forum Software package.

+*

+* @copyright (c) phpBB Limited <https://www.phpbb.com>

+* @license GNU General Public License, version 2 (GPL-2.0)

+*

+* For full copyright and license information, please see

+* the docs/CREDITS.txt file.

+*

+*/

+namespace phpbb\console\command\db;

+

+abstract class migration_command extends \phpbb\console\command\command

+{

+ /** @var \phpbb\db\migrator */

+ protected $migrator;

+

+ /** @var \phpbb\extension\manager */

+ protected $extension_manager;

+

+ /** @var \phpbb\config\config */

+ protected $config;

+

+ /** @var \phpbb\cache\service */

+ protected $cache;

+

+ public function __construct(\phpbb\user $user, \phpbb\db\migrator $migrator, \phpbb\extension\manager $extension_manager, \phpbb\config\config $config, \phpbb\cache\service $cache)

+ {

+ $this->migrator = $migrator;

+ $this->extension_manager = $extension_manager;

+ $this->config = $config;

+ $this->cache = $cache;

+ parent::__construct($user);

+ }

+

+ protected function load_migrations()

+ {

+ $migrations = $this->extension_manager

+ ->get_finder()

+ ->core_path('phpbb/db/migration/data/')

+ ->extension_directory('/migrations')

+ ->get_classes();

+

+ $this->migrator->set_migrations($migrations);

+

+ return $this->migrator->get_migrations();

+ }

+

+ protected function finalise_update()

+ {

+ $this->cache->purge();

+ $this->config->increment('assets_version', 1);

+ }

+}

+<?php

+/**

+*

+* This file is part of the phpBB Forum Software package.

+*

+* @copyright (c) phpBB Limited <https://www.phpbb.com>

+* @license GNU General Public License, version 2 (GPL-2.0)

+*

+* For full copyright and license information, please see

+* the docs/CREDITS.txt file.

+*

+*/

+namespace phpbb\console\command\db;

+

+use phpbb\db\output_handler\log_wrapper_migrator_output_handler;

+use Symfony\Component\Console\Input\InputArgument;

+use Symfony\Component\Console\Input\InputInterface;

+use Symfony\Component\Console\Output\OutputInterface;

+use Symfony\Component\Console\Style\SymfonyStyle;

+

+class revert extends \phpbb\console\command\db\migrate

+{

+ protected function configure()

+ {

+ $this

+ ->setName('db:revert')

+ ->setDescription($this->language->lang('CLI_DESCRIPTION_DB_REVERT'))

+ ->addArgument(

+ 'name',

+ InputArgument::REQUIRED,

+ $this->language->lang('CLI_MIGRATION_NAME')

+ )

+ ;

+ }

+

+ protected function execute(InputInterface $input, OutputInterface $output)

+ {

+ $io = new SymfonyStyle($input, $output);

+

+ $name = str_replace('/', '\\', $input->getArgument('name'));

+

+ $this->migrator->set_output_handler(new log_wrapper_migrator_output_handler($this->language, new console_migrator_output_handler($this->user, $output), $this->phpbb_root_path . 'store/migrations_' . time() . '.log', $this->filesystem));

+

+ $this->cache->purge();

+

+ if (!in_array($name, $this->load_migrations()))

+ {

+ $io->error($this->language->lang('MIGRATION_NOT_VALID', $name));

+ return 1;

+ }

+ else if ($this->migrator->migration_state($name) === false)

+ {

+ $io->error($this->language->lang('MIGRATION_NOT_INSTALLED', $name));

+ return 1;

+ }

+

+ try

+ {

+ while ($this->migrator->migration_state($name) !== false)

+ {

+ $this->migrator->revert($name);

+ }

+ }

+ catch (\phpbb\db\migration\exception $e)

+ {

+ $io->error($e->getLocalisedMessage($this->user));

+ $this->finalise_update();

+ return 1;

+ }

+

+ $this->finalise_update();

+ $io->success($this->language->lang('INLINE_UPDATE_SUCCESSFUL'));

+ }

+}