* Setter for {@link $return_statements return_statements}.

*

* @param bool $return_statements True if SQL should not be executed but returned as strings

*/

public function set_return_statements($return_statements)

{

class phpbb_db_driver_mysqli extends phpbb_db_driver

{

var $multi_insert = true;

var $connect_error = '';

/**

*/

class phpbb_db_migration_exception extends \Exception

{

protected $parameters;

public function __construct()

{

$parameters = func_get_args();

$this->parameters = $parameters;

}

public function __toString()

{

return $this->message . ': ' . var_export($this->parameters, true);

*/

abstract class phpbb_db_migration

{

protected $config;

protected $db;

protected $db_tools;

protected $table_prefix;

protected $phpbb_root_path;

protected $php_ext;

protected $errors;

/**

*/

{

$this->config = $config;

$this->db = $db;

}

/**

*

* @return array An array of migration class names

*/

/**

* Updates the database schema by providing a set of change instructions

*

*/

public function update_schema()

{

/**

* Updates data by returning a list of instructions to be executed

*

*/

public function update_data()

{

}

/**

* Wrapper for running queries to generate user feedback on updates

*/

protected function sql_query($sql)

{

*

*/

class phpbb_db_migration_tool_config implements phpbb_db_migration_tool_interface

{

/** @var phpbb_config */

public function __construct(phpbb_config $config)

{

$this->config = $config;

}

/**

*

* @param string $config_name The name of the config setting you would like to add

* @param mixed $config_value The value of the config setting

* @param bool $is_dynamic True if it is dynamic (changes very often) and should not be stored in the cache, false if not.

*/

public function add($config_name, $config_value = '', $is_dynamic = false)

{

}

$this->config->set($config_name, $config_value, !$is_dynamic);

}

/**

*

* @param string $config_name The name of the config setting you would like to update

* @param mixed $config_value The value of the config setting

*/

public function update($config_name, $config_value = '')

{

}

$this->config->set($config_name, $config_value);

}

/**

*

* @param bool $compare If equal to the current config value, will be updated to the new config value, otherwise not

* @param string $config_name The name of the config setting you would like to update

* @param mixed $config_value The value of the config setting

*/

public function update_if_equals($compare, $config_name, $config_value = '')

{

}

$this->config->set_atomic($config_name, $compare, $config_value);

}

/**

*

* @param string $config_name The name of the config setting you would like to remove

*/

public function remove($config_name)

{

}

$this->config->delete($config_name);

}

}

*

*/

interface phpbb_db_migration_tool_interface

{

/**

*

*/

class phpbb_db_migration_tool_module implements phpbb_db_migration_tool_interface

{

/** @var phpbb_cache_service */

/** @var dbal */

/** @var phpbb_user */

/** @var string */

/** @var string */

/** @var string */

{

$this->db = $db;

$this->cache = $cache;

* @param string $class The module class(acp|mcp|ucp)

* @param int|string|bool $parent The parent module_id|module_langname (0 for no parent). Use false to ignore the parent check and check class wide.

* @param int|string $module The module_id|module_langname you would like to check for to see if it exists

* @return bool true/false if module exists

*/

public function exists($class, $parent, $module)

return true;

}

$parent_sql = '';

if ($parent !== false)

{

// Allows '' to be sent as 0

if (!is_numeric($parent))

{

$sql = 'SELECT module_id

FROM ' . $this->modules_table . "

WHERE module_langname = '" . $this->db->sql_escape($parent) . "'

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

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

{

return false;

}

}

else

{

$sql = 'SELECT module_id

FROM ' . $this->modules_table . "

$parent_sql

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

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

{

return true;

}

* @param array $data an array of the data on the new module. This can be setup in two different ways.

* 1. The "manual" way. For inserting a category or one at a time. It will be merged with the base array shown a bit below,

* but at the least requires 'module_langname' to be sent, and, if you want to create a module (instead of just a category) you must send module_basename and module_mode.

* 2. The "automatic" way. For inserting multiple at a time based on the specs in the info file for the module(s). For this to work the modules must be correctly setup in the info file.

* An example follows (this would insert the settings, log, and flag modes from the includes/acp/info/acp_asacp.php file):

* Optionally you may not send 'modes' and it will insert all of the modules in that info file.

*/

public function add($class, $parent = 0, $data = array(), $include_path = false)

{

// allow sending the name as a string in $data to create a category

if (!is_array($data))

if (!isset($data['module_langname']))

{

// The "automatic" way

$basename = (isset($data['module_basename'])) ? $data['module_basename'] : '';

$basename = str_replace(array('/', '\\'), '', $basename);

$class = str_replace(array('/', '\\'), '', $class);

$info_file = "$class/info/$basename.{$this->php_ext}";

// The manual and automatic ways both failed...

{

throw new phpbb_db_migration_exception('MODULE_INFO_FILE_NOT_EXIST', $class, $info_file);

}

if (!class_exists($classname))

{

}

$info = new $classname;

}

// The "manual" way

if (!is_numeric($parent))

{

$sql = 'SELECT module_id

FROM ' . $this->modules_table . "

WHERE module_langname = '" . $this->db->sql_escape($parent) . "'

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

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

{

throw new phpbb_db_migration_exception('MODULE_PARENT_NOT_EXIST', $parent);

}

}

else if (!$this->exists($class, false, $parent))

{

if (isset($data['before']) && $data['before'])

{

$sql = 'SELECT left_id

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

$sql = 'UPDATE ' . $this->modules_table . "

SET left_id = left_id + 2, right_id = right_id + 2

AND left_id >= $to_left

AND left_id < {$module_data['left_id']}";

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

$sql = 'UPDATE ' . $this->modules_table . "

SET left_id = $to_left, right_id = " . ($to_left + 1) . "

AND module_id = {$module_data['module_id']}";

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

}

else if (isset($data['after']) && $data['after'])

{

$sql = 'SELECT right_id

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

$sql = 'UPDATE ' . $this->modules_table . "

SET left_id = left_id + 2, right_id = right_id + 2

AND left_id >= $to_right

AND left_id < {$module_data['left_id']}";

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

$sql = 'UPDATE ' . $this->modules_table . '

SET left_id = ' . ($to_right + 1) . ', right_id = ' . ($to_right + 2) . "

AND module_id = {$module_data['module_id']}";

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

}

// Clear the Modules Cache

$this->cache->destroy("_modules_$class");

}

/**

* @param int|string|bool $parent The parent module_id|module_langname (0 for no parent). Use false to ignore the parent check and check class wide.

* @param int|string $module The module id|module_langname

* @param string|bool $include_path If you would like to use a custom include path, specify that here

*/

public function remove($class, $parent = 0, $module = '', $include_path = false)

{

// Automatic method

$basename = str_replace(array('/', '\\'), '', $module['module_basename']);

$class = str_replace(array('/', '\\'), '', $class);

$info_file = "$class/info/$basename.{$this->php_ext}";

{

throw new phpbb_db_migration_exception('MODULE_NOT_EXIST', $info_file);

}

if (!class_exists($classname))

{

}

$info = new $classname;

$this->remove($class, $parent, $info['title']) . '<br />';

}

}

}

else

{

if (!$this->exists($class, $parent, $module))

{

throw new phpbb_db_migration_exception('MODULE_NOT_EXIST', ((isset($this->user->lang[$module])) ? $this->user->lang[$module] : $module));

if ($parent !== false)

{

// Allows '' to be sent as 0

if (!is_numeric($parent))

{

$sql = 'SELECT module_id

FROM ' . $this->modules_table . "

WHERE module_langname = '" . $this->db->sql_escape($parent) . "'

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

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

// we know it exists from the module_exists check

}

else

{

$module_ids = array();

if (!is_numeric($module))

{

$sql = 'SELECT module_id

FROM ' . $this->modules_table . "

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

{

}

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

$sql = 'SELECT module_langname

FROM ' . $this->modules_table . "

WHERE module_id = $module

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

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

$module_ids[] = $module;

}

}

$this->cache->destroy("_modules_$class");

}

}

}

*

*/

class phpbb_db_migration_tool_permission implements phpbb_db_migration_tool_interface

{

/** @var phpbb_auth */

/** @var phpbb_cache_service */

/** @var dbal */

/** @var string */

/** @var string */

{

$this->db = $db;

$this->cache = $cache;

*

* @param string $auth_option The name of the permission (auth) option

* @param bool $global True for checking a global permission setting, False for a local permission setting

* @return bool true if it exists, false if not

*/

public function exists($auth_option, $global = true)

*

* @param string $auth_option The name of the permission (auth) option

* @param bool $global True for checking a global permission setting, False for a local permission setting

*/

public function add($auth_option, $global = true, $copy_from = false)

{

}

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

{

$this->db->sql_multi_insert($table, $sql_ary);

}

$auth_admin->acl_clear_prefetch();

}

}

/**

*

* @param string $auth_option The name of the permission (auth) option

* @param bool $global True for checking a global permission setting, False for a local permission setting

*/

public function remove($auth_option, $global = true)

{

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

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

// If it is a local and global permission, do not remove the row! :P

if ($row['is_global'] && $row['is_local'])

else

{

// Delete time

}

// Purge the auth cache

$this->cache->destroy('_acl_options');

$this->auth->acl_clear_prefetch();

}

/**

*

* @param string $role_name The new role name

* @param sting $role_type The type (u_, m_, a_)

*/

public function role_add($role_name, $role_type = '', $role_description = '')

{

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = '" . $this->db->sql_escape($role_name) . "'";

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

if ($role_id)

{

throw new phpbb_db_migration_exception('ROLE_ALREADY_EXISTS', $old_role_name);

}

FROM ' . ACL_ROLES_TABLE . "

WHERE role_type = '" . $this->db->sql_escape($role_type) . "'";

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

$role_order = (!$role_order) ? 1 : $role_order + 1;

$sql_ary = array(

$sql = 'INSERT INTO ' . ACL_ROLES_TABLE . ' ' . $this->db->sql_build_array('INSERT', $sql_ary);

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

}

/**

*

* @param string $old_role_name The old role name

* @param string $new_role_name The new role name

*/

public function role_update($old_role_name, $new_role_name = '')

{

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = '" . $this->db->sql_escape($old_role_name) . "'";

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

if (!$role_id)

{

SET role_name = '" . $this->db->sql_escape($new_role_name) . "'

WHERE role_name = '" . $this->db->sql_escape($old_role_name) . "'";

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

}

/**

* Remove a permission role

*

* @param string $role_name The role name to remove

*/

public function role_remove($role_name)

{

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = '" . $this->db->sql_escape($role_name) . "'";

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

if (!$role_id)

{

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

$this->auth->acl_clear_prefetch();

}

/**

* @param string|array $auth_option The auth_option or array of auth_options you would like to set

* @param string $type The type (role|group)

* @param bool $has_permission True if you want to give them permission, false if you want to deny them permission

*/

public function permission_set($name, $auth_option = array(), $type = 'role', $has_permission = true)

{

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

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

{

}

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

{

}

$current_auth = array();

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = '" . $this->db->sql_escape($name) . "'";

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

if (!$role_id)

{

FROM ' . GROUPS_TABLE . "

WHERE group_name = '" . $this->db->sql_escape($name) . "'";

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

if (!$group_id)

{

AND auth_role_id <> 0

AND forum_id = 0';

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

if ($role_id)

{

$sql = 'SELECT role_name

'role_id' => $role_id,

'auth_option_id' => $auth_option_id,

'auth_setting' => $has_permission,

}

}

'group_id' => $group_id,

'auth_option_id' => $auth_option_id,

'auth_setting' => $has_permission,

}

}

}

$this->auth->acl_clear_prefetch();

}

/**

* @param string $name The name of the role/group

* @param string|array $auth_option The auth_option or array of auth_options you would like to set

* @param string $type The type (role|group)

*/

public function permission_unset($name, $auth_option = array(), $type = 'role')

{

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

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

{

}

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

{

}

$type = (string) $type; // Prevent PHP bug.

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = '" . $this->db->sql_escape($name) . "'";

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

if (!$role_id)

{

}

$sql = 'DELETE FROM ' . ACL_ROLES_DATA_TABLE . '

FROM ' . GROUPS_TABLE . "

WHERE group_name = '" . $this->db->sql_escape($name) . "'";

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

if (!$group_id)

{

WHERE group_id = ' . $group_id . '

AND auth_role_id <> 0';

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

if ($role_id)

{

$sql = 'SELECT role_name

}

$this->auth->acl_clear_prefetch();

}

}

*/

class phpbb_db_migrator

{

protected $config;

protected $db;

protected $db_tools;

protected $table_prefix;

protected $phpbb_root_path;

protected $php_ext;

protected $migrations_table;

protected $migration_state;

protected $migrations = array();

public $last_run_migration = false;

/**

* Constructor of the database migrator

*/

{

$this->config = $config;

$this->db = $db;

/**

* Load migration data files from a directory

*

* @return array Array of migrations with names

*/

{

$handle = opendir($path);

while (($file = readdir($handle)) !== false)

{

if (strpos($file, '_') !== 0 && strrpos($file, '.' . $this->php_ext) === (strlen($file) - strlen($this->php_ext) - 1))

{

if (!in_array($name, $this->migrations))

{

}

}

{

{

}

}

*

* The update step can either be a schema or a (partial) data update. To

* check if update() needs to be called again use the finished() method.

*/

public function update()

{

}

else

{

}

$sql = 'UPDATE ' . $this->migrations_table . '

return true;

}

protected function process_data_step($migration)

{

$steps = $migration->update_data();

foreach ($steps as $step)

{

{

}

}

protected function run_step($step)

{

}

public function get_callable_from_step($step)

{

$type = $step[0];

$callable_and_parameters = $this->get_callable_from_step($step);

$callable = $callable_and_parameters[0];

$sub_parameters = $callable_and_parameters[1];

return array(

function ($condition) use ($callable, $sub_parameters) {

return call_user_func_array($callable, $sub_parameters);

return array(

array($this->tools[$class], $method),

);

break;

}

}

protected function insert_migration($name, $state)

{

$migration_row = $state;

/**

* Checks if a migration's dependencies can even theoretically be satisfied.

*

*/

public function unfulfillable($name)

{

return true;

}

/**

* Helper to get a migration

*