*

*/

/**

* 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) . '%';

*

*/

/**

* Firebird/Interbase Database Abstraction Layer

* Minimum Requirement is Firebird 2.1

* @package dbal

*/

{

var $last_query_text = '';

var $service_handle = false;

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

*

*/

/**

* MSSQL Database Abstraction Layer

* Minimum Requirement is MSSQL 2000+

* @package dbal

*/

{

var $connect_error = '';

{

foreach ($row as $key => $value)

{

}

}

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

{

return @mssql_free_result($query_id);

}

*

*/

/**

* MSSQL Database Base Abstraction Layer

* @package dbal

*/

{

/**

* {@inheritDoc}

*

*/

/**

* Unified ODBC functions

*

* @package dbal

*/

{

var $last_query_text = '';

var $connect_error = '';

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

*

*/

/**

* @package dbal

*/

{

var $last_query_text = '';

var $query_options = array();

var $connect_error = '';

{

foreach ($row as $key => $value)

{

}

// remove helper values from LIMIT queries

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

unset($this->open_queries[(int) $query_id]);

return @sqlsrv_free_stmt($query_id);

}

return false;

}

*

*/

/**

* MySQL4 Database Abstraction Layer

* MySQL 5.0+

* @package dbal

*/

{

var $multi_insert = true;

var $connect_error = '';

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

*

*/

/**

* Abstract MySQL Database Base Abstraction Layer

* @package dbal

*/

{

/**

* {@inheritDoc}

*

*/

/**

* MySQLi Database Abstraction Layer

* MySQL 4.1+ or MySQL 5.0+

* @package dbal

*/

{

var $multi_insert = true;

var $connect_error = '';

/**

* Connect to server

*/

{

if (!function_exists('mysqli_connect'))

{

$this->server = ($this->persistency) ? 'p:' . (($sqlserver) ? $sqlserver : 'localhost') : $sqlserver;

$this->dbname = $database;

// If port is set and it is not numeric, most likely mysqli socket is set.

// Try to map it to the $socket parameter.

if ($port)

{

if (is_numeric($port))

else

{

$socket = $port;

}

}

*

*/

/**

* Oracle Database Abstraction Layer

* @package dbal

*/

{

var $last_query_text = '';

var $connect_error = '';

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

*

*/

/**

* PostgreSQL Database Abstraction Layer

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

}

return false;

}

@pg_free_result($query_id);

return ($temp_result) ? $temp_result['last_value'] : false;

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

if ($result = @pg_query($this->db_connect_id, "EXPLAIN $explain_query"))

{

{

$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);

}

$endtime = $endtime[0] + $endtime[1];

$result = @pg_query($this->db_connect_id, $query);

{

// Take the time spent on parsing rows into account

}

*

*/

/**

* Sqlite Database Abstraction Layer

* Minimum Requirement: 2.8.2+

* @package dbal

*/

{

var $connect_error = '';

$query_id = $this->query_result;

}

{

return $cache->sql_freeresult($query_id);

}

*

*/

{

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

*

*/

{

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

*

*/

{

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

*

*/

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

{

public function effectively_installed()

{

}

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

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

{

}

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

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

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

{

}

static public function depends_on()

{

}

public function update_data()

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_schema()

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

*

*/

{

public function effectively_installed()

{

}

static public function depends_on()

{

}

public function update_data()

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

*

*/

{

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

*

*/

{

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

),

$this->table_prefix . 'notifications' => array(

'COLUMNS' => array(

'item_type' => array('VCHAR:255', ''),

'item_id' => array('UINT', 0),

'item_parent_id' => array('UINT', 0),

*

*/

{

static public function depends_on()

{

}

public function update_schema()

'add_tables' => array(

$this->table_prefix . 'notification_types' => array(

'COLUMNS' => array(

'notification_type_name' => array('VCHAR:255', ''),

'notification_type_enabled' => array('BOOL', 1),

),

),

$this->table_prefix . 'notifications' => array(

'COLUMNS' => array(

'notification_type_id' => array('USINT', 0),

'item_id' => array('UINT', 0),

'item_parent_id' => array('UINT', 0),

),

$this->table_prefix . 'notifications' => array(

'COLUMNS' => array(

'item_type' => array('VCHAR:255', ''),

'item_id' => array('UINT', 0),

'item_parent_id' => array('UINT', 0),

*

*/

{

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

{

}

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

'add_tables' => array(

$this->table_prefix . 'styles_imageset' => array(

'COLUMNS' => array(

'imageset_name' => array('VCHAR_UNI:255', ''),

'imageset_copyright' => array('VCHAR_UNI', ''),

'imageset_path' => array('VCHAR:100', ''),

),

$this->table_prefix . 'styles_imageset_data' => array(

'COLUMNS' => array(

'image_name' => array('VCHAR:200', ''),

'image_filename' => array('VCHAR:200', ''),

'image_lang' => array('VCHAR:30', ''),

),

$this->table_prefix . 'styles_template' => array(

'COLUMNS' => array(

'template_name' => array('VCHAR_UNI:255', ''),

'template_copyright' => array('VCHAR_UNI', ''),

'template_path' => array('VCHAR:100', ''),

),

$this->table_prefix . 'styles_theme' => array(

'COLUMNS' => array(

'theme_name' => array('VCHAR_UNI:255', ''),

'theme_copyright' => array('VCHAR_UNI', ''),

'theme_path' => array('VCHAR:100', ''),

*

*/

{

public function effectively_installed()

{

static public function depends_on()

{

}

public function update_schema()

'add_tables' => array(

$this->table_prefix . 'teampage' => array(

'COLUMNS' => array(

'group_id' => array('UINT', 0),

'teampage_name' => array('VCHAR_UNI:255', ''),

'teampage_position' => array('UINT', 0),

*

*/

{

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

*

*/

/**

* The migrator is responsible for applying new migrations in the correct order.

*

* @package db

*/

{

/**

* Extra parameters sent to exception to aid in debugging

}

/**

* @return string

*/

{

$parameters = $this->getParameters();

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

*

*/

/**

* Abstract base class for database migrations

*

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

*

*/

/**

* The migrator is responsible for applying new migrations in the correct order.

*

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

{

}

}

}

*

*/

/**

* Collects rows for insert into a database until the buffer size is reached.

*

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

*

*/

/**

* Database Tools for handling cross-db actions such as altering columns, etc.

*

* @package dbal

*/

{

/**

* Current sql layer

/**

* @var object DB object

*/

/**

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

{