*

*/

/**

* @ignore

*/

* Database Abstraction Layer

* @package dbal

*/

{

var $db_connect_id;

var $query_result;

// Fill default sql layer based on the class being called.

// This can be changed by the specified layer itself later if needed.

// Do not change this please! This variable is used to easy the use of it - and is hardcoded.

$this->any_char = chr(0) . '%';

*

*/

/**

* @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 = '';

*

*/

{

static public function depends_on()

{

}

public function update_data()

$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()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

return array(

array('config.add', array('email_max_chunk_size', 50)),

);

}

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

array('custom', array(array(&$this, 'cleanup_deactivated_styles'))),

array('custom', array(array(&$this, 'delete_orphan_private_messages'))),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

public function update_data()

{

return array(

);

}

}

*

*/

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

{

public function effectively_installed()

{

}

{

}

public function update_data()

array('custom', array(array(&$this, 'update_bots'))),

array('custom', array(array(&$this, 'disable_bots_from_receiving_pms'))),

);

}

WHERE user_id = $bot_user_id";

$this->sql_query($sql);

}

else

{

*

*/

{

public function effectively_installed()

{

}

public function update_schema()

array('custom', array(array(&$this, 'fix_unset_last_view_time'))),

array('custom', array(array(&$this, 'reset_smiley_size'))),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

array('config.add', array('check_attachment_content', '1')),

array('config.add', array('mime_triggers', 'body|head|html|img|plaintext|a href|pre|script|table|title')),

);

}

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

public function update_data()

{

return array(

);

}

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

array('permission.add', array('u_masspm_group', true, 'u_masspm')),

array('custom', array(array(&$this, 'correct_acp_email_permissions'))),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

return array(

array('custom', array(array(&$this, 'update_custom_profile_fields'))),

);

}

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()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

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 update_data()

{

return array(

);

}

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

array('custom', array(array(&$this, 'add_newly_registered_group'))),

array('custom', array(array(&$this, 'set_user_options_default'))),

);

}

// Clear permissions...

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

$auth_admin->acl_clear_prefetch();

}

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

return array(

array('custom', array(array(&$this, 'update_cp_fields'))),

);

}

public function update_cp_fields()

{

$sql = 'UPDATE ' . PROFILE_FIELDS_TABLE . '

SET field_show_on_vt = 1

WHERE field_hide = 0

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

array('config.add', array('feed_topics_active', $this->config['feed_overall_topics'])),

array('custom', array(array(&$this, 'delete_text_templates'))),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

return array(

array('custom', array(array(&$this, 'update_email_hash'))),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

array('config.update_if_equals', array(600, 'queue_interval', 60)),

array('config.update_if_equals', array(50, 'email_package_size', 20)),

);

}

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

array('custom', array(array(&$this, 'update_file_extension_group_names'))),

array('custom', array(array(&$this, 'fix_firebird_qa_captcha'))),

);

}

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

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(

);

}

{

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()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

return array(

);

}

*

*/

{

static public function depends_on()

{

}

public function update_data()

{

return array(

array('custom', array(array($this, 'convert_notifications'))),

);

}

{

}

/**

* Perform the conversion (separate for testability)

*

*/

{

$sql = 'SELECT user_id, user_notify_type, user_notify_pm

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

{

$notification_methods = array();

// In-board notification

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

$insert_buffer->flush();

}

/**

* 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()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

public function effectively_installed()

{

AND module_basename = 'ucp_profile'

AND module_mode = 'signature'";

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

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

return $module_auth === 'acl_u_sig' || $module_auth === false;

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

return array(

array('custom', array(array($this, 'update_post_visibility'))),

array('custom', array(array($this, 'update_topic_visibility'))),

array('permission.add', array('f_softdelete', false)),

array('permission.add', array('m_softdelete', false)),

$this->sql_query($sql);

}

{

$sql = 'UPDATE ' . $this->table_prefix . 'topics

SET topic_posts_approved = topic_replies + 1,

WHERE topic_visibility = ' . ITEM_APPROVED;

$this->sql_query($sql);

$sql = 'UPDATE ' . $this->table_prefix . 'topics

SET topic_posts_approved = 0,

WHERE topic_visibility = ' . ITEM_UNAPPROVED;

$this->sql_query($sql);

$sql = 'SELECT forum_id, topic_visibility, COUNT(topic_id) AS sum_topics, SUM(topic_posts_approved) AS sum_posts_approved, SUM(topic_posts_unapproved) AS sum_posts_unapproved

FROM ' . $this->table_prefix . 'topics

$update_forums = array();

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

{

$forum_id = (int) $row['forum_id'];

if (!isset($update_forums[$forum_id]))

{

WHERE forum_id = ' . $forum_id;

$this->sql_query($sql);

}

}

}

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

return array(

);

}

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

// 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()

{

static public function depends_on()

{

}

public function update_schema()

*

*/

{

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);

{

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;

*

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

{

// The "automatic" way

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

$module = $this->get_module_info($class, $basename);

$result = '';

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

$module_info = $this->get_module_info($class, $basename);

foreach ($module_info['modes'] as $mode => $info)

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))

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;

foreach ($state['migration_depends_on'] as $depend)

{

if (!isset($this->migration_state[$depend]) ||

!$this->migration_state[$depend]['migration_schema_done'] ||

!$this->migration_state[$depend]['migration_data_done'])

'name' => $name,

'class' => $migration,

'state' => $state,

);

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

{

{

$state = array(

'migration_depends_on' => $migration->depends_on(),

}

}

if (!$state['migration_schema_done'])

{

$this->apply_schema_changes($migration->update_schema());

$state['migration_schema_done'] = true;

}

{

try

{

$result = $this->process_data_step($migration->update_data(), $state['migration_data_state']);

$state['migration_data_state'] = ($result === true) ? '' : $result;

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

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

}

{

// Revert the schema changes

$this->revert($name);

$this->last_run_migration = array(

'name' => $name,

'class' => $migration,

);

if ($state['migration_data_done'])

));

}

}

{

// 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

{

continue;

}

return false;

}

* 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

* The Column types for every database we support

* @var array

*/

/**

* A list of types being unsigned for better reference in some db's

/**

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

// Determine mapping database type

switch ($this->db->sql_layer)

{