*

*/

/**

* @ignore

*/

* Database Abstraction Layer

* @package dbal

*/

{

var $db_connect_id;

var $query_result;

* Correctly adjust LIKE expression for special characters

* Some DBMS are handling them in a different way

*

* @return string LIKE expression including the keyword!

*/

function sql_like_expression($expression)

* @param string $field name of the sql column that shall be compared

* @param array $array array of values that are allowed (IN) or not allowed (NOT IN)

* @param bool $negate true for NOT IN (), false for IN () (default)

*/

function sql_in_set($field, $array, $negate = false, $allow_empty_set = false)

{

*

*/

/**

* @ignore

*/

* Minimum Requirement is Firebird 2.1

* @package dbal

*/

{

var $last_query_text = '';

var $service_handle = false;

*

*/

/**

* @ignore

*/

* Minimum Requirement is MSSQL 2000+

* @package dbal

*/

{

var $connect_error = '';

*

*/

/**

* @ignore

*/

* MSSQL Database Base Abstraction Layer

* @package dbal

*/

{

/**

* {@inheritDoc}

*

*/

/**

* @ignore

*/

*

* @package dbal

*/

{

var $last_query_text = '';

var $connect_error = '';

*

*/

/**

* @ignore

*/

{

if (is_array($value))

{

array_to_obj($value, $obj->$key);

}

else

/**

* @package dbal

*/

{

var $m_insert_id = NULL;

var $last_query_text = '';

*

*/

/**

* @ignore

*/

* MySQL 5.0+

* @package dbal

*/

{

var $multi_insert = true;

var $connect_error = '';

*

*/

/**

* @ignore

*/

* Abstract MySQL Database Base Abstraction Layer

* @package dbal

*/

{

/**

* {@inheritDoc}

*

*/

/**

* @ignore

*/

* MySQL 4.1+ or MySQL 5.0+

* @package dbal

*/

{

var $multi_insert = true;

var $connect_error = '';

*

*/

/**

* @ignore

*/

* Oracle Database Abstraction Layer

* @package dbal

*/

{

var $last_query_text = '';

var $connect_error = '';

*

*/

/**

* @ignore

*/

* Minimum Requirement is Version 7.3+

* @package dbal

*/

{

var $last_query_text = '';

var $connect_error = '';

$this->connect_error = 'pg_pconnect function does not exist, is pgsql extension installed?';

return $this->sql_error('');

}

$collector->install();

$this->db_connect_id = (!$new_link) ? @pg_pconnect($connect_string) : @pg_pconnect($connect_string, PGSQL_CONNECT_FORCE_NEW);

}

$this->connect_error = 'pg_connect function does not exist, is pgsql extension installed?';

return $this->sql_error('');

}

$collector->install();

$this->db_connect_id = (!$new_link) ? @pg_connect($connect_string) : @pg_connect($connect_string, PGSQL_CONNECT_FORCE_NEW);

}

*

*/

/**

* @ignore

*/

* Minimum Requirement: 2.8.2+

* @package dbal

*/

{

var $connect_error = '';

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

/** @todo DROP LOGIN_ATTEMPT_TABLE.attempt_id in 3.0.12-RC1 **/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

public function update_custom_profile_fields()

{

$sql = 'SELECT field_id, field_required, field_show_on_reg, field_hide

FROM ' . PROFILE_FIELDS_TABLE;

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

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

$group_id = $this->db->sql_nextid();

}

$sql = 'SELECT role_id

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = 'ROLE_USER_NEW_MEMBER'

$u_role = $this->db->sql_nextid();

// Now add the correct data to the roles...

$sql = 'INSERT INTO ' . ACL_ROLES_DATA_TABLE . " (role_id, auth_option_id, auth_setting) SELECT $u_role, auth_option_id, 0 FROM " . ACL_OPTIONS_TABLE . " WHERE auth_option LIKE 'u_%' AND auth_option IN ('u_sendpm', 'u_masspm', 'u_masspm_group')";

$this->sql_query($sql);

$this->sql_query($sql);

}

$sql = 'SELECT role_id

FROM ' . ACL_ROLES_TABLE . "

WHERE role_name = 'ROLE_FORUM_NEW_MEMBER'

$this->sql_query($sql);

}

$sql = 'SELECT 1

FROM ' . USERS_TABLE . '

WHERE user_new = 0';

// Clear permissions...

include_once($this->phpbb_root_path . 'includes/acp/auth.' . $this->php_ext);

$auth_admin->acl_clear_prefetch();

}

}

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

public function update_cp_fields()

{

$sql = 'UPDATE ' . PROFILE_FIELDS_TABLE . '

SET field_show_on_vt = 1

WHERE field_hide = 0

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

static public function depends_on()

{

$bbcode_match = $row['bbcode_match'];

$bbcode_tpl = $row['bbcode_tpl'];

$sql_ary = $acp_bbcodes->build_regexp($bbcode_match, $bbcode_tpl);

$sql = 'UPDATE ' . BBCODES_TABLE . '

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

return array(

);

}

public function move_customise_modules()

{

// First get language module id

$sql = 'SELECT module_id FROM ' . MODULES_TABLE . "

WHERE module_basename = 'acp_language'";

{

include($this->phpbb_root_path . 'includes/functions_acp.' . $this->php_ext);

}

$module_manager->module_class = 'acp';

$module_manager->move_module($language_module_id, $language_management_module_id);

}

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

return array(

);

}

*

*/

{

static public function depends_on()

{

}

public function update_data()

public function convert_notifications()

{

$insert_table = $this->table_prefix . 'user_notifications';

$this->perform_conversion($insert_buffer, $insert_table);

}

/**

* Perform the conversion (separate for testability)

*

* @param string $insert_table

*/

{

$sql = 'DELETE FROM ' . $insert_table;

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

/**

* Insert method rows to DB

*

* @param string $item_type

* @param int $item_id

* @param int $user_id

* @param string $methods

*/

{

$row_base = array(

'item_type' => $item_type,

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

return array(

);

}

*

*/

{

public function effectively_installed()

{

// Get list of valid 3.1 styles

$available_styles = array('prosilver');

$skip_dirs = array('.', '..', 'prosilver');

foreach ($iterator as $fileinfo)

{

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

}

/**

* "Daylight Saving Time" option

*

* @param $timezone float Users timezone in 3.0

* @param $dst int Users daylight saving time

*/

public function convert_phpbb30_timezone($timezone, $dst)

{

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

/**

* @ignore

*/

}

/**

*

* @package db

*/

{

/**

* Extra parameters sent to exception to aid in debugging

}

/**

*

* @return string

*/

{

$parameters = $this->getParameters();

array_unshift($parameters, $this->getMessage());

*

*/

/**

* @ignore

*/

*

* @package db

*/

{

protected $config;

protected $db;

protected $db_tools;

/** @var string */

/**

* Constructor

*

* @param string $phpbb_root_path

* @param string $php_ext

* @param string $table_prefix

*/

{

$this->config = $config;

$this->db = $db;

*

*/

/**

* Migration config tool

*

* @package db

*/

{

protected $config;

/**

* Constructor

*

*/

{

$this->config = $config;

}

{

if (!isset($this->config[$config_name]))

{

}

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

* current config value

*

* @param string $compare If equal to the current config value, will be

* @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

{

if (!isset($this->config[$config_name]))

{

}

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

*

*/

/**

* Migration module management tool

*

* @package db

*/

{

protected $cache;

/** @var dbal */

protected $db;

protected $user;

/** @var string */

/**

* Constructor

*

* @param mixed $cache

* @param string $phpbb_root_path

* @param string $php_ext

* @param string $modules_table

*/

{

$this->db = $db;

$this->cache = $cache;

/**

* Module Add

*

*

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

* @param int|string $parent The parent module_id|module_langname (0 for no parent)

* 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,

if (!$module_id)

{

}

$parent = $data['parent_id'] = $module_id;

}

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

{

}

if ($this->exists($class, $parent, $data['module_langname']))

include($this->phpbb_root_path . 'includes/acp/acp_modules.' . $this->php_ext);

$this->user->add_lang('acp/modules');

}

$module_data = array(

'module_enabled' => (isset($data['module_enabled'])) ? $data['module_enabled'] : 1,

if (is_string($result))

{

// Error

}

else

{

// Failed.

if (!isset($module['module_basename']))

{

}

// Automatic method

include($this->phpbb_root_path . 'includes/acp/acp_modules.' . $this->php_ext);

$this->user->add_lang('acp/modules');

}

$acp_modules->module_class = $class;

foreach ($module_ids as $module_id)

}

/**

*

* @param string $class Module Class

* @param string $basename Module Basename

{

include($this->phpbb_root_path . 'includes/acp/acp_modules.' . $this->php_ext);

}

$module = $acp_modules->get_module_infos($basename, $class, true);

if (empty($module))

{

}

return array_pop($module);

*

*/

/**

* Migration permission management tool

*

* @package db

*/

{

protected $auth;

protected $cache;

/** @var dbal */

/**

* Constructor

*

* @param mixed $cache

* @param string $phpbb_root_path

* @param string $php_ext

*/

{

$this->db = $db;

$this->cache = $cache;

{

include($this->phpbb_root_path . 'includes/acp/auth.' . $this->php_ext);

}

// We have to add a check to see if the !$global (if global, local, and if local, global) permission already exists. If it does, acl_add_option currently has a bug which would break the ACL system, so we are having a work-around here.

if ($this->exists($auth_option, !$global))

}

/**

*

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

* @return null

*/

* Update the name on a permission role

*

* @param string $old_role_name The old role name

* @return null

*/

public function role_update($old_role_name, $new_role_name)

if (!$role_id)

{

}

$sql = 'UPDATE ' . ACL_ROLES_TABLE . "

if (!$role_id)

{

}

$sql = 'SELECT auth_option_id, auth_setting

if (!$group_id)

{

}

// If the group has a role set for them we will add the requested permissions to that role.

if (!$role_id)

{

}

$sql = 'DELETE FROM ' . ACL_ROLES_DATA_TABLE . '

if (!$group_id)

{

}

// If the group has a role set for them we will remove the requested permissions from that role.

*

*/

/**

* Migration tool interface

*

* @package db

*/

{

/**

* Retrieve a short name used for commands in migrations.

*

*/

/**

* @ignore

*/

}

/**

*

* @package db

*/

{

protected $config;

protected $db;

protected $db_tools;

/** @var string */

/**

* Constructor of the database migrator

*/

{

$this->config = $config;

$this->db = $db;

$state['migration_data_done'] = ($result === true);

$state['migration_end_time'] = ($result === true) ? time() : 0;

}

{

// Revert the schema changes

$this->revert($name);

));

}

}

{

// We should try rolling back here

foreach ($steps as $reverse_step_identifier => $reverse_step)

case 'if':

if (!isset($parameters[0]))

{

}

if (!isset($parameters[1]))

{

}

$condition = $parameters[0];

case 'custom':

if (!is_callable($parameters[0]))

{

}

return array(

default:

if (!$method)

{

}

if (!isset($this->tools[$class]))

{

}

if (!method_exists(get_class($this->tools[$class]), $method))

{

}

// Attempt to reverse operations

* Helper to get a migration

*

* @param string $name Name of the migration

*/

protected function get_migration($name)

{

/**

* Load migration data files from a directory

*

* @param string $path Path to migration data files

* @param bool $check_fulfillable If TRUE (default), we will check

* if all of the migrations are fulfillable after loading them.

* with the last call to prevent throwing errors unnecessarily).

* @return array Array of migration names

*/

{

if (!is_dir($path))

{

}

$migrations = array();

$unfulfillable = $this->unfulfillable($name);

if ($unfulfillable !== false)

{

}

}

}

*

*/

/**

* @ignore

*/

*

* Usage:

* <code>

*

* while (do_stuff())

* {

*

* @package dbal

*/

{

protected $db;

/** @var string */

protected $buffer = array();

/**

* @param string $table_name

* @param int $max_buffered_rows

*/

{

$this->db = $db;

$this->table_name = $table_name;

*

*/

/**

* @ignore

*/

*

* @package dbal

*/

{

/**

* Current sql layer

/**

* Constructor. Set DB Object and set {@link $return_statements return_statements}.

*

* @param bool $return_statements True if only statements should be returned and no SQL being executed

*/

{

$this->db = $db;

$this->return_statements = $return_statements;

trigger_error("Index name '${column_name}_gen' on table '$table_name' is too long. The maximum auto increment column length is 26 characters.", E_USER_ERROR);

}

switch ($this->sql_layer)

{

case 'mssql':

$column_list[] = $entities[0];

}

$primary_key = false;

$_new_cols = array();

{

$new_table_cols[] = 'PRIMARY KEY (' . implode(', ', $sql_schema_changes['primary_key']) . ')';

}

else if ($primary_key !== false)

{

$new_table_cols[] = $primary_key;

$columns = implode(',', $column_list);

$statements[] = 'CREATE TABLE ' . $table_name . ' (' . implode(',', $new_table_cols) . ');';

$statements[] = 'INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;';

$statements[] = 'DROP TABLE ' . $table_name . '_temp';

}

/**

*/

function sql_column_add($table_name, $column_name, $column_data, $inline = false)

{

$new_table_cols = $column_name . ' ' . $column_data['column_type_sql'] . ',' . $new_table_cols;

$statements[] = 'CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');';

$statements[] = 'INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;';

$statements[] = 'DROP TABLE ' . $table_name . '_temp';

$new_table_cols = preg_replace('/' . $column_name . '[^,]+(?:,|$)/m', '', $new_table_cols);

$statements[] = 'CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');';

$statements[] = 'INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;';

$statements[] = 'DROP TABLE ' . $table_name . '_temp';

$columns = implode(',', $column_list);

$statements[] = 'CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ', PRIMARY KEY (' . implode(', ', $column) . '));';

$statements[] = 'INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;';

$statements[] = 'DROP TABLE ' . $table_name . '_temp';

$columns = implode(',', $column_list);

$statements[] = 'CREATE TABLE ' . $table_name . ' (' . implode(',', $old_table_cols) . ');';

$statements[] = 'INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;';

$statements[] = 'DROP TABLE ' . $table_name . '_temp';