+ /* @var $provider_collection \phpbb\auth\provider_collection */

+ /* @var $captcha_factory \phpbb\captcha\factory */

+ /** @var \fastImageSize\fastImageSize */

+ protected $imagesize;

+

+ * @param \fastImageSize\fastImageSize $imagesize fastImageSize class

+ public function __construct(\phpbb\config\config $config, \fastImageSize\fastImageSize $imagesize, $phpbb_root_path, $php_ext, \phpbb\path_helper $path_helper, \phpbb\cache\driver\driver_interface $cache = null)

+ $this->imagesize = $imagesize;

+ // Get image dimensions if they are not set

+ if ($row['avatar_width'] <= 0 || $row['avatar_height'] <= 0)

+ if (($row['avatar_width'] <= 0 || $row['avatar_height'] <= 0) && (($image_data = $this->imagesize->getImageSize($url)) === false))

+ if (!empty($image_data) && ($image_data['width'] <= 0 || $image_data['width'] <= 0))

+ $row['avatar_width'] = ($row['avatar_width'] && $row['avatar_height']) ? $row['avatar_width'] : $image_data['width'];

+ $row['avatar_height'] = ($row['avatar_width'] && $row['avatar_height']) ? $row['avatar_height'] : $image_data['height'];

+ $dims = $this->imagesize->getImageSize($file_path . '/' . $image);

+

+ if ($dims === false)

+ $dims = array(0, 0);

+ $dims = array($dims['width'], $dims['height']);

+ // Get image dimensions

+ if (($width <= 0 || $height <= 0) && (($image_data = $this->imagesize->getImageSize($url)) === false))

+ $error[] = 'UNABLE_GET_IMAGE_SIZE';

+ return false;

+ }

+ if (!empty($image_data) && ($image_data['width'] <= 0 || $image_data['height'] <= 0))

+ {

+ $error[] = 'AVATAR_NO_SIZE';

+ return false;

+ $width = ($width && $height) ? $width : $image_data['width'];

+ $height = ($width && $height) ? $height : $image_data['height'];

+

+ if (!empty($image_data) && (!isset($types[$image_data['type']]) || !in_array($extension, $types[$image_data['type']])))

+ if (!isset($types[$image_data['type']]))

+ $error[] = array('IMAGE_FILETYPE_MISMATCH', $types[$image_data['type']][0], $extension);

+ * @var \phpbb\filesystem\filesystem_interface

+ */

+ protected $filesystem;

+

+ /**

+ * @param \phpbb\filesystem\filesystem_interface phpBB filesystem helper

+ * @param \phpbb\path_helper $path_helper phpBB path helper

+ public function __construct(\phpbb\config\config $config, $phpbb_root_path, $php_ext, \phpbb\filesystem\filesystem_interface $filesystem, \phpbb\path_helper $path_helper, \phpbb\mimetype\guesser $mimetype_guesser, \phpbb\event\dispatcher_interface $dispatcher, \phpbb\cache\driver\driver_interface $cache = null)

+ $this->filesystem = $filesystem;

+ $upload = new \fileupload($this->filesystem, 'AVATAR_', $this->allowed_extensions, $this->config['avatar_filesize'], $this->config['avatar_min_width'], $this->config['avatar_min_height'], $this->config['avatar_max_width'], $this->config['avatar_max_height'], (isset($this->config['mime_triggers']) ? explode('|', $this->config['mime_triggers']) : false));

+ return (file_exists($this->phpbb_root_path . $this->config['avatar_path']) && $this->filesystem->is_writable($this->phpbb_root_path . $this->config['avatar_path']) && (@ini_get('file_uploads') || strtolower(@ini_get('file_uploads')) == 'on'));

+ strpos($filename, 'url_generator') === 0 ||

+ $query_id = md5($query);

+ if (($result = $this->_read('sql_' . $query_id)) === false)

+ $this->sql_rowset[$query_id] = $result;

+ global $phpbb_filesystem;

+ if ($check && !$phpbb_filesystem->is_writable($this->cache_dir))

+* ACM dummy Caching

+class dummy extends \phpbb\cache\driver\base

+ global $config;

+

+ $config->set('cache_last_gc', time(), false);

+ global $config;

+

+ $config->set('cache_last_gc', time(), false);

+ * @var \phpbb\filesystem\filesystem_interface

+ */

+ protected $filesystem;

+

+ /**

+ global $phpbb_root_path, $phpbb_container;

+

+ $this->cache_dir = !is_null($cache_dir) ? $cache_dir : $phpbb_root_path . 'cache/' . $phpbb_container->getParameter('core.environment') . '/';

+ $this->filesystem = new \phpbb\filesystem\filesystem();

+

+ if (!is_dir($this->cache_dir))

+ {

+ @mkdir($this->cache_dir, 0777, true);

+ }

+ if (!$this->filesystem->is_writable($this->cache_dir))

+ global $config, $phpEx;

+ $config->set('cache_last_gc', time(), false);

+ $query_id = md5($query);

+ if ($this->_write('sql_' . $query_id, $this->sql_rowset[$query_id], $ttl + time(), $query))

+ try

+ $this->filesystem->phpbb_chmod($file, CHMOD_READ | CHMOD_WRITE);

+ }

+ catch (\phpbb\filesystem\exception\filesystem_exception $e)

+ {

+ // Do nothing

+ global $config;

+ // cache has auto GC, no need to have any code here :)

+ $config->set('cache_last_gc', time(), false);

+ $query_id = md5($query);

+ $temp[$query_id] = true;

+ $this->_write('sql_' . $query_id, $this->sql_rowset[$query_id], $ttl);

+ global $config, $db, $user, $request;

+ $this->confirm_id = $request->variable('confirm_id', '');

+ $this->confirm_code = $request->variable('confirm_code', '');

+ $refresh = $request->variable('refresh_vc', false) && $config['confirm_refresh'];

+ global $config, $user, $template, $request, $phpbb_admin_path, $phpEx;

+ $variables .= '&amp;' . rawurlencode($captcha_var) . '=' . $request->variable($captcha_var, (int) $config[$captcha_var]);

+ if (!$user->is_setup())

+ global $request;

+

+ if ($request->variable('confirm_code', false) && $this->solved === 0)

+ global $db, $user, $auth, $template, $phpbb_log, $request;

+ $submit = $request->variable('submit', '');

+ $value = $request->variable($captcha_var, 0);

+ $config->set($captcha_var, $value);

+ $phpbb_log->add('admin', $user->data['user_id'], $user->ip, 'LOG_CONFIG_VISUAL');

+ $var = (isset($_REQUEST[$captcha_var])) ? $request->variable($captcha_var, 0) : $config[$captcha_var];

+ global $config, $request;

+ $config->set($captcha_var, $request->variable($captcha_var, (int) $config[$captcha_var]));

+ global $config, $db, $user, $request;

+ $this->confirm_id = $request->variable('qa_confirm_id', '');

+ $this->answer = $request->variable('qa_answer', '', true);

+ global $phpbb_container;

+ $db_tool = $phpbb_container->get('dbal.tools');

+ global $phpbb_container;

+ $db_tool = $phpbb_container->get('dbal.tools');

+ global $db, $request;

+ $answer = ($this->question_strict) ? $request->variable('qa_answer', '', true) : utf8_clean_string($request->variable('qa_answer', '', true));

+ global $request;

+

+ if ($request->variable('qa_answer', false) && $this->solved === 0)

+ global $config, $request, $phpbb_log, $template, $user;

+ $submit = $request->variable('submit', false);

+ $question_id = $request->variable('question_id', 0);

+ $action = $request->variable('action', '');

+ $phpbb_log->add('admin', $user->data['user_id'], $user->ip, 'LOG_CONFIG_VISUAL');

+ global $request;

+

+ $answers = $request->variable('answers', '', true);

+ 'question_text' => $request->variable('question_text', '', true),

+ 'strict' => $request->variable('strict', false),

+ 'lang_iso' => $request->variable('lang_iso', ''),

+ global $config, $db, $user, $request;

+ $this->challenge = $request->variable('recaptcha_challenge_field', '');

+ $this->response = $request->variable('recaptcha_response_field', '');

+ global $config, $db, $template, $user, $phpbb_log, $request;

+ $submit = $request->variable('submit', '');

+ $value = $request->variable($captcha_var, '');

+ $config->set($captcha_var, $value);

+ $phpbb_log->add('admin', $user->data['user_id'], $user->ip, 'LOG_CONFIG_VISUAL');

+ $var = (isset($_REQUEST[$captcha_var])) ? $request->variable($captcha_var, '') : ((isset($config[$captcha_var])) ? $config[$captcha_var] : '');

+ "php": ">=5.3.9"

+ * @var \phpbb\language\language User object

+ protected $language;

+ * @param string $name The name of the application

+ * @param string $version The version of the application

+ * @param \phpbb\language\language $language The user which runs the application (used for translation)

+ public function __construct($name, $version, \phpbb\language\language $language)

+ $this->language = $language;

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

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

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

+ protected $filesystem;

+

+ function __construct(\phpbb\user $user, \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->filesystem = $filesystem;

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

+<?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\reparser;

+

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

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

+

+class list_all extends \phpbb\console\command\command

+{

+ /**

+ * @var string[] Names of the reparser services

+ */

+ protected $reparser_names;

+

+ /**

+ * Constructor

+ *

+ * @param \phpbb\user $user

+ * @param \phpbb\di\service_collection $reparsers

+ */

+ public function __construct(\phpbb\user $user, \phpbb\di\service_collection $reparsers)

+ {

+ parent::__construct($user);

+ $this->reparser_names = array();

+ foreach ($reparsers as $name => $reparser)

+ {

+ // Store the names without the "text_reparser." prefix

+ $this->reparser_names[] = preg_replace('(^text_reparser\\.)', '', $name);

+ }

+ }

+

+ /**

+ * Sets the command name and description

+ *

+ * @return null

+ */

+ protected function configure()

+ {

+ $this

+ ->setName('reparser:list')

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

+ ;

+ }

+

+ /**

+ * Executes the command reparser:reparse

+ *

+ * @param InputInterface $input

+ * @param OutputInterface $output

+ * @return integer

+ */

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

+ {

+ $output->writeln('<info>' . implode(', ', $this->reparser_names) . '</info>');

+

+ return 0;

+ }

+}

+<?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\reparser;

+

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

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

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

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

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

+

+class reparse extends \phpbb\console\command\command

+{

+ /**

+ * @var \phpbb\config\db_text

+ */

+ protected $config_text;

+

+ /**

+ * @var InputInterface

+ */

+ protected $input;

+

+ /**

+ * @var SymfonyStyle

+ */

+ protected $io;

+

+ /**

+ * @var OutputInterface

+ */

+ protected $output;

+

+ /**

+ * @var \phpbb\di\service_collection

+ */

+ protected $reparsers;

+

+ /**

+ * @var array Reparser names as keys, and their last $current ID as values

+ */

+ protected $resume_data;

+

+ /**

+ * Constructor

+ *

+ * @param \phpbb\user $user

+ * @param \phpbb\di\service_collection $reparsers

+ * @param \phpbb\config\db_text $config_text

+ */

+ public function __construct(\phpbb\user $user, \phpbb\di\service_collection $reparsers, \phpbb\config\db_text $config_text)

+ {

+ require_once __DIR__ . '/../../../../includes/functions_content.php';

+

+ $this->config_text = $config_text;

+ $this->reparsers = $reparsers;

+ parent::__construct($user);

+ }

+

+ /**

+ * Sets the command name and description

+ *

+ * @return null

+ */

+ protected function configure()

+ {

+ $this

+ ->setName('reparser:reparse')

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

+ ->addArgument('reparser-name', InputArgument::OPTIONAL, $this->user->lang('CLI_DESCRIPTION_REPARSER_REPARSE_ARG_1'))

+ ->addOption(

+ 'dry-run',

+ null,

+ InputOption::VALUE_NONE,

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

+ )

+ ->addOption(

+ 'resume',

+ null,

+ InputOption::VALUE_NONE,

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

+ )

+ ->addOption(

+ 'range-min',

+ null,

+ InputOption::VALUE_REQUIRED,

+ $this->user->lang('CLI_DESCRIPTION_REPARSER_REPARSE_OPT_RANGE_MIN'),

+ 1

+ )

+ ->addOption(

+ 'range-max',

+ null,

+ InputOption::VALUE_REQUIRED,

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

+ )

+ ->addOption(

+ 'range-size',

+ null,

+ InputOption::VALUE_REQUIRED,

+ $this->user->lang('CLI_DESCRIPTION_REPARSER_REPARSE_OPT_RANGE_SIZE'),

+ 100

+ );

+ ;

+ }

+

+ /**

+ * Create a styled progress bar

+ *

+ * @param integer $max Max value for the progress bar

+ * @return \Symfony\Component\Console\Helper\ProgressBar

+ */

+ protected function create_progress_bar($max)

+ {

+ $progress = $this->io->createProgressBar($max);

+ if ($this->output->getVerbosity() === OutputInterface::VERBOSITY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%percent:3s%%]</info> %message%');

+ $progress->setOverwrite(false);

+ }

+ else if ($this->output->getVerbosity() >= OutputInterface::VERBOSITY_VERY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%current:s%/%max:s%]</info><comment>[%elapsed%/%estimated%][%memory%]</comment> %message%');

+ $progress->setOverwrite(false);

+ }

+ else

+ {

+ $this->io->newLine(2);

+ $progress->setFormat(

+ " %current:s%/%max:s% %bar% %percent:3s%%\n" .

+ " %message% %elapsed:6s%/%estimated:-6s% %memory:6s%\n");

+ $progress->setBarWidth(60);

+ }

+

+ if (!defined('PHP_WINDOWS_VERSION_BUILD'))

+ {

+ $progress->setEmptyBarCharacter('░'); // light shade character \u2591

+ $progress->setProgressCharacter('');

+ $progress->setBarCharacter('▓'); // dark shade character \u2593

+ }

+

+ return $progress;

+ }

+

+ /**

+ * Executes the command reparser:reparse

+ *

+ * @param InputInterface $input

+ * @param OutputInterface $output

+ * @return integer

+ */

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

+ {

+ $this->input = $input;

+ $this->output = $output;

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

+ $this->load_resume_data();

+

+ $name = $input->getArgument('reparser-name');

+ if (isset($name))

+ {

+ // Allow "post_text" to be an alias for "text_reparser.post_text"

+ if (!isset($this->reparsers[$name]))

+ {

+ $name = 'text_reparser.' . $name;

+ }

+ $this->reparse($name);

+ }

+ else

+ {

+ foreach ($this->reparsers as $name => $service)

+ {

+ $this->reparse($name);

+ }

+ }

+

+ $this->io->success($this->user->lang('CLI_REPARSER_REPARSE_SUCCESS'));

+

+ return 0;

+ }

+

+ /**

+ * Get an option value, adjusted for given reparser

+ *

+ * Will use the last saved value if --resume is set and the option was not specified

+ * on the command line

+ *

+ * @param string $reparser_name Reparser name

+ * @param string $option_name Option name

+ * @return integer

+ */

+ protected function get_option($reparser_name, $option_name)

+ {

+ // Return the option from the resume_data if applicable

+ if ($this->input->getOption('resume') && isset($this->resume_data[$reparser_name][$option_name]) && !$this->input->hasParameterOption('--' . $option_name))

+ {

+ return $this->resume_data[$reparser_name][$option_name];

+ }

+

+ $value = $this->input->getOption($option_name);

+

+ // range-max has no default value, it must be computed for each reparser

+ if ($option_name === 'range-max' && $value === null)

+ {

+ $value = $this->reparsers[$reparser_name]->get_max_id();

+ }

+

+ return $value;

+ }

+

+ /**

+ * Load the resume data from the database

+ */

+ protected function load_resume_data()

+ {

+ $resume_data = $this->config_text->get('reparser_resume');

+ $this->resume_data = (empty($resume_data)) ? array() : unserialize($resume_data);

+ }

+

+ /**

+ * Reparse all text handled by given reparser within given range

+ *

+ * @param string $name Reparser name

+ */

+ protected function reparse($name)

+ {

+ $reparser = $this->reparsers[$name];

+ if ($this->input->getOption('dry-run'))

+ {

+ $reparser->disable_save();

+ }

+ else

+ {

+ $reparser->enable_save();

+ }

+

+ // Start at range-max if specified or at the highest ID otherwise

+ $max = $this->get_option($name, 'range-max');

+ $min = $this->get_option($name, 'range-min');

+ $size = $this->get_option($name, 'range-size');

+

+ if ($max < $min)

+ {

+ return;

+ }

+

+ $this->io->section($this->user->lang('CLI_REPARSER_REPARSE_REPARSING', preg_replace('(^text_reparser\\.)', '', $name), $min, $max));

+

+ $progress = $this->create_progress_bar($max);

+ $progress->setMessage($this->user->lang('CLI_REPARSER_REPARSE_REPARSING_START', preg_replace('(^text_reparser\\.)', '', $name)));

+ $progress->start();

+

+ // Start from $max and decrement $current by $size until we reach $min

+ $current = $max;

+ while ($current >= $min)

+ {

+ $start = max($min, $current + 1 - $size);

+ $end = max($min, $current);

+

+ $progress->setMessage($this->user->lang('CLI_REPARSER_REPARSE_REPARSING', preg_replace('(^text_reparser\\.)', '', $name), $start, $end));

+ $reparser->reparse_range($start, $end);

+

+ $current = $start - 1;

+ $progress->setProgress($max + 1 - $start);

+

+ $this->update_resume_data($name, $current);

+ }

+ $progress->finish();

+

+ $this->io->newLine(2);

+ }

+

+ /**

+ * Save the resume data to the database

+ */

+ protected function save_resume_data()

+ {

+ $this->config_text->set('reparser_resume', serialize($this->resume_data));

+ }

+

+ /**

+ * Save the resume data to the database

+ *

+ * @param string $name Reparser name

+ * @param string $current Current ID

+ */

+ protected function update_resume_data($name, $current)

+ {

+ $this->resume_data[$name] = array(

+ 'range-min' => $this->get_option($name, 'range-min'),

+ 'range-max' => $current,

+ 'range-size' => $this->get_option($name, 'range-size'),

+ );

+ $this->save_resume_data();

+ }

+}

+<?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\thumbnail;

+

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

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

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

+

+class delete extends \phpbb\console\command\command

+{

+ /**

+ * @var \phpbb\db\driver\driver_interface

+ */

+ protected $db;

+

+ /**

+ * phpBB root path

+ * @var string

+ */

+ protected $phpbb_root_path;

+

+ /**

+ * Constructor

+ *

+ * @param \phpbb\user $user The user object (used to get language information)

+ * @param \phpbb\db\driver\driver_interface $db Database connection

+ * @param string $phpbb_root_path Root path

+ */

+ public function __construct(\phpbb\user $user, \phpbb\db\driver\driver_interface $db, $phpbb_root_path)

+ {

+ $this->db = $db;

+ $this->phpbb_root_path = $phpbb_root_path;

+

+ parent::__construct($user);

+ }

+

+ /**

+ * Sets the command name and description

+ *

+ * @return null

+ */

+ protected function configure()

+ {

+ $this

+ ->setName('thumbnail:delete')

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

+ ;

+ }

+

+ /**

+ * Executes the command thumbnail:delete.

+ *

+ * Deletes all existing thumbnails and updates the database accordingly.

+ *

+ * @param InputInterface $input The input stream used to get the argument and verbose option.

+ * @param OutputInterface $output The output stream, used for printing verbose-mode and error information.

+ *

+ * @return int 0 if all is ok, 1 if a thumbnail couldn't be deleted.

+ */

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

+ {

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

+

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

+

+ $sql = 'SELECT COUNT(*) AS nb_missing_thumbnails

+ FROM ' . ATTACHMENTS_TABLE . '

+ WHERE thumbnail = 1';

+ $result = $this->db->sql_query($sql);

+ $nb_missing_thumbnails = (int) $this->db->sql_fetchfield('nb_missing_thumbnails');

+ $this->db->sql_freeresult($result);

+

+ if ($nb_missing_thumbnails === 0)

+ {

+ $io->warning($this->user->lang('CLI_THUMBNAIL_NOTHING_TO_DELETE'));

+ return 0;

+ }

+

+ $sql = 'SELECT attach_id, physical_filename, extension, real_filename, mimetype

+ FROM ' . ATTACHMENTS_TABLE . '

+ WHERE thumbnail = 1';

+ $result = $this->db->sql_query($sql);

+

+ $progress = $io->createProgressBar($nb_missing_thumbnails);

+ if ($output->getVerbosity() === OutputInterface::VERBOSITY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%percent:3s%%]</info> %message%');

+ $progress->setOverwrite(false);

+ }

+ else if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%current:s%/%max:s%]</info><comment>[%elapsed%/%estimated%][%memory%]</comment> %message%');

+ $progress->setOverwrite(false);

+ }

+ else

+ {

+ $io->newLine(2);

+ $progress->setFormat(

+ " %current:s%/%max:s% %bar% %percent:3s%%\n" .

+ " %elapsed:6s%/%estimated:-6s% %memory:6s%\n");

+ $progress->setBarWidth(60);

+ }

+

+ if (!defined('PHP_WINDOWS_VERSION_BUILD'))

+ {

+ $progress->setEmptyBarCharacter('░'); // light shade character \u2591

+ $progress->setProgressCharacter('');

+ $progress->setBarCharacter('▓'); // dark shade character \u2593

+ }

+

+ $progress->setMessage($this->user->lang('CLI_THUMBNAIL_DELETING'));

+

+ $progress->start();

+

+ $thumbnail_deleted = array();

+ $return = 0;

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $thumbnail_path = $this->phpbb_root_path . 'files/thumb_' . $row['physical_filename'];

+

+ if (@unlink($thumbnail_path))

+ {

+ $thumbnail_deleted[] = $row['attach_id'];

+

+ if (sizeof($thumbnail_deleted) === 250)

+ {

+ $this->commit_changes($thumbnail_deleted);

+ $thumbnail_deleted = array();

+ }

+

+ $progress->setMessage($this->user->lang('CLI_THUMBNAIL_DELETED', $row['real_filename'], $row['physical_filename']));

+ }

+ else

+ {

+ $return = 1;

+ $progress->setMessage('<error>' . $this->user->lang('CLI_THUMBNAIL_SKIPPED', $row['real_filename'], $row['physical_filename']) . '</error>');

+ }

+

+ $progress->advance();

+ }

+ $this->db->sql_freeresult($result);

+

+ if (!empty($thumbnail_deleted))

+ {

+ $this->commit_changes($thumbnail_deleted);

+ }

+

+ $progress->finish();

+

+ $io->newLine(2);

+ $io->success($this->user->lang('CLI_THUMBNAIL_DELETING_DONE'));

+

+ return $return;

+ }

+

+ /**

+ * Commits the changes to the database

+ *

+ * @param array $thumbnail_deleted

+ */

+ protected function commit_changes(array $thumbnail_deleted)

+ {

+ $sql = 'UPDATE ' . ATTACHMENTS_TABLE . '

+ SET thumbnail = 0

+ WHERE ' . $this->db->sql_in_set('attach_id', $thumbnail_deleted);

+ $this->db->sql_query($sql);

+ }

+}

+<?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\thumbnail;

+

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

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

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

+

+class generate extends \phpbb\console\command\command

+{

+ /**

+ * @var \phpbb\db\driver\driver_interface

+ */

+ protected $db;

+

+ /**

+ * @var \phpbb\cache\service

+ */

+ protected $cache;

+

+ /**

+ * phpBB root path

+ * @var string

+ */

+ protected $phpbb_root_path;

+

+ /**

+ * PHP extension.

+ *

+ * @var string

+ */

+ protected $php_ext;

+

+ /**

+ * Constructor

+ *

+ * @param \phpbb\user $user The user object (used to get language information)

+ * @param \phpbb\db\driver\driver_interface $db Database connection

+ * @param \phpbb\cache\service $cache The cache service

+ * @param string $phpbb_root_path Root path

+ * @param string $php_ext PHP extension

+ */

+ public function __construct(\phpbb\user $user, \phpbb\db\driver\driver_interface $db, \phpbb\cache\service $cache, $phpbb_root_path, $php_ext)

+ {

+ $this->db = $db;

+ $this->cache = $cache;

+ $this->phpbb_root_path = $phpbb_root_path;

+ $this->php_ext = $php_ext;

+

+ parent::__construct($user);

+ }

+

+ /**

+ * Sets the command name and description

+ *

+ * @return null

+ */

+ protected function configure()

+ {

+ $this

+ ->setName('thumbnail:generate')

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

+ ;

+ }

+

+ /**

+ * Executes the command thumbnail:generate.

+ *

+ * Generate a thumbnail for all attachments which need one and don't have it yet.

+ *

+ * @param InputInterface $input The input stream used to get the argument and verboe option.

+ * @param OutputInterface $output The output stream, used for printing verbose-mode and error information.

+ *

+ * @return int 0.

+ */

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

+ {

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

+

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

+

+ $sql = 'SELECT COUNT(*) AS nb_missing_thumbnails

+ FROM ' . ATTACHMENTS_TABLE . '

+ WHERE thumbnail = 0';

+ $result = $this->db->sql_query($sql);

+ $nb_missing_thumbnails = (int) $this->db->sql_fetchfield('nb_missing_thumbnails');

+ $this->db->sql_freeresult($result);

+

+ if ($nb_missing_thumbnails === 0)

+ {

+ $io->warning($this->user->lang('CLI_THUMBNAIL_NOTHING_TO_GENERATE'));

+ return 0;

+ }

+

+ $extensions = $this->cache->obtain_attach_extensions(true);

+

+ $sql = 'SELECT attach_id, physical_filename, extension, real_filename, mimetype

+ FROM ' . ATTACHMENTS_TABLE . '

+ WHERE thumbnail = 0';

+ $result = $this->db->sql_query($sql);

+

+ if (!function_exists('create_thumbnail'))

+ {

+ require($this->phpbb_root_path . 'includes/functions_posting.' . $this->php_ext);

+ }

+

+ $progress = $io->createProgressBar($nb_missing_thumbnails);

+ if ($output->getVerbosity() === OutputInterface::VERBOSITY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%percent:3s%%]</info> %message%');

+ $progress->setOverwrite(false);

+ }

+ else if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERY_VERBOSE)

+ {

+ $progress->setFormat('<info>[%current:s%/%max:s%]</info><comment>[%elapsed%/%estimated%][%memory%]</comment> %message%');

+ $progress->setOverwrite(false);

+ }

+ else

+ {

+ $io->newLine(2);

+ $progress->setFormat(

+ " %current:s%/%max:s% %bar% %percent:3s%%\n" .

+ " %elapsed:6s%/%estimated:-6s% %memory:6s%\n");

+ $progress->setBarWidth(60);

+ }

+

+ if (!defined('PHP_WINDOWS_VERSION_BUILD'))

+ {

+ $progress->setEmptyBarCharacter('░'); // light shade character \u2591

+ $progress->setProgressCharacter('');

+ $progress->setBarCharacter('▓'); // dark shade character \u2593

+ }

+

+ $progress->setMessage($this->user->lang('CLI_THUMBNAIL_GENERATING'));

+

+ $progress->start();

+

+ $thumbnail_created = array();

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ if (isset($extensions[$row['extension']]['display_cat']) && $extensions[$row['extension']]['display_cat'] == ATTACHMENT_CATEGORY_IMAGE)

+ {

+ $source = $this->phpbb_root_path . 'files/' . $row['physical_filename'];

+ $destination = $this->phpbb_root_path . 'files/thumb_' . $row['physical_filename'];

+

+ if (create_thumbnail($source, $destination, $row['mimetype']))

+ {

+ $thumbnail_created[] = (int) $row['attach_id'];

+

+ if (count($thumbnail_created) === 250)

+ {

+ $this->commit_changes($thumbnail_created);

+ $thumbnail_created = array();

+ }

+

+ $progress->setMessage($this->user->lang('CLI_THUMBNAIL_GENERATED', $row['real_filename'], $row['physical_filename']));

+ }

+ else

+ {

+ $progress->setMessage('<info>' . $this->user->lang('CLI_THUMBNAIL_SKIPPED', $row['real_filename'], $row['physical_filename']) . '</info>');

+ }

+ }

+

+ $progress->advance();

+ }

+ $this->db->sql_freeresult($result);

+

+ if (!empty($thumbnail_created))

+ {

+ $this->commit_changes($thumbnail_created);

+ }

+

+ $progress->finish();

+

+ $io->newLine(2);

+ $io->success($this->user->lang('CLI_THUMBNAIL_GENERATING_DONE'));

+

+ return 0;

+ }

+

+ /**

+ * Commits the changes to the database

+ *

+ * @param array $thumbnail_created

+ */

+ protected function commit_changes(array $thumbnail_created)

+ {

+ $sql = 'UPDATE ' . ATTACHMENTS_TABLE . '

+ SET thumbnail = 1

+ WHERE ' . $this->db->sql_in_set('attach_id', $thumbnail_created);

+ $this->db->sql_query($sql);

+ }

+}

+<?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\thumbnail;

+

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

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

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

+

+class recreate extends \phpbb\console\command\command

+{

+ /**

+ * Sets the command name and description

+ *

+ * @return null

+ */

+ protected function configure()

+ {

+ $this

+ ->setName('thumbnail:recreate')

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

+ ;

+ }

+

+ /**

+ * Executes the command thumbnail:recreate.

+ *

+ * This command is a "macro" to execute thumbnail:delete and then thumbnail:generate.

+ *

+ * @param InputInterface $input The input stream used to get the argument and verboe option.

+ * @param OutputInterface $output The output stream, used for printing verbose-mode and error information.

+ *

+ * @return int 0 if all is ok, 1 if a thumbnail couldn't be deleted.

+ */

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

+ {

+ $parameters = array(

+ 'command' => 'thumbnail:delete'

+ );

+

+ if ($input->getOption('verbose'))

+ {

+ $parameters['-' . str_repeat('v', $output->getVerbosity() - 1)] = true;

+ }

+

+ $this->getApplication()->setAutoExit(false);

+

+ $input_delete = new ArrayInput($parameters);

+ $return = $this->getApplication()->run($input_delete, $output);

+

+ if ($return === 0)

+ {

+ $parameters['command'] = 'thumbnail:generate';

+

+ $input_create = new ArrayInput($parameters);

+ $return = $this->getApplication()->run($input_create, $output);

+ }

+

+ $this->getApplication()->setAutoExit(true);

+

+ return $return;

+ }

+}

+class exception extends \phpbb\exception\runtime_exception

+ /**

+ * phpBB router

+ * @var \phpbb\routing\router

+ */

+ protected $router;

+

+ * @var \phpbb\filesystem\filesystem_interface The filesystem object

+ * @param \phpbb\routing\router $router phpBB router

+ * @param \phpbb\filesystem\filesystem_interface $filesystem The filesystem object

+ public function __construct(\phpbb\template\template $template, \phpbb\user $user, \phpbb\config\config $config, \phpbb\routing\router $router, \phpbb\symfony_request $symfony_request, \phpbb\request\request_interface $request, \phpbb\filesystem\filesystem_interface $filesystem, $phpbb_root_path, $php_ext)

+ $this->router = $router;

+ $this->router->setContext($context);

+ $route_url = $this->router->generate($route, $params, $reference_type);

+ * Assigns automatic refresh time meta tag in template

+ *

+ * @param int $time time in seconds, when redirection should occur

+ * @param string $url the URL where the user should be redirected

+ * @return null

+ */

+ public function assign_meta_refresh_var($time, $url)

+ {

+ $this->template->assign_vars(array(

+ 'META' => '<meta http-equiv="refresh" content="' . $time . '; url=' . $url . '" />',

+ ));

+ }

+

+ /**

+ public function __construct(ContainerInterface $container, $phpbb_root_path, \phpbb\template\template $template = null)

+ throw new \phpbb\controller\exception('CONTROLLER_NOT_SPECIFIED');

+ throw new \phpbb\controller\exception('CONTROLLER_METHOD_NOT_SPECIFIED');

+ throw new \phpbb\controller\exception('CONTROLLER_SERVICE_UNDEFINED', array($service));

+ throw new \phpbb\controller\exception('CONTROLLER_ARGUMENT_VALUE_MISSING', array($param->getPosition() + 1, get_class($object) . ':' . $method, $param->name));

+ * If $forum_data is not given, forum id will be retrieved via $request->variable()

+ * If $forum_data is not given, forum id will be retrieved via $request->variable()

+ global $user, $phpbb_log;

+

+ $phpbb_log->add('critical', $user->data['user_id'], $user->ip, 'LOG_PLUPLOAD_TIDY_FAILED', false, array(

+ ));

+ if ($query_id)

+ if (!$query_id)

+ if (!$query_id)

+ if ($query_id)

+ $expression = str_replace(array('_', '%'), array("\_", "\%"), $expression);

+ $expression = str_replace(array(chr(0) . "\_", chr(0) . "\%"), array('_', '%'), $expression);

+ $expression = str_replace(array('_', '%'), array("\_", "\%"), $expression);

+ $expression = str_replace(array(chr(0) . "\_", chr(0) . "\%"), array('_', '%'), $expression);

+ $row = mssql_fetch_assoc($result_id);

+ mssql_free_result($result_id);

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0 && $this->query_result !== true)

+ if (!$query_id || $query_id === true)

+ $row = mssql_fetch_assoc($query_id);

+ if ($query_id === true)

+ {

+ return false;

+ }

+

+ return ($query_id) ? @mssql_data_seek($query_id, $rownum) : false;

+ if ($row = mssql_fetch_assoc($result_id))

+ mssql_free_result($result_id);

+ mssql_free_result($result_id);

+ if ($query_id === true)

+ {

+ return false;

+ }

+

+ return mssql_free_result($query_id);

+ $row = mssql_fetch_assoc($result_id);

+ mssql_free_result($result_id);

+ $row = mssql_fetch_assoc($result_id);

+ mssql_free_result($result_id);

+ while ($row = mssql_fetch_row($result))

+ mssql_free_result($result);

+ if ($result)

+ while ($void = mssql_fetch_assoc($result))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ mssql_free_result($result);

+ $row = odbc_fetch_array($result_id);

+ odbc_free_result($result_id);

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0)

+ return ($query_id) ? odbc_fetch_array($query_id) : false;

+ if (odbc_fetch_array($result_id))

+ $id = odbc_result($result_id, 1);

+ odbc_free_result($result_id);

+ odbc_free_result($result_id);

+ return odbc_free_result($query_id);

+ if ($result)

+ while ($void = odbc_fetch_array($result))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ odbc_free_result($result);

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0)

+ if (!$query_id)

+ $row = sqlsrv_fetch_array($query_id, SQLSRV_FETCH_ASSOC);

+ if ($result_id)

+ $row = sqlsrv_fetch_array($result_id);

+ sqlsrv_free_stmt($result_id);

+ return sqlsrv_free_stmt($query_id);

+ sqlsrv_next_result($result);

+ while ($row = sqlsrv_fetch_array($result))

+ sqlsrv_free_stmt($result);

+ if ($result)

+ while ($void = sqlsrv_fetch_array($result))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ sqlsrv_free_stmt($result);

+ if ($result)

+ {

+ $row = mysql_fetch_assoc($result);

+ mysql_free_result($result);

+ $modes = array_map('trim', explode(',', $row['sql_mode']));

+ }

+ else

+ {

+ $modes = array();

+ }

+ if ($result)

+ {

+ $row = mysql_fetch_assoc($result);

+ mysql_free_result($result);

+ $this->sql_server_version = $row['version'];

+ if (!empty($cache) && $use_cache)

+ {

+ $cache->put('mysql_version', $this->sql_server_version);

+ }

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0)

+ return ($query_id) ? mysql_fetch_assoc($query_id) : false;

+ return mysql_free_result($query_id);

+ while ($row = mysql_fetch_assoc($result))

+ mysql_free_result($result);

+ while ($row = mysql_fetch_assoc($result))

+ mysql_free_result($result);

+ if ($result)

+ while ($void = mysql_fetch_assoc($result))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ mysql_free_result($result);

+ if ($result)

+ $row = mysqli_fetch_assoc($result);

+ mysqli_free_result($result);

+ if ($result)

+ $row = mysqli_fetch_assoc($result);

+ mysqli_free_result($result);

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ if ($query_id)

+ $result = mysqli_fetch_assoc($query_id);

+ return ($query_id) ? @mysqli_data_seek($query_id, $rownum) : false;

+ if (!$query_id)

+ {

+ return false;

+ }

+

+ if ($query_id === true)

+ {

+ return true;

+ }

+

+ return mysqli_free_result($query_id);

+ while ($row = mysqli_fetch_assoc($result))

+ mysqli_free_result($result);

+ while ($row = mysqli_fetch_assoc($result))

+ mysqli_free_result($result);

+ if ($result)

+ while ($void = mysqli_fetch_assoc($result))

+ mysqli_free_result($result);

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0)

+ if ($query_id)

+ $result = ocifetchinto($query_id, $row, OCI_ASSOC + OCI_RETURN_NULLS);

+ if (!$query_id)

+ if ($stmt)

+ {

+ $success = @ociexecute($stmt, OCI_DEFAULT);

+ if ($success)

+ {

+ $temp_result = ocifetchinto($stmt, $temp_array, OCI_ASSOC + OCI_RETURN_NULLS);

+ ocifreestatement($stmt);

+ if ($temp_result)

+ {

+ return $temp_array['CURRVAL'];

+ }

+ else

+ {

+ return false;

+ }

+ }

+ return ocifreestatement($query_id);

+ if ($result)

+ $success = @ociexecute($result, OCI_DEFAULT);

+ if ($success)

+ {

+ $row = array();

+

+ while (ocifetchinto($result, $row, OCI_ASSOC + OCI_RETURN_NULLS))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ @ocifreestatement($result);

+ }

+ if ($query_id)

+ {

+ $row = pg_fetch_assoc($query_id, null);

+ pg_free_result($query_id);

+ $this->sql_server_version = (!empty($row['version'])) ? trim(substr($row['version'], 10)) : 0;

+ if (!empty($cache) && $use_cache)

+ {

+ $cache->put('pgsql_version', $this->sql_server_version);

+ }

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ else if (strpos($query, 'SELECT') === 0)

+ return ($query_id) ? pg_fetch_assoc($query_id, null) : false;

+ return ($query_id) ? @pg_result_seek($query_id, $rownum) : false;

+ $temp_result = pg_fetch_assoc($temp_q_id, null);

+ pg_free_result($query_id);

+ return pg_free_result($query_id);

+ while ($row = pg_fetch_assoc($result, null))

+ pg_free_result($result);

+ if ($result)

+ while ($void = pg_fetch_assoc($result, null))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ pg_free_result($result);

+ if ($result)

+ {

+ $row = sqlite_fetch_array($result, SQLITE_ASSOC);

+ $this->sql_server_version = (!empty($row['version'])) ? $row['version'] : 0;

+ if (!empty($cache) && $use_cache)

+ {

+ $cache->put('sqlite_version', $this->sql_server_version);

+ }

+ if (!$this->query_result)

+ return false;

+

+ if ($cache && $cache_ttl)

+ $this->query_result = $cache->sql_save($this, $query, $this->query_result, $cache_ttl);

+ return ($query_id) ? sqlite_fetch_array($query_id, SQLITE_ASSOC) : false;

+ return ($query_id) ? @sqlite_seek($query_id, $rownum) : false;

+ if ($result)

+ while ($void = sqlite_fetch_array($result, SQLITE_ASSOC))

+ {

+ // Take the time spent on parsing rows into account

+ }

+ if (!$this->query_result)

+ {

+ return false;

+ }

+

+ if ($result)

+ while ($void = $result->fetchArray(SQLITE3_ASSOC))

+ {

+ // Take the time spent on parsing rows into account

+ }

+<?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\db\extractor;

+

+use phpbb\db\extractor\exception\invalid_format_exception;

+use phpbb\db\extractor\exception\extractor_not_initialized_exception;

+

+/**

+ * Abstract base class for database extraction

+ */

+abstract class base_extractor implements extractor_interface

+{

+ /**

+ * @var string phpBB root path

+ */

+ protected $phpbb_root_path;

+

+ /**

+ * @var \phpbb\request\request_interface

+ */

+ protected $request;

+

+ /**

+ * @var \phpbb\db\driver\driver_interface

+ */

+ protected $db;

+

+ /**

+ * @var bool

+ */

+ protected $download;

+

+ /**

+ * @var bool

+ */

+ protected $store;

+

+ /**

+ * @var int

+ */

+ protected $time;

+

+ /**

+ * @var string

+ */

+ protected $format;

+

+ /**

+ * @var resource

+ */

+ protected $fp;

+

+ /**

+ * @var string

+ */

+ protected $write;

+

+ /**

+ * @var string

+ */

+ protected $close;

+

+ /**

+ * @var bool

+ */

+ protected $run_comp;

+

+ /**

+ * @var bool

+ */

+ protected $is_initialized;

+

+ /**

+ * Constructor

+ *

+ * @param string $phpbb_root_path

+ * @param \phpbb\request\request_interface $request

+ * @param \phpbb\db\driver\driver_interface $db

+ */

+ public function __construct($phpbb_root_path, \phpbb\request\request_interface $request, \phpbb\db\driver\driver_interface $db)

+ {

+ $this->phpbb_root_path = $phpbb_root_path;

+ $this->request = $request;

+ $this->db = $db;

+ $this->fp = null;

+

+ $this->is_initialized = false;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function init_extractor($format, $filename, $time, $download = false, $store = false)

+ {

+ $this->download = $download;

+ $this->store = $store;

+ $this->time = $time;

+ $this->format = $format;

+

+ switch ($format)

+ {

+ case 'text':

+ $ext = '.sql';

+ $open = 'fopen';

+ $this->write = 'fwrite';

+ $this->close = 'fclose';

+ $mimetype = 'text/x-sql';

+ break;

+ case 'bzip2':

+ $ext = '.sql.bz2';

+ $open = 'bzopen';

+ $this->write = 'bzwrite';

+ $this->close = 'bzclose';

+ $mimetype = 'application/x-bzip2';

+ break;

+ case 'gzip':

+ $ext = '.sql.gz';

+ $open = 'gzopen';

+ $this->write = 'gzwrite';

+ $this->close = 'gzclose';

+ $mimetype = 'application/x-gzip';

+ break;

+ default:

+ throw new invalid_format_exception();

+ break;

+ }

+

+ if ($download === true)

+ {

+ $name = $filename . $ext;

+ header('Cache-Control: private, no-cache');

+ header("Content-Type: $mimetype; name=\"$name\"");

+ header("Content-disposition: attachment; filename=$name");

+

+ switch ($format)

+ {

+ case 'bzip2':

+ ob_start();

+ break;

+

+ case 'gzip':

+ if (strpos($this->request->header('Accept-Encoding'), 'gzip') !== false && strpos(strtolower($this->request->header('User-Agent')), 'msie') === false)

+ {

+ ob_start('ob_gzhandler');

+ }

+ else

+ {

+ $this->run_comp = true;

+ }

+ break;

+ }

+ }

+

+ if ($store === true)

+ {

+ $file = $this->phpbb_root_path . 'store/' . $filename . $ext;

+

+ $this->fp = $open($file, 'w');

+

+ if (!$this->fp)

+ {

+ trigger_error('FILE_WRITE_FAIL', E_USER_ERROR);

+ }

+ }

+

+ $this->is_initialized = true;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_end()

+ {

+ static $close;

+

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ if ($this->store)

+ {

+ if ($close === null)

+ {

+ $close = $this->close;

+ }

+ $close($this->fp);

+ }

+

+ // bzip2 must be written all the way at the end

+ if ($this->download && $this->format === 'bzip2')

+ {

+ $c = ob_get_clean();

+ echo bzcompress($c);

+ }

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function flush($data)

+ {

+ static $write;

+

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ if ($this->store === true)

+ {

+ if ($write === null)

+ {

+ $write = $this->write;

+ }

+ $write($this->fp, $data);

+ }

+

+ if ($this->download === true)

+ {

+ if ($this->format === 'bzip2' || $this->format === 'text' || ($this->format === 'gzip' && !$this->run_comp))

+ {

+ echo $data;

+ }

+

+ // we can write the gzip data as soon as we get it

+ if ($this->format === 'gzip')

+ {

+ if ($this->run_comp)

+ {

+ echo gzencode($data);

+ }

+ else

+ {

+ ob_flush();

+ flush();

+ }

+ }

+ }

+ }

+}

+<?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\db\extractor\exception;

+

+use phpbb\exception\runtime_exception;

+

+/**

+* This exception is thrown when invalid format is given to the extractor

+*/

+class extractor_not_initialized_exception extends runtime_exception

+{

+

+}

+<?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\db\extractor\exception;

+

+/**

+* This exception is thrown when invalid format is given to the extractor

+*/

+class invalid_format_exception extends \InvalidArgumentException

+{

+

+}

+<?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\db\extractor;

+

+/**

+* Database extractor interface

+*/

+interface extractor_interface

+{

+ /**

+ * Start the extraction of the database

+ *

+ * This function initialize the database extraction. It is required to call this

+ * function before calling any other extractor functions.

+ *

+ * @param string $format

+ * @param string $filename

+ * @param int $time

+ * @param bool $download

+ * @param bool $store

+ * @return null

+ * @throws \phpbb\db\extractor\exception\invalid_format_exception when $format is invalid

+ */

+ public function init_extractor($format, $filename, $time, $download = false, $store = false);

+

+ /**

+ * Writes header comments to the database backup

+ *

+ * @param string $table_prefix prefix of phpBB database tables

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function write_start($table_prefix);

+

+ /**

+ * Closes file and/or dumps download data

+ *

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function write_end();

+

+ /**

+ * Extracts database table structure

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function write_table($table_name);

+

+ /**

+ * Extracts data from database table

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function write_data($table_name);

+

+ /**

+ * Writes data to file/download content

+ *

+ * @param string $data

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function flush($data);

+}

+<?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\db\extractor;

+

+/**

+* A factory which serves the suitable extractor instance for the given dbal

+*/

+class factory

+{

+ /**

+ * @var \phpbb\db\driver\driver_interface

+ */

+ protected $db;

+

+ /**

+ * @var \Symfony\Component\DependencyInjection\ContainerInterface

+ */

+ protected $container;

+

+ /**

+ * Extractor factory constructor

+ *

+ * @param \phpbb\db\driver\driver_interface $db

+ * @param \Symfony\Component\DependencyInjection\ContainerInterface $container

+ */

+ public function __construct(\phpbb\db\driver\driver_interface $db, \Symfony\Component\DependencyInjection\ContainerInterface $container)

+ {

+ $this->db = $db;

+ $this->container = $container;

+ }

+

+ /**

+ * DB extractor factory getter

+ *

+ * @return \phpbb\db\extractor\extractor_interface an appropriate instance of the database extractor for the used database driver

+ * @throws \InvalidArgumentException when the database driver is unknown

+ */

+ public function get()

+ {

+ // Return the appropriate DB extractor

+ if ($this->db instanceof \phpbb\db\driver\mssql || $this->db instanceof \phpbb\db\driver\mssql_base)

+ {

+ return $this->container->get('dbal.extractor.extractors.mssql_extractor');

+ }

+ else if ($this->db instanceof \phpbb\db\driver\mysql_base)

+ {

+ return $this->container->get('dbal.extractor.extractors.mysql_extractor');

+ }

+ else if ($this->db instanceof \phpbb\db\driver\oracle)

+ {

+ return $this->container->get('dbal.extractor.extractors.oracle_extractor');

+ }

+ else if ($this->db instanceof \phpbb\db\driver\postgres)

+ {

+ return $this->container->get('dbal.extractor.extractors.postgres_extractor');

+ }

+ else if ($this->db instanceof \phpbb\db\driver\sqlite)

+ {

+ return $this->container->get('dbal.extractor.extractors.sqlite_extractor');

+ }

+ else if ($this->db instanceof \phpbb\db\driver\sqlite3)

+ {

+ return $this->container->get('dbal.extractor.extractors.sqlite3_extractor');

+ }

+

+ throw new \InvalidArgumentException('Invalid database driver given');

+ }

+}

+<?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\db\extractor;

+

+use phpbb\db\extractor\exception\extractor_not_initialized_exception;

+

+class mssql_extractor extends base_extractor

+{

+ /**

+ * Writes closing line(s) to database backup

+ *

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ public function write_end()

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $this->flush("COMMIT\nGO\n");

+ parent::write_end();

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_start($table_prefix)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = "--\n";

+ $sql_data .= "-- phpBB Backup Script\n";

+ $sql_data .= "-- Dump of tables for $table_prefix\n";

+ $sql_data .= "-- DATE : " . gmdate("d-m-Y H:i:s", $this->time) . " GMT\n";

+ $sql_data .= "--\n";

+ $sql_data .= "BEGIN TRANSACTION\n";

+ $sql_data .= "GO\n";

+ $this->flush($sql_data);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_table($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = '-- Table: ' . $table_name . "\n";

+ $sql_data .= "IF OBJECT_ID(N'$table_name', N'U') IS NOT NULL\n";

+ $sql_data .= "DROP TABLE $table_name;\n";

+ $sql_data .= "GO\n";

+ $sql_data .= "\nCREATE TABLE [$table_name] (\n";

+ $rows = array();

+

+ $text_flag = false;

+

+ $sql = "SELECT COLUMN_NAME, COLUMN_DEFAULT, IS_NULLABLE, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, COLUMNPROPERTY(object_id(TABLE_NAME), COLUMN_NAME, 'IsIdentity') as IS_IDENTITY

+ FROM INFORMATION_SCHEMA.COLUMNS

+ WHERE TABLE_NAME = '$table_name'";

+ $result = $this->db->sql_query($sql);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $line = "\t[{$row['COLUMN_NAME']}] [{$row['DATA_TYPE']}]";

+

+ if ($row['DATA_TYPE'] == 'text')

+ {

+ $text_flag = true;

+ }

+

+ if ($row['IS_IDENTITY'])

+ {

+ $line .= ' IDENTITY (1 , 1)';

+ }

+

+ if ($row['CHARACTER_MAXIMUM_LENGTH'] && $row['DATA_TYPE'] !== 'text')

+ {

+ $line .= ' (' . $row['CHARACTER_MAXIMUM_LENGTH'] . ')';

+ }

+

+ if ($row['IS_NULLABLE'] == 'YES')

+ {

+ $line .= ' NULL';

+ }

+ else

+ {

+ $line .= ' NOT NULL';

+ }

+

+ if ($row['COLUMN_DEFAULT'])

+ {

+ $line .= ' DEFAULT ' . $row['COLUMN_DEFAULT'];

+ }

+

+ $rows[] = $line;

+ }

+ $this->db->sql_freeresult($result);

+

+ $sql_data .= implode(",\n", $rows);

+ $sql_data .= "\n) ON [PRIMARY]";

+

+ if ($text_flag)

+ {

+ $sql_data .= " TEXTIMAGE_ON [PRIMARY]";

+ }

+

+ $sql_data .= "\nGO\n\n";

+ $rows = array();

+

+ $sql = "SELECT CONSTRAINT_NAME, COLUMN_NAME

+ FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE

+ WHERE TABLE_NAME = '$table_name'";

+ $result = $this->db->sql_query($sql);

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ if (!sizeof($rows))

+ {

+ $sql_data .= "ALTER TABLE [$table_name] WITH NOCHECK ADD\n";

+ $sql_data .= "\tCONSTRAINT [{$row['CONSTRAINT_NAME']}] PRIMARY KEY CLUSTERED \n\t(\n";

+ }

+ $rows[] = "\t\t[{$row['COLUMN_NAME']}]";

+ }

+ if (sizeof($rows))

+ {

+ $sql_data .= implode(",\n", $rows);

+ $sql_data .= "\n\t) ON [PRIMARY] \nGO\n";

+ }

+ $this->db->sql_freeresult($result);

+

+ $index = array();

+ $sql = "EXEC sp_statistics '$table_name'";

+ $result = $this->db->sql_query($sql);

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ if ($row['TYPE'] == 3)

+ {

+ $index[$row['INDEX_NAME']][] = '[' . $row['COLUMN_NAME'] . ']';

+ }

+ }

+ $this->db->sql_freeresult($result);

+

+ foreach ($index as $index_name => $column_name)

+ {

+ $index[$index_name] = implode(', ', $column_name);

+ }

+

+ foreach ($index as $index_name => $columns)

+ {

+ $sql_data .= "\nCREATE INDEX [$index_name] ON [$table_name]($columns) ON [PRIMARY]\nGO\n";

+ }

+ $this->flush($sql_data);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_data($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ if ($this->db->get_sql_layer() === 'mssql')

+ {

+ $this->write_data_mssql($table_name);

+ }

+ else if ($this->db->get_sql_layer() === 'mssqlnative')

+ {

+ $this->write_data_mssqlnative($table_name);

+ }

+ else

+ {

+ $this->write_data_odbc($table_name);

+ }

+ }

+

+ /**

+ * Extracts data from database table (for MSSQL driver)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function write_data_mssql($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $ary_type = $ary_name = array();

+ $ident_set = false;

+ $sql_data = '';

+

+ // Grab all of the data from current table.

+ $sql = "SELECT *

+ FROM $table_name";

+ $result = $this->db->sql_query($sql);

+

+ $retrieved_data = mssql_num_rows($result);

+

+ $i_num_fields = mssql_num_fields($result);

+

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $ary_type[$i] = mssql_field_type($result, $i);

+ $ary_name[$i] = mssql_field_name($result, $i);

+ }

+

+ if ($retrieved_data)

+ {

+ $sql = "SELECT 1 as has_identity

+ FROM INFORMATION_SCHEMA.COLUMNS

+ WHERE COLUMNPROPERTY(object_id('$table_name'), COLUMN_NAME, 'IsIdentity') = 1";

+ $result2 = $this->db->sql_query($sql);

+ $row2 = $this->db->sql_fetchrow($result2);

+ if (!empty($row2['has_identity']))

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name ON\nGO\n";

+ $ident_set = true;

+ }

+ $this->db->sql_freeresult($result2);

+ }

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $schema_vals = $schema_fields = array();

+

+ // Build the SQL statement to recreate the data.

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $str_val = $row[$ary_name[$i]];

+

+ if (preg_match('#char|text|bool|varbinary#i', $ary_type[$i]))

+ {

+ $str_quote = '';

+ $str_empty = "''";

+ $str_val = sanitize_data_mssql(str_replace("'", "''", $str_val));

+ }

+ else if (preg_match('#date|timestamp#i', $ary_type[$i]))

+ {

+ if (empty($str_val))

+ {

+ $str_quote = '';

+ }

+ else

+ {

+ $str_quote = "'";

+ }

+ }

+ else

+ {

+ $str_quote = '';

+ $str_empty = 'NULL';

+ }

+

+ if (empty($str_val) && $str_val !== '0' && !(is_int($str_val) || is_float($str_val)))

+ {

+ $str_val = $str_empty;

+ }

+

+ $schema_vals[$i] = $str_quote . $str_val . $str_quote;

+ $schema_fields[$i] = $ary_name[$i];

+ }

+

+ // Take the ordered fields and their associated data and build it

+ // into a valid sql statement to recreate that field in the data.

+ $sql_data .= "INSERT INTO $table_name (" . implode(', ', $schema_fields) . ') VALUES (' . implode(', ', $schema_vals) . ");\nGO\n";

+

+ $this->flush($sql_data);

+ $sql_data = '';

+ }

+ $this->db->sql_freeresult($result);

+

+ if ($retrieved_data && $ident_set)

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name OFF\nGO\n";

+ }

+ $this->flush($sql_data);

+ }

+

+ /**

+ * Extracts data from database table (for MSSQL Native driver)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function write_data_mssqlnative($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $ary_type = $ary_name = array();

+ $ident_set = false;

+ $sql_data = '';

+

+ // Grab all of the data from current table.

+ $sql = "SELECT * FROM $table_name";

+ $this->db->mssqlnative_set_query_options(array('Scrollable' => SQLSRV_CURSOR_STATIC));

+ $result = $this->db->sql_query($sql);

+

+ $retrieved_data = $this->db->mssqlnative_num_rows($result);

+

+ if (!$retrieved_data)

+ {

+ $this->db->sql_freeresult($result);

+ return;

+ }

+

+ $sql = "SELECT COLUMN_NAME, DATA_TYPE

+ FROM INFORMATION_SCHEMA.COLUMNS

+ WHERE INFORMATION_SCHEMA.COLUMNS.TABLE_NAME = '" . $this->db->sql_escape($table_name) . "'";

+ $result_fields = $this->db->sql_query($sql);

+

+ $i_num_fields = 0;

+ while ($row = $this->db->sql_fetchrow($result_fields))

+ {

+ $ary_type[$i_num_fields] = $row['DATA_TYPE'];

+ $ary_name[$i_num_fields] = $row['COLUMN_NAME'];

+ $i_num_fields++;

+ }

+ $this->db->sql_freeresult($result_fields);

+

+ $sql = "SELECT 1 as has_identity

+ FROM INFORMATION_SCHEMA.COLUMNS

+ WHERE COLUMNPROPERTY(object_id('$table_name'), COLUMN_NAME, 'IsIdentity') = 1";

+ $result2 = $this->db->sql_query($sql);

+ $row2 = $this->db->sql_fetchrow($result2);

+

+ if (!empty($row2['has_identity']))

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name ON\nGO\n";

+ $ident_set = true;

+ }

+ $this->db->sql_freeresult($result2);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $schema_vals = $schema_fields = array();

+

+ // Build the SQL statement to recreate the data.

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $str_val = $row[$ary_name[$i]];

+

+ // defaults to type number - better quote just to be safe, so check for is_int too

+ if (is_int($ary_type[$i]) || preg_match('#char|text|bool|varbinary#i', $ary_type[$i]))

+ {

+ $str_quote = '';

+ $str_empty = "''";

+ $str_val = sanitize_data_mssql(str_replace("'", "''", $str_val));

+ }

+ else if (preg_match('#date|timestamp#i', $ary_type[$i]))

+ {

+ if (empty($str_val))

+ {

+ $str_quote = '';

+ }

+ else

+ {

+ $str_quote = "'";

+ }

+ }

+ else

+ {

+ $str_quote = '';

+ $str_empty = 'NULL';

+ }

+

+ if (empty($str_val) && $str_val !== '0' && !(is_int($str_val) || is_float($str_val)))

+ {

+ $str_val = $str_empty;

+ }

+

+ $schema_vals[$i] = $str_quote . $str_val . $str_quote;

+ $schema_fields[$i] = $ary_name[$i];

+ }

+

+ // Take the ordered fields and their associated data and build it

+ // into a valid sql statement to recreate that field in the data.

+ $sql_data .= "INSERT INTO $table_name (" . implode(', ', $schema_fields) . ') VALUES (' . implode(', ', $schema_vals) . ");\nGO\n";

+

+ $this->flush($sql_data);

+ $sql_data = '';

+ }

+ $this->db->sql_freeresult($result);

+

+ if ($ident_set)

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name OFF\nGO\n";

+ }

+ $this->flush($sql_data);

+ }

+

+ /**

+ * Extracts data from database table (for ODBC driver)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function write_data_odbc($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $ary_type = $ary_name = array();

+ $ident_set = false;

+ $sql_data = '';

+

+ // Grab all of the data from current table.

+ $sql = "SELECT *

+ FROM $table_name";

+ $result = $this->db->sql_query($sql);

+

+ $retrieved_data = odbc_num_rows($result);

+

+ if ($retrieved_data)

+ {

+ $sql = "SELECT 1 as has_identity

+ FROM INFORMATION_SCHEMA.COLUMNS

+ WHERE COLUMNPROPERTY(object_id('$table_name'), COLUMN_NAME, 'IsIdentity') = 1";

+ $result2 = $this->db->sql_query($sql);

+ $row2 = $this->db->sql_fetchrow($result2);

+ if (!empty($row2['has_identity']))

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name ON\nGO\n";

+ $ident_set = true;

+ }

+ $this->db->sql_freeresult($result2);

+ }

+

+ $i_num_fields = odbc_num_fields($result);

+

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $ary_type[$i] = odbc_field_type($result, $i + 1);

+ $ary_name[$i] = odbc_field_name($result, $i + 1);

+ }

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $schema_vals = $schema_fields = array();

+

+ // Build the SQL statement to recreate the data.

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $str_val = $row[$ary_name[$i]];

+

+ if (preg_match('#char|text|bool|varbinary#i', $ary_type[$i]))

+ {

+ $str_quote = '';

+ $str_empty = "''";

+ $str_val = sanitize_data_mssql(str_replace("'", "''", $str_val));

+ }

+ else if (preg_match('#date|timestamp#i', $ary_type[$i]))

+ {

+ if (empty($str_val))

+ {

+ $str_quote = '';

+ }

+ else

+ {

+ $str_quote = "'";

+ }

+ }

+ else

+ {

+ $str_quote = '';

+ $str_empty = 'NULL';

+ }

+

+ if (empty($str_val) && $str_val !== '0' && !(is_int($str_val) || is_float($str_val)))

+ {

+ $str_val = $str_empty;

+ }

+

+ $schema_vals[$i] = $str_quote . $str_val . $str_quote;

+ $schema_fields[$i] = $ary_name[$i];

+ }

+

+ // Take the ordered fields and their associated data and build it

+ // into a valid sql statement to recreate that field in the data.

+ $sql_data .= "INSERT INTO $table_name (" . implode(', ', $schema_fields) . ') VALUES (' . implode(', ', $schema_vals) . ");\nGO\n";

+

+ $this->flush($sql_data);

+

+ $sql_data = '';

+

+ }

+ $this->db->sql_freeresult($result);

+

+ if ($retrieved_data && $ident_set)

+ {

+ $sql_data .= "\nSET IDENTITY_INSERT $table_name OFF\nGO\n";

+ }

+ $this->flush($sql_data);

+ }

+}

+<?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\db\extractor;

+

+use phpbb\db\extractor\exception\extractor_not_initialized_exception;

+

+class mysql_extractor extends base_extractor

+{

+ /**

+ * {@inheritdoc}

+ */

+ public function write_start($table_prefix)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = "#\n";

+ $sql_data .= "# phpBB Backup Script\n";

+ $sql_data .= "# Dump of tables for $table_prefix\n";

+ $sql_data .= "# DATE : " . gmdate("d-m-Y H:i:s", $this->time) . " GMT\n";

+ $sql_data .= "#\n";

+ $this->flush($sql_data);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_table($table_name)

+ {

+ static $new_extract;

+

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ if ($new_extract === null)

+ {

+ if ($this->db->get_sql_layer() === 'mysqli' || version_compare($this->db->sql_server_info(true), '3.23.20', '>='))

+ {

+ $new_extract = true;

+ }

+ else

+ {

+ $new_extract = false;

+ }

+ }

+

+ if ($new_extract)

+ {

+ $this->new_write_table($table_name);

+ }

+ else

+ {

+ $this->old_write_table($table_name);

+ }

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_data($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ if ($this->db->get_sql_layer() === 'mysqli')

+ {

+ $this->write_data_mysqli($table_name);

+ }

+ else

+ {

+ $this->write_data_mysql($table_name);

+ }

+ }

+

+ /**

+ * Extracts data from database table (for MySQLi driver)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function write_data_mysqli($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql = "SELECT *

+ FROM $table_name";

+ $result = mysqli_query($this->db->get_db_connect_id(), $sql, MYSQLI_USE_RESULT);

+ if ($result != false)

+ {

+ $fields_cnt = mysqli_num_fields($result);

+

+ // Get field information

+ $field = mysqli_fetch_fields($result);

+ $field_set = array();

+

+ for ($j = 0; $j < $fields_cnt; $j++)

+ {

+ $field_set[] = $field[$j]->name;

+ }

+

+ $search = array("\\", "'", "\x00", "\x0a", "\x0d", "\x1a", '"');

+ $replace = array("\\\\", "\\'", '\0', '\n', '\r', '\Z', '\\"');

+ $fields = implode(', ', $field_set);

+ $sql_data = 'INSERT INTO ' . $table_name . ' (' . $fields . ') VALUES ';

+ $first_set = true;

+ $query_len = 0;

+ $max_len = get_usable_memory();

+

+ while ($row = mysqli_fetch_row($result))

+ {

+ $values = array();

+ if ($first_set)

+ {

+ $query = $sql_data . '(';

+ }

+ else

+ {

+ $query .= ',(';

+ }

+

+ for ($j = 0; $j < $fields_cnt; $j++)

+ {

+ if (!isset($row[$j]) || is_null($row[$j]))

+ {

+ $values[$j] = 'NULL';

+ }

+ else if (($field[$j]->flags & 32768) && !($field[$j]->flags & 1024))

+ {

+ $values[$j] = $row[$j];

+ }

+ else

+ {

+ $values[$j] = "'" . str_replace($search, $replace, $row[$j]) . "'";

+ }

+ }

+ $query .= implode(', ', $values) . ')';

+

+ $query_len += strlen($query);

+ if ($query_len > $max_len)

+ {

+ $this->flush($query . ";\n\n");

+ $query = '';

+ $query_len = 0;

+ $first_set = true;

+ }

+ else

+ {

+ $first_set = false;

+ }

+ }

+ mysqli_free_result($result);

+

+ // check to make sure we have nothing left to flush

+ if (!$first_set && $query)

+ {

+ $this->flush($query . ";\n\n");

+ }

+ }

+ }

+

+ /**

+ * Extracts data from database table (for MySQL driver)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function write_data_mysql($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql = "SELECT *

+ FROM $table_name";

+ $result = mysql_unbuffered_query($sql, $this->db->get_db_connect_id());

+

+ if ($result != false)

+ {

+ $fields_cnt = mysql_num_fields($result);

+

+ // Get field information

+ $field = array();

+ for ($i = 0; $i < $fields_cnt; $i++)

+ {

+ $field[] = mysql_fetch_field($result, $i);

+ }

+ $field_set = array();

+

+ for ($j = 0; $j < $fields_cnt; $j++)

+ {

+ $field_set[] = $field[$j]->name;

+ }

+

+ $search = array("\\", "'", "\x00", "\x0a", "\x0d", "\x1a", '"');

+ $replace = array("\\\\", "\\'", '\0', '\n', '\r', '\Z', '\\"');

+ $fields = implode(', ', $field_set);

+ $sql_data = 'INSERT INTO ' . $table_name . ' (' . $fields . ') VALUES ';

+ $first_set = true;

+ $query_len = 0;

+ $max_len = get_usable_memory();

+

+ while ($row = mysql_fetch_row($result))

+ {

+ $values = array();

+ if ($first_set)

+ {

+ $query = $sql_data . '(';

+ }

+ else

+ {

+ $query .= ',(';

+ }

+

+ for ($j = 0; $j < $fields_cnt; $j++)

+ {

+ if (!isset($row[$j]) || is_null($row[$j]))

+ {

+ $values[$j] = 'NULL';

+ }

+ else if ($field[$j]->numeric && ($field[$j]->type !== 'timestamp'))

+ {

+ $values[$j] = $row[$j];

+ }

+ else

+ {

+ $values[$j] = "'" . str_replace($search, $replace, $row[$j]) . "'";

+ }

+ }

+ $query .= implode(', ', $values) . ')';

+

+ $query_len += strlen($query);

+ if ($query_len > $max_len)

+ {

+ $this->flush($query . ";\n\n");

+ $query = '';

+ $query_len = 0;

+ $first_set = true;

+ }

+ else

+ {

+ $first_set = false;

+ }

+ }

+ mysql_free_result($result);

+

+ // check to make sure we have nothing left to flush

+ if (!$first_set && $query)

+ {

+ $this->flush($query . ";\n\n");

+ }

+ }

+ }

+

+ /**

+ * Extracts database table structure (for MySQLi or MySQL 3.23.20+)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function new_write_table($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql = 'SHOW CREATE TABLE ' . $table_name;

+ $result = $this->db->sql_query($sql);

+ $row = $this->db->sql_fetchrow($result);

+

+ $sql_data = '# Table: ' . $table_name . "\n";

+ $sql_data .= "DROP TABLE IF EXISTS $table_name;\n";

+ $this->flush($sql_data . $row['Create Table'] . ";\n\n");

+

+ $this->db->sql_freeresult($result);

+ }

+

+ /**

+ * Extracts database table structure (for MySQL verisons older than 3.23.20)

+ *

+ * @param string $table_name name of the database table

+ * @return null

+ * @throws \phpbb\db\extractor\exception\extractor_not_initialized_exception when calling this function before init_extractor()

+ */

+ protected function old_write_table($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = '# Table: ' . $table_name . "\n";

+ $sql_data .= "DROP TABLE IF EXISTS $table_name;\n";

+ $sql_data .= "CREATE TABLE $table_name(\n";

+ $rows = array();

+

+ $sql = "SHOW FIELDS

+ FROM $table_name";

+ $result = $this->db->sql_query($sql);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $line = ' ' . $row['Field'] . ' ' . $row['Type'];

+

+ if (!is_null($row['Default']))

+ {

+ $line .= " DEFAULT '{$row['Default']}'";

+ }

+

+ if ($row['Null'] != 'YES')

+ {

+ $line .= ' NOT NULL';

+ }

+

+ if ($row['Extra'] != '')

+ {

+ $line .= ' ' . $row['Extra'];

+ }

+

+ $rows[] = $line;

+ }

+ $this->db->sql_freeresult($result);

+

+ $sql = "SHOW KEYS

+ FROM $table_name";

+

+ $result = $this->db->sql_query($sql);

+

+ $index = array();

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $kname = $row['Key_name'];

+

+ if ($kname != 'PRIMARY')

+ {

+ if ($row['Non_unique'] == 0)

+ {

+ $kname = "UNIQUE|$kname";

+ }

+ }

+

+ if ($row['Sub_part'])

+ {

+ $row['Column_name'] .= '(' . $row['Sub_part'] . ')';

+ }

+ $index[$kname][] = $row['Column_name'];

+ }

+ $this->db->sql_freeresult($result);

+

+ foreach ($index as $key => $columns)

+ {

+ $line = ' ';

+

+ if ($key == 'PRIMARY')

+ {

+ $line .= 'PRIMARY KEY (' . implode(', ', $columns) . ')';

+ }

+ else if (strpos($key, 'UNIQUE') === 0)

+ {

+ $line .= 'UNIQUE ' . substr($key, 7) . ' (' . implode(', ', $columns) . ')';

+ }

+ else if (strpos($key, 'FULLTEXT') === 0)

+ {

+ $line .= 'FULLTEXT ' . substr($key, 9) . ' (' . implode(', ', $columns) . ')';

+ }

+ else

+ {

+ $line .= "KEY $key (" . implode(', ', $columns) . ')';

+ }

+

+ $rows[] = $line;

+ }

+

+ $sql_data .= implode(",\n", $rows);

+ $sql_data .= "\n);\n\n";

+

+ $this->flush($sql_data);

+ }

+}

+<?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\db\extractor;

+

+use phpbb\db\extractor\exception\extractor_not_initialized_exception;

+

+class oracle_extractor extends base_extractor

+{

+ /**

+ * {@inheritdoc}

+ */

+ public function write_table($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = '-- Table: ' . $table_name . "\n";

+ $sql_data .= "DROP TABLE $table_name\n/\n";

+ $sql_data .= "\nCREATE TABLE $table_name (\n";

+

+ $sql = "SELECT COLUMN_NAME, DATA_TYPE, DATA_PRECISION, DATA_LENGTH, NULLABLE, DATA_DEFAULT

+ FROM ALL_TAB_COLS

+ WHERE table_name = '{$table_name}'";

+ $result = $this->db->sql_query($sql);

+

+ $rows = array();

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $line = ' "' . $row['column_name'] . '" ' . $row['data_type'];

+

+ if ($row['data_type'] !== 'CLOB')

+ {

+ if ($row['data_type'] !== 'VARCHAR2' && $row['data_type'] !== 'CHAR')

+ {

+ $line .= '(' . $row['data_precision'] . ')';

+ }

+ else

+ {

+ $line .= '(' . $row['data_length'] . ')';

+ }

+ }

+

+ if (!empty($row['data_default']))

+ {

+ $line .= ' DEFAULT ' . $row['data_default'];

+ }

+

+ if ($row['nullable'] == 'N')

+ {

+ $line .= ' NOT NULL';

+ }

+ $rows[] = $line;

+ }

+ $this->db->sql_freeresult($result);

+

+ $sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME

+ FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B

+ WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME

+ AND B.CONSTRAINT_TYPE = 'P'

+ AND A.TABLE_NAME = '{$table_name}'";

+ $result = $this->db->sql_query($sql);

+

+ $primary_key = array();

+ $constraint_name = '';

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $constraint_name = '"' . $row['constraint_name'] . '"';

+ $primary_key[] = '"' . $row['column_name'] . '"';

+ }

+ $this->db->sql_freeresult($result);

+

+ if (sizeof($primary_key))

+ {

+ $rows[] = " CONSTRAINT {$constraint_name} PRIMARY KEY (" . implode(', ', $primary_key) . ')';

+ }

+

+ $sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME

+ FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B

+ WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME

+ AND B.CONSTRAINT_TYPE = 'U'

+ AND A.TABLE_NAME = '{$table_name}'";

+ $result = $this->db->sql_query($sql);

+

+ $unique = array();

+ $constraint_name = '';

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $constraint_name = '"' . $row['constraint_name'] . '"';

+ $unique[] = '"' . $row['column_name'] . '"';

+ }

+ $this->db->sql_freeresult($result);

+

+ if (sizeof($unique))

+ {

+ $rows[] = " CONSTRAINT {$constraint_name} UNIQUE (" . implode(', ', $unique) . ')';

+ }

+

+ $sql_data .= implode(",\n", $rows);

+ $sql_data .= "\n)\n/\n";

+

+ $sql = "SELECT A.REFERENCED_NAME, C.*

+ FROM USER_DEPENDENCIES A, USER_TRIGGERS B, USER_SEQUENCES C

+ WHERE A.REFERENCED_TYPE = 'SEQUENCE'

+ AND A.NAME = B.TRIGGER_NAME

+ AND B.TABLE_NAME = '{$table_name}'

+ AND C.SEQUENCE_NAME = A.REFERENCED_NAME";

+ $result = $this->db->sql_query($sql);

+

+ $type = $this->request->variable('type', '');

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $sql_data .= "\nDROP SEQUENCE \"{$row['referenced_name']}\"\n/\n";

+ $sql_data .= "\nCREATE SEQUENCE \"{$row['referenced_name']}\"";

+

+ if ($type == 'full')

+ {

+ $sql_data .= ' START WITH ' . $row['last_number'];

+ }

+

+ $sql_data .= "\n/\n";

+ }

+ $this->db->sql_freeresult($result);

+

+ $sql = "SELECT DESCRIPTION, WHEN_CLAUSE, TRIGGER_BODY

+ FROM USER_TRIGGERS

+ WHERE TABLE_NAME = '{$table_name}'";

+ $result = $this->db->sql_query($sql);

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $sql_data .= "\nCREATE OR REPLACE TRIGGER {$row['description']}WHEN ({$row['when_clause']})\n{$row['trigger_body']}\n/\n";

+ }

+ $this->db->sql_freeresult($result);

+

+ $sql = "SELECT A.INDEX_NAME, B.COLUMN_NAME

+ FROM USER_INDEXES A, USER_IND_COLUMNS B

+ WHERE A.UNIQUENESS = 'NONUNIQUE'

+ AND A.INDEX_NAME = B.INDEX_NAME

+ AND B.TABLE_NAME = '{$table_name}'";

+ $result = $this->db->sql_query($sql);

+

+ $index = array();

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $index[$row['index_name']][] = $row['column_name'];

+ }

+

+ foreach ($index as $index_name => $column_names)

+ {

+ $sql_data .= "\nCREATE INDEX $index_name ON $table_name(" . implode(', ', $column_names) . ")\n/\n";

+ }

+ $this->db->sql_freeresult($result);

+ $this->flush($sql_data);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_data($table_name)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $ary_type = $ary_name = array();

+

+ // Grab all of the data from current table.

+ $sql = "SELECT *

+ FROM $table_name";

+ $result = $this->db->sql_query($sql);

+

+ $i_num_fields = ocinumcols($result);

+

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ $ary_type[$i] = ocicolumntype($result, $i + 1);

+ $ary_name[$i] = ocicolumnname($result, $i + 1);

+ }

+

+ $sql_data = '';

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $schema_vals = $schema_fields = array();

+

+ // Build the SQL statement to recreate the data.

+ for ($i = 0; $i < $i_num_fields; $i++)

+ {

+ // Oracle uses uppercase - we use lowercase

+ $str_val = $row[strtolower($ary_name[$i])];

+

+ if (preg_match('#char|text|bool|raw|clob#i', $ary_type[$i]))

+ {

+ $str_quote = '';

+ $str_empty = "''";

+ $str_val = sanitize_data_oracle($str_val);

+ }

+ else if (preg_match('#date|timestamp#i', $ary_type[$i]))

+ {

+ if (empty($str_val))

+ {

+ $str_quote = '';

+ }

+ else

+ {

+ $str_quote = "'";

+ }

+ }

+ else

+ {

+ $str_quote = '';

+ $str_empty = 'NULL';

+ }

+

+ if (empty($str_val) && $str_val !== '0')

+ {

+ $str_val = $str_empty;

+ }

+

+ $schema_vals[$i] = $str_quote . $str_val . $str_quote;

+ $schema_fields[$i] = '"' . $ary_name[$i] . '"';

+ }

+

+ // Take the ordered fields and their associated data and build it

+ // into a valid sql statement to recreate that field in the data.

+ $sql_data = "INSERT INTO $table_name (" . implode(', ', $schema_fields) . ') VALUES (' . implode(', ', $schema_vals) . ")\n/\n";

+

+ $this->flush($sql_data);

+ }

+ $this->db->sql_freeresult($result);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function write_start($table_prefix)

+ {

+ if (!$this->is_initialized)

+ {

+ throw new extractor_not_initialized_exception();

+ }

+

+ $sql_data = "--\n";

+ $sql_data .= "-- phpBB Backup Script\n";

+ $sql_data .= "-- Dump of tables for $table_prefix\n";

+ $sql_data .= "-- DATE : " . gmdate("d-m-Y H:i:s", $this->time) . " GMT\n";

+ $sql_data .= "--\n";

+ $this->flush($sql_data);

+ }

+}

+<?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\db\extractor;