1 files changed, 58 insertions, 1459 deletions
diff --git a/phpBB/install/database_update.php b/phpBB/install/database_update.php
index 67794221a6..0b495cf995 100644
--- a/phpBB/install/database_update.php
+++ b/phpBB/install/database_update.php
@@ -8,7 +8,7 @@
 *
 */
 
-$updates_to_version = '3.0.3';
+$updates_to_version = '3.1.0';
 
 // Return if we "just include it" to find out for which version the database update is responsuble for
 if (defined('IN_PHPBB') && defined('IN_INSTALL'))
@@ -23,304 +23,32 @@ define('IN_INSTALL', true);
 
 if (!defined('PHPBB_ROOT_PATH')) define('PHPBB_ROOT_PATH', './../');
 if (!defined('PHP_EXT')) define('PHP_EXT', substr(strrchr(__FILE__, '.'), 1));
-
-// Report all errors, except notices
-//error_reporting(E_ALL ^ E_NOTICE);
-error_reporting(E_ALL);
+include PHPBB_ROOT_PATH . 'common.' . PHP_EXT;
 
 @set_time_limit(0);
 
-// Include essential scripts
-include(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
-
-if (!isset($dbms))
-{
-	die("Please read: <a href='../docs/INSTALL.html'>INSTALL.html</a> before attempting to update.");
-}
-
-// Load Extensions
-if (!empty($load_extensions))
-{
-	$load_extensions = explode(',', $load_extensions);
-
-	foreach ($load_extensions as $extension)
-	{
-		@dl(trim($extension));
-	}
-}
-
-// Include files
-require(PHPBB_ROOT_PATH . 'includes/acm/acm_' . $acm_type . '.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/cache.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/template.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/session.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/auth.' . PHP_EXT);
-
-require(PHPBB_ROOT_PATH . 'includes/functions.' . PHP_EXT);
-
-if (file_exists(PHPBB_ROOT_PATH . 'includes/functions_content.' . PHP_EXT))
-{
-	require(PHPBB_ROOT_PATH . 'includes/functions_content.' . PHP_EXT);
-}
-
-require(PHPBB_ROOT_PATH . 'includes/functions_admin.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);
-require(PHPBB_ROOT_PATH . 'includes/utf/utf_tools.' . PHP_EXT);
+// Start session management
+phpbb::$user->session_begin();
+phpbb::$acl->init(phpbb::$user->data);
+phpbb::$user->setup('install');
 
-// If we are on PHP >= 6.0.0 we do not need some code
-if (version_compare(PHP_VERSION, '6.0.0-dev', '>='))
-{
-	/**
-	* @ignore
-	*/
-	define('STRIP', false);
-}
-else
+if (!phpbb::$user->is_registered)
 {
-	@set_magic_quotes_runtime(0);
-	define('STRIP', (get_magic_quotes_gpc()) ? true : false);
+	login_box();
 }
 
-$user = new user();
-$db = new $sql_db();
-
-// Connect to DB
-$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, false);
-
-// We do not need this any longer, unset for safety purposes
-unset($dbpasswd);
-
-$user->ip = (!empty($_SERVER['REMOTE_ADDR'])) ? htmlspecialchars($_SERVER['REMOTE_ADDR']) : '';
-
-$sql = "SELECT config_value
-	FROM " . CONFIG_TABLE . "
-	WHERE config_name = 'default_lang'";
-$result = $db->sql_query($sql);
-$row = $db->sql_fetchrow($result);
-$db->sql_freeresult($result);
-
-$language = basename(request_var('language', ''));
-
-if (!$language)
+if (!phpbb::$acl->acl_get('a_board'))
 {
-	$language = $row['config_value'];
+	trigger_error('NO_AUTH');
 }
 
-if (!file_exists(PHPBB_ROOT_PATH . 'language/' . $language))
-{
-	die('No language found!');
-}
+include PHPBB_ROOT_PATH . 'includes/db/db_tools.' . PHP_EXT;
 
-// And finally, load the relevant language files
-include(PHPBB_ROOT_PATH . 'language/' . $language . '/common.' . PHP_EXT);
-include(PHPBB_ROOT_PATH . 'language/' . $language . '/acp/common.' . PHP_EXT);
-include(PHPBB_ROOT_PATH . 'language/' . $language . '/install.' . PHP_EXT);
-
-// Set PHP error handler to ours
-//set_error_handler('msg_handler');
+$db_tools = new phpbb_db_tools(phpbb::$db, true);
 
 // Define some variables for the database update
 $inline_update = (request_var('type', 0)) ? true : false;
 
-// Database column types mapping
-$dbms_type_map = array(
-	'mysql'		=> array(
-		'INT:'		=> 'int(%d)',
-		'BINT'		=> 'bigint(20)',
-		'UINT'		=> 'mediumint(8) UNSIGNED',
-		'UINT:'		=> 'int(%d) UNSIGNED',
-		'TINT:'		=> 'tinyint(%d)',
-		'USINT'		=> 'smallint(4) UNSIGNED',
-		'BOOL'		=> 'tinyint(1) UNSIGNED',
-		'VCHAR'		=> 'varchar(255)',
-		'VCHAR:'	=> 'varchar(%d)',
-		'CHAR:'		=> 'char(%d)',
-		'XSTEXT'	=> 'text',
-		'XSTEXT_UNI'=> 'varchar(100)',
-		'STEXT'		=> 'text',
-		'STEXT_UNI'	=> 'varchar(255)',
-		'TEXT'		=> 'text',
-		'TEXT_UNI'	=> 'text',
-		'MTEXT'		=> 'mediumtext',
-		'MTEXT_UNI'	=> 'mediumtext',
-		'TIMESTAMP'	=> 'int(11) UNSIGNED',
-		'DECIMAL'	=> 'decimal(5,2)',
-		'VCHAR_UNI'	=> 'varchar(255)',
-		'VCHAR_UNI:'=> 'varchar(%d)',
-		'VCHAR_CI'	=> 'varchar(255)',
-		'VARBINARY'	=> 'varbinary(255)',
-	),
-
-	'firebird'	=> array(
-		'INT:'		=> 'INTEGER',
-		'BINT'		=> 'DOUBLE PRECISION',
-		'UINT'		=> 'INTEGER',
-		'UINT:'		=> 'INTEGER',
-		'TINT:'		=> 'INTEGER',
-		'USINT'		=> 'INTEGER',
-		'BOOL'		=> 'INTEGER',
-		'VCHAR'		=> 'VARCHAR(255) CHARACTER SET NONE',
-		'VCHAR:'	=> 'VARCHAR(%d) CHARACTER SET NONE',
-		'CHAR:'		=> 'CHAR(%d) CHARACTER SET NONE',
-		'XSTEXT'	=> 'BLOB SUB_TYPE TEXT CHARACTER SET NONE',
-		'STEXT'		=> 'BLOB SUB_TYPE TEXT CHARACTER SET NONE',
-		'TEXT'		=> 'BLOB SUB_TYPE TEXT CHARACTER SET NONE',
-		'MTEXT'		=> 'BLOB SUB_TYPE TEXT CHARACTER SET NONE',
-		'XSTEXT_UNI'=> 'VARCHAR(100) CHARACTER SET UTF8',
-		'STEXT_UNI'	=> 'VARCHAR(255) CHARACTER SET UTF8',
-		'TEXT_UNI'	=> 'BLOB SUB_TYPE TEXT CHARACTER SET UTF8',
-		'MTEXT_UNI'	=> 'BLOB SUB_TYPE TEXT CHARACTER SET UTF8',
-		'TIMESTAMP'	=> 'INTEGER',
-		'DECIMAL'	=> 'DOUBLE PRECISION',
-		'VCHAR_UNI'	=> 'VARCHAR(255) CHARACTER SET UTF8',
-		'VCHAR_UNI:'=> 'VARCHAR(%d) CHARACTER SET UTF8',
-		'VCHAR_CI'	=> 'VARCHAR(255) CHARACTER SET UTF8',
-		'VARBINARY'	=> 'CHAR(255) CHARACTER SET NONE',
-	),
-
-	'mssql'		=> array(
-		'INT:'		=> '[int]',
-		'BINT'		=> '[float]',
-		'UINT'		=> '[int]',
-		'UINT:'		=> '[int]',
-		'TINT:'		=> '[int]',
-		'USINT'		=> '[int]',
-		'BOOL'		=> '[int]',
-		'VCHAR'		=> '[varchar] (255)',
-		'VCHAR:'	=> '[varchar] (%d)',
-		'CHAR:'		=> '[char] (%d)',
-		'XSTEXT'	=> '[varchar] (1000)',
-		'STEXT'		=> '[varchar] (3000)',
-		'TEXT'		=> '[varchar] (8000)',
-		'MTEXT'		=> '[text]',
-		'XSTEXT_UNI'=> '[varchar] (100)',
-		'STEXT_UNI'	=> '[varchar] (255)',
-		'TEXT_UNI'	=> '[varchar] (4000)',
-		'MTEXT_UNI'	=> '[text]',
-		'TIMESTAMP'	=> '[int]',
-		'DECIMAL'	=> '[float]',
-		'VCHAR_UNI'	=> '[varchar] (255)',
-		'VCHAR_UNI:'=> '[varchar] (%d)',
-		'VCHAR_CI'	=> '[varchar] (255)',
-		'VARBINARY'	=> '[varchar] (255)',
-	),
-
-	'oracle'	=> array(
-		'INT:'		=> 'number(%d)',
-		'BINT'		=> 'number(20)',
-		'UINT'		=> 'number(8)',
-		'UINT:'		=> 'number(%d)',
-		'TINT:'		=> 'number(%d)',
-		'USINT'		=> 'number(4)',
-		'BOOL'		=> 'number(1)',
-		'VCHAR'		=> 'varchar2(255 char)',
-		'VCHAR:'	=> 'varchar2(%d char)',
-		'CHAR:'		=> 'char(%d char)',
-		'XSTEXT'	=> 'varchar2(1000 char)',
-		'STEXT'		=> 'varchar2(3000 char)',
-		'TEXT'		=> 'clob',
-		'MTEXT'		=> 'clob',
-		'XSTEXT_UNI'=> 'varchar2(100 char)',
-		'STEXT_UNI'	=> 'varchar2(255 char)',
-		'TEXT_UNI'	=> 'clob',
-		'MTEXT_UNI'	=> 'clob',
-		'TIMESTAMP'	=> 'number(11)',
-		'DECIMAL'	=> 'number(5, 2)',
-		'DECIMAL:'	=> 'number(%d, 2)',
-		'PDECIMAL'	=> 'number(6, 3)',
-		'PDECIMAL:'	=> 'number(%d, 3)',
-		'VCHAR_UNI'	=> 'varchar2(255 char)',
-		'VCHAR_UNI:'=> 'varchar2(%d char)',
-		'VCHAR_CI'	=> 'varchar2(255 char)',
-		'VARBINARY'	=> 'raw(255)',
-	),
-
-	'db2'		=> array(
-		'INT:'		=> 'integer',
-		'BINT'		=> 'float',
-		'UINT'		=> 'integer',
-		'UINT:'		=> 'integer',
-		'TINT:'		=> 'smallint',
-		'USINT'		=> 'smallint',
-		'BOOL'		=> 'smallint',
-		'VCHAR'		=> 'varchar(255)',
-		'VCHAR:'	=> 'varchar(%d)',
-		'CHAR:'		=> 'char(%d)',
-		'XSTEXT'	=> 'clob(65K)',
-		'STEXT'		=> 'varchar(3000)',
-		'TEXT'		=> 'clob(65K)',
-		'MTEXT'		=> 'clob(16M)',
-		'XSTEXT_UNI'=> 'varchar(100)',
-		'STEXT_UNI'	=> 'varchar(255)',
-		'TEXT_UNI'	=> 'clob(65K)',
-		'MTEXT_UNI'	=> 'clob(16M)',
-		'TIMESTAMP'	=> 'integer',
-		'DECIMAL'	=> 'float',
-		'VCHAR_UNI'	=> 'varchar(255)',
-		'VCHAR_UNI:'=> 'varchar(%d)',
-		'VCHAR_CI'	=> 'varchar(255)',
-		'VARBINARY'	=> 'varchar(255)',
-	),
-
-	'sqlite'	=> array(
-		'INT:'		=> 'int(%d)',
-		'BINT'		=> 'bigint(20)',
-		'UINT'		=> 'INTEGER UNSIGNED', //'mediumint(8) UNSIGNED',
-		'UINT:'		=> 'INTEGER UNSIGNED', // 'int(%d) UNSIGNED',
-		'TINT:'		=> 'tinyint(%d)',
-		'USINT'		=> 'INTEGER UNSIGNED', //'mediumint(4) UNSIGNED',
-		'BOOL'		=> 'INTEGER UNSIGNED', //'tinyint(1) UNSIGNED',
-		'VCHAR'		=> 'varchar(255)',
-		'VCHAR:'	=> 'varchar(%d)',
-		'CHAR:'		=> 'char(%d)',
-		'XSTEXT'	=> 'text(65535)',
-		'STEXT'		=> 'text(65535)',
-		'TEXT'		=> 'text(65535)',
-		'MTEXT'		=> 'mediumtext(16777215)',
-		'XSTEXT_UNI'=> 'text(65535)',
-		'STEXT_UNI'	=> 'text(65535)',
-		'TEXT_UNI'	=> 'text(65535)',
-		'MTEXT_UNI'	=> 'mediumtext(16777215)',
-		'TIMESTAMP'	=> 'INTEGER UNSIGNED', //'int(11) UNSIGNED',
-		'DECIMAL'	=> 'decimal(5,2)',
-		'VCHAR_UNI'	=> 'varchar(255)',
-		'VCHAR_UNI:'=> 'varchar(%d)',
-		'VCHAR_CI'	=> 'varchar(255)',
-		'VARBINARY'	=> 'blob',
-	),
-
-	'postgres'	=> array(
-		'INT:'		=> 'INT4',
-		'BINT'		=> 'INT8',
-		'UINT'		=> 'INT4', // unsigned
-		'UINT:'		=> 'INT4', // unsigned
-		'USINT'		=> 'INT2', // unsigned
-		'BOOL'		=> 'boolean', // unsigned
-		'TINT:'		=> 'INT2',
-		'VCHAR'		=> 'varchar(255)',
-		'VCHAR:'	=> 'varchar(%d)',
-		'CHAR:'		=> 'char(%d)',
-		'XSTEXT'	=> 'varchar(1000)',
-		'STEXT'		=> 'varchar(3000)',
-		'TEXT'		=> 'varchar(8000)',
-		'MTEXT'		=> 'TEXT',
-		'XSTEXT_UNI'=> 'varchar(100)',
-		'STEXT_UNI'	=> 'varchar(255)',
-		'TEXT_UNI'	=> 'varchar(4000)',
-		'MTEXT_UNI'	=> 'TEXT',
-		'TIMESTAMP'	=> 'INT4', // unsigned
-		'DECIMAL'	=> 'decimal(5,2)',
-		'VCHAR_UNI'	=> 'varchar(255)',
-		'VCHAR_UNI:'=> 'varchar(%d)',
-		'VCHAR_CI'	=> 'varchar(255)',
-		'VARBINARY'	=> 'bytea',
-	),
-);
-
-// A list of types being unsigned for better reference in some db's
-$unsigned_types = array('UINT', 'UINT:', 'USINT', 'BOOL', 'TIMESTAMP');
-
 // Only an example, but also commented out
 $database_update_info = array(
 
@@ -328,9 +56,6 @@ $database_update_info = array(
 	'3.0.3-RC1'		=> array(),
 );
 
-// Determine mapping database type
-$map_dbms = $db->dbms_type;
-
 $error_ary = array();
 $errored = false;
 
@@ -338,15 +63,15 @@ header('Content-type: text/html; charset=UTF-8');
 
 ?>
 <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
-<html xmlns="http://www.w3.org/1999/xhtml" dir="<?php echo $lang['DIRECTION']; ?>" lang="<?php echo $lang['USER_LANG']; ?>" xml:lang="<?php echo $lang['USER_LANG']; ?>">
+<html xmlns="http://www.w3.org/1999/xhtml" dir="<?php echo phpbb::$user->lang['DIRECTION']; ?>" lang="<?php echo phpbb::$user->lang['USER_LANG']; ?>" xml:lang="<?php echo phpbb::$user->lang['USER_LANG']; ?>">
 <head>
 
 <meta http-equiv="content-type" content="text/html; charset=UTF-8" />
-<meta http-equiv="content-language" content="<?php echo $lang['USER_LANG']; ?>" />
+<meta http-equiv="content-language" content="<?php echo phpbb::$user->lang['USER_LANG']; ?>" />
 <meta http-equiv="content-style-type" content="text/css" />
 <meta http-equiv="imagetoolbar" content="no" />
 
-<title><?php echo $lang['UPDATING_TO_LATEST_STABLE']; ?></title>
+<title><?php echo phpbb::$user->lang['UPDATING_TO_LATEST_STABLE']; ?></title>
 
 <link href="../adm/style/admin.css" rel="stylesheet" type="text/css" media="screen" />
 
@@ -363,19 +88,19 @@ header('Content-type: text/html; charset=UTF-8');
 				<div id="content">
 					<div id="main">
 
-	<h1><?php echo $lang['UPDATING_TO_LATEST_STABLE']; ?></h1>
+	<h1><?php echo phpbb::$user->lang['UPDATING_TO_LATEST_STABLE']; ?></h1>
 
 	<br />
 
-	<p><?php echo $lang['DATABASE_TYPE']; ?> :: <strong><?php echo $db->sql_layer; ?></strong><br />
+	<p><?php echo phpbb::$user->lang['DATABASE_TYPE']; ?> :: <strong><?php echo phpbb::$db->sql_layer; ?></strong><br />
 <?php
 
 // To let set_config() calls succeed, we need to make the config array available globally
 phpbb::$acm->destroy('#config');
 $config = phpbb_cache::obtain_config();
 
-echo $lang['PREVIOUS_VERSION'] . ' :: <strong>' . phpbb::$config['version'] . '</strong><br />';
-echo $lang['UPDATED_VERSION'] . ' :: <strong>' . $updates_to_version . '</strong></p>';
+echo phpbb::$user->lang['PREVIOUS_VERSION'] . ' :: <strong>' . phpbb::$config['version'] . '</strong><br />';
+echo phpbb::$user->lang['UPDATED_VERSION'] . ' :: <strong>' . $updates_to_version . '</strong></p>';
 
 $current_version = str_replace('rc', 'RC', strtolower(phpbb::$config['version']));
 $latest_version = str_replace('rc', 'RC', strtolower($updates_to_version));
@@ -392,46 +117,17 @@ if ($inline_update)
 else
 {
 	// If not called from the update script, we will actually remove the traces
-	$db->sql_query('DELETE FROM ' . CONFIG_TABLE . " WHERE config_name = 'version_update_from'");
-}
-
-// Checks/Operations that have to be completed prior to starting the update itself
-$exit = false;
-
-if ($exit)
-{
-?>
-
-					</div>
-				</div>
-			<span class="corners-bottom"><span></span></span>
-		</div>
-		</div>
-	</div>
-
-	<div id="page-footer">
-		Powered by <a href="http://www.phpbb.com/">phpBB</a> &copy; 2000, 2002, 2005, 2007 phpBB Group
-	</div>
-</div>
-
-</body>
-</html>
-
-<?php
-	if (function_exists('exit_handler'))
-	{
-		exit_handler();
-	}
+	phpbb::$db->sql_query('DELETE FROM ' . CONFIG_TABLE . " WHERE config_name = 'version_update_from'");
 }
 
 // Schema updates
 ?>
 	<br /><br />
 
-	<h1><?php echo $lang['UPDATE_DATABASE_SCHEMA']; ?></h1>
+	<h1><?php echo phpbb::$user->lang['UPDATE_DATABASE_SCHEMA']; ?></h1>
 
 	<br />
-	<p><?php echo $lang['PROGRESS']; ?> :: <strong>
+	<p><?php echo phpbb::$user->lang['PROGRESS']; ?> :: <strong>
 
 <?php
 
@@ -439,6 +135,8 @@ flush();
 
 // We go through the schema changes from the lowest to the highest version
 // We try to also include versions 'in-between'...
+// We go through the schema changes from the lowest to the highest version
+// We try to also include versions 'in-between'...
 $no_updates = true;
 $versions = array_keys($database_update_info);
 for ($i = 0; $i < sizeof($versions); $i++)
@@ -448,101 +146,27 @@ for ($i = 0; $i < sizeof($versions); $i++)
 
 	$next_version = (isset($versions[$i + 1])) ? $versions[$i + 1] : $updates_to_version;
 
-	if (!sizeof($schema_changes))
-	{
-		continue;
-	}
-
 	// If the installed version to be updated to is < than the current version, and if the current version is >= as the version to be updated to next, we will skip the process
 	if (version_compare($version, $current_version, '<') && version_compare($current_version, $next_version, '>='))
 	{
 		continue;
 	}
 
-	$no_updates = false;
-
-	// Change columns?
-	if (!empty($schema_changes['change_columns']))
-	{
-		foreach ($schema_changes['change_columns'] as $table => $columns)
-		{
-			foreach ($columns as $column_name => $column_data)
-			{
-				sql_column_change($map_dbms, $table, $column_name, $column_data);
-			}
-		}
-	}
-
-	// Add columns?
-	if (!empty($schema_changes['add_columns']))
-	{
-		foreach ($schema_changes['add_columns'] as $table => $columns)
-		{
-			foreach ($columns as $column_name => $column_data)
-			{
-				// Only add the column if it does not exist yet
-				if (!column_exists($map_dbms, $table, $column_name))
-				{
-					sql_column_add($map_dbms, $table, $column_name, $column_data);
-				}
-			}
-		}
-	}
-
-	// Remove keys?
-	if (!empty($schema_changes['drop_keys']))
-	{
-		foreach ($schema_changes['drop_keys'] as $table => $indexes)
-		{
-			foreach ($indexes as $index_name)
-			{
-				sql_index_drop($map_dbms, $index_name, $table);
-			}
-		}
-	}
-
-	// Drop columns?
-	if (!empty($schema_changes['drop_columns']))
+	if (!sizeof($schema_changes))
 	{
-		foreach ($schema_changes['drop_columns'] as $table => $columns)
-		{
-			foreach ($columns as $column)
-			{
-				sql_column_remove($map_dbms, $table, $column);
-			}
-		}
+		continue;
 	}
 
-	// Add primary keys?
-	if (!empty($schema_changes['add_primary_keys']))
-	{
-		foreach ($schema_changes['add_primary_keys'] as $table => $columns)
-		{
-			sql_create_primary_key($map_dbms, $table, $columns);
-		}
-	}
+	// Get statements for schema updates
+	$statements = $db_tools->sql_schema_changes($schema_changes);
 
-	// Add unqiue indexes?
-	if (!empty($schema_changes['add_unique_index']))
+	if (sizeof($statements))
 	{
-		foreach ($schema_changes['add_unique_index'] as $table => $index_array)
-		{
-			foreach ($index_array as $index_name => $column)
-			{
-				sql_create_unique_index($map_dbms, $index_name, $table, $column);
-			}
-		}
-	}
+		$no_updates = false;
 
-	// Add indexes?
-	if (!empty($schema_changes['add_index']))
-	{
-		foreach ($schema_changes['add_index'] as $table => $index_array)
+		foreach ($statements as $sql)
 		{
-			foreach ($index_array as $index_name => $column)
-			{
-				sql_create_index($map_dbms, $index_name, $table, $column);
-			}
+			_sql($sql, $errored, $error_ary);
 		}
 	}
 }
@@ -556,9 +180,9 @@ $errored = $no_updates = false;
 ?>
 
 <br /><br />
-<h1><?php echo $lang['UPDATING_DATA']; ?></h1>
+<h1><?php echo phpbb::$user->lang['UPDATING_DATA']; ?></h1>
 <br />
-<p><?php echo $lang['PROGRESS']; ?> :: <strong>
+<p><?php echo phpbb::$user->lang['PROGRESS']; ?> :: <strong>
 
 <?php
 
@@ -566,8 +190,8 @@ flush();
 
 $no_updates = true;
 
-$versions = array(
-);
+$no_updates = true;
+$versions = array_keys($database_update_info);
 
 // some code magic
 for ($i = 0; $i < sizeof($versions); $i++)
@@ -581,8 +205,7 @@ for ($i = 0; $i < sizeof($versions); $i++)
 		continue;
 	}
 
-	$no_updates = false;
-	change_database_data($version);
+	change_database_data($no_updates, $version);
 }
 
 _write_result($no_updates, $errored, $error_ary);
@@ -593,9 +216,9 @@ $errored = $no_updates = false;
 ?>
 
 <br /><br />
-<h1><?php echo $lang['UPDATE_VERSION_OPTIMIZE']; ?></h1>
+<h1><?php echo phpbb::$user->lang['UPDATE_VERSION_OPTIMIZE']; ?></h1>
 <br />
-<p><?php echo $lang['PROGRESS']; ?> :: <strong>
+<p><?php echo phpbb::$user->lang['PROGRESS']; ?> :: <strong>
 
 <?php
 
@@ -634,7 +257,7 @@ _write_result($no_updates, $errored, $error_ary);
 ?>
 
 <br />
-<h1><?php echo $lang['UPDATE_COMPLETED']; ?></h1>
+<h1><?php echo phpbb::$user->lang['UPDATE_COMPLETED']; ?></h1>
 
 <br />
 
@@ -646,9 +269,9 @@ if (!$inline_update)
 	phpbb::$acm->purge();
 ?>
 
-	<p style="color:red"><?php echo $lang['UPDATE_FILES_NOTICE']; ?></p>
+	<p style="color:red"><?php echo phpbb::$user->lang['UPDATE_FILES_NOTICE']; ?></p>
 
-	<p><?php echo $lang['COMPLETE_LOGIN_TO_BOARD']; ?></p>
+	<p><?php echo phpbb::$user->lang['COMPLETE_LOGIN_TO_BOARD']; ?></p>
 
 <?php
 }
@@ -656,9 +279,9 @@ else
 {
 ?>
 
-	<p><?php echo ((isset($lang['INLINE_UPDATE_SUCCESSFUL'])) ? $lang['INLINE_UPDATE_SUCCESSFUL'] : 'The database update was successful. Now you need to continue the update process.'); ?></p>
+	<p><?php echo ((isset(phpbb::$user->lang['INLINE_UPDATE_SUCCESSFUL'])) ? phpbb::$user->lang['INLINE_UPDATE_SUCCESSFUL'] : 'The database update was successful. Now you need to continue the update process.'); ?></p>
 
-	<p><a href="<?php echo append_sid('install/index', "mode=update&amp;sub=file_check&amp;lang=$language"); ?>" class="button1"><?php echo (isset($lang['CONTINUE_UPDATE_NOW'])) ? $lang['CONTINUE_UPDATE_NOW'] : 'Continue the update process now'; ?></a></p>
+	<p><a href="<?php echo append_sid('install/index', "mode=update&amp;sub=file_check&amp;lang=$language"); ?>" class="button1"><?php echo (isset(phpbb::$user->lang['CONTINUE_UPDATE_NOW'])) ? phpbb::$user->lang['CONTINUE_UPDATE_NOW'] : 'Continue the update process now'; ?></a></p>
 
 <?php
 }
@@ -700,7 +323,7 @@ if (function_exists('exit_handler'))
 */
 function change_database_data($version)
 {
-	global $db, $map_dbms, $errored, $error_ary;
+	global $errored, $error_ary;
 
 	switch ($version)
 	{
@@ -714,24 +337,22 @@ function change_database_data($version)
 */
 function _sql($sql, &$errored, &$error_ary, $echo_dot = true)
 {
-	global $db;
-
 	if (defined('DEBUG_EXTRA'))
 	{
 		echo "<br />\n{$sql}\n<br />";
 	}
 
-	$db->sql_return_on_error(true);
+	phpbb::$db->sql_return_on_error(true);
 
-	$result = $db->sql_query($sql);
-	if ($db->sql_error_triggered)
+	$result = phpbb::$db->sql_query($sql);
+	if (phpbb::$db->sql_error_triggered)
 	{
 		$errored = true;
-		$error_ary['sql'][] = $db->sql_error_sql;
-		$error_ary['error_code'][] = $db->_sql_error();
+		$error_ary['sql'][] = phpbb::$db->sql_error_sql;
+		$error_ary['error_code'][] = phpbb::$db->_sql_error();
 	}
 
-	$db->sql_return_on_error(false);
+	phpbb::$db->sql_return_on_error(false);
 
 	if ($echo_dot)
 	{
@@ -744,1052 +365,30 @@ function _sql($sql, &$errored, &$error_ary, $echo_dot = true)
 
 function _write_result($no_updates, $errored, $error_ary)
 {
-	global $lang;
-
 	if ($no_updates)
 	{
-		echo ' ' . $lang['NO_UPDATES_REQUIRED'] . '</strong></p>';
+		echo ' ' . phpbb::$user->lang['NO_UPDATES_REQUIRED'] . '</strong></p>';
 	}
 	else
 	{
-		echo ' <span class="success">' . $lang['DONE'] . '</span></strong><br />' . $lang['RESULT'] . ' :: ';
+		echo ' <span class="success">' . phpbb::$user->lang['DONE'] . '</span></strong><br />' . phpbb::$user->lang['RESULT'] . ' :: ';
 
 		if ($errored)
 		{
-			echo ' <strong>' . $lang['SOME_QUERIES_FAILED'] . '</strong> <ul>';
+			echo ' <strong>' . phpbb::$user->lang['SOME_QUERIES_FAILED'] . '</strong> <ul>';
 
 			for ($i = 0; $i < sizeof($error_ary['sql']); $i++)
 			{
-				echo '<li>' . $lang['ERROR'] . ' :: <strong>' . htmlspecialchars($error_ary['error_code'][$i]['message']) . '</strong><br />';
-				echo $lang['SQL'] . ' :: <strong>' . htmlspecialchars($error_ary['sql'][$i]) . '</strong><br /><br /></li>';
-			}
-
-			echo '</ul> <br /><br />' . $lang['SQL_FAILURE_EXPLAIN'] . '</p>';
-		}
-		else
-		{
-			echo '<strong>' . $lang['NO_ERRORS'] . '</strong></p>';
-		}
-	}
-}
-
-/**
-* Check if a specified column exist
-*/
-function column_exists($dbms, $table, $column_name)
-{
-	global $db;
-
-	switch ($dbms)
-	{
-		case 'mysql':
-			$sql = "SHOW COLUMNS
-				FROM $table";
-			$result = $db->sql_query($sql);
-			while ($row = $db->sql_fetchrow($result))
-			{
-				// lower case just in case
-				if (strtolower($row['Field']) == $column_name)
-				{
-					$db->sql_freeresult($result);
-					return true;
-				}
-			}
-			$db->sql_freeresult($result);
-			return false;
-		break;
-
-		// PostgreSQL has a way of doing this in a much simpler way but would
-		// not allow us to support all versions of PostgreSQL
-		case 'postgres':
-			$sql = "SELECT a.attname
-				FROM pg_class c, pg_attribute a
-				WHERE c.relname = '{$table}'
-					AND a.attnum > 0
-					AND a.attrelid = c.oid";
-			$result = $db->sql_query($sql);
-			while ($row = $db->sql_fetchrow($result))
-			{
-				// lower case just in case
-				if (strtolower($row['attname']) == $column_name)
-				{
-					$db->sql_freeresult($result);
-					return true;
-				}
-			}
-			$db->sql_freeresult($result);
-			return false;
-		break;
-
-		// same deal with PostgreSQL, we must perform more complex operations than
-		// we technically could
-		case 'mssql':
-			$sql = "SELECT c.name
-				FROM syscolumns c
-				LEFT JOIN sysobjects o ON c.id = o.id
-				WHERE o.name = '{$table}'";
-			$result = $db->sql_query($sql);
-			while ($row = $db->sql_fetchrow($result))
-			{
-				// lower case just in case
-				if (strtolower($row['name']) == $column_name)
-				{
-					$db->sql_freeresult($result);
-					return true;
-				}
-			}
-			$db->sql_freeresult($result);
-			return false;
-		break;
-
-		case 'oracle':
-			$sql = "SELECT column_name
-				FROM user_tab_columns
-				WHERE table_name = '{$table}'";
-			$result = $db->sql_query($sql);
-			while ($row = $db->sql_fetchrow($result))
-			{
-				// lower case just in case
-				if (strtolower($row['column_name']) == $column_name)
-				{
-					$db->sql_freeresult($result);
-					return true;
-				}
-			}
-			$db->sql_freeresult($result);
-			return false;
-		break;
-
-		case 'firebird':
-			$sql = "SELECT RDB\$FIELD_NAME as FNAME
-				FROM RDB\$RELATION_FIELDS
-				WHERE RDB\$RELATION_NAME = '{$table}'";
-			$result = $db->sql_query($sql);
-			while ($row = $db->sql_fetchrow($result))
-			{
-				// lower case just in case
-				if (strtolower($row['fname']) == $column_name)
-				{
-					$db->sql_freeresult($result);
-					return true;
-				}
+				echo '<li>' . phpbb::$user->lang['ERROR'] . ' :: <strong>' . htmlspecialchars($error_ary['error_code'][$i]['message']) . '</strong><br />';
+				echo phpbb::$user->lang['SQL'] . ' :: <strong>' . htmlspecialchars($error_ary['sql'][$i]) . '</strong><br /><br /></li>';
 			}
-			$db->sql_freeresult($result);
-			return false;
-		break;
-
-		// ugh, SQLite
-		case 'sqlite':
-			$sql = "SELECT sql
-				FROM sqlite_master
-				WHERE type = 'table'
-					AND name = '{$table}'";
-			$result = $db->sql_query($sql);
-
-			if (!$result)
-			{
-				return false;
-			}
-
-			$row = $db->sql_fetchrow($result);
-			$db->sql_freeresult($result);
-
-			preg_match('#\((.*)\)#s', $row['sql'], $matches);
-
-			$cols = trim($matches[1]);
-			$col_array = preg_split('/,(?![\s\w]+\))/m', $cols);
 
-			foreach ($col_array as $declaration)
-			{
-				$entities = preg_split('#\s+#', trim($declaration));
-				if ($entities[0] == 'PRIMARY')
-				{
-					continue;
-				}
-
-				if (strtolower($entities[0]) == $column_name)
-				{
-					return true;
-				}
-			}
-			return false;
-		break;
-	}
-}
-
-/**
-* Function to prepare some column information for better usage
-*/
-function prepare_column_data($dbms, $column_data, $table_name, $column_name)
-{
-	global $dbms_type_map, $unsigned_types;
-
-	// Get type
-	if (strpos($column_data[0], ':') !== false)
-	{
-		list($orig_column_type, $column_length) = explode(':', $column_data[0]);
-
-		if (!is_array($dbms_type_map[$dbms][$orig_column_type . ':']))
-		{
-			$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'], $column_length);
+			echo '</ul> <br /><br />' . phpbb::$user->lang['SQL_FAILURE_EXPLAIN'] . '</p>';
 		}
 		else
 		{
-			if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['rule']))
-			{
-				switch ($dbms_type_map[$dbms][$orig_column_type . ':']['rule'][0])
-				{
-					case 'div':
-						$column_length /= $dbms_type_map[$dbms][$orig_column_type . ':']['rule'][1];
-						$column_length = ceil($column_length);
-						$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);
-					break;
-				}
-			}
-
-			if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['limit']))
-			{
-				switch ($dbms_type_map[$dbms][$orig_column_type . ':']['limit'][0])
-				{
-					case 'mult':
-						$column_length *= $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][1];
-						if ($column_length > $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][2])
-						{
-							$column_type = $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][3];
-						}
-						else
-						{
-							$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);
-						}
-					break;
-				}
-			}
+			echo '<strong>' . phpbb::$user->lang['NO_ERRORS'] . '</strong></p>';
 		}
-		$orig_column_type .= ':';
-	}
-	else
-	{
-		$orig_column_type = $column_data[0];
-		$column_type = $dbms_type_map[$dbms][$column_data[0]];
-	}
-
-	// Adjust default value if db-dependant specified
-	if (is_array($column_data[1]))
-	{
-		$column_data[1] = (isset($column_data[1][$dbms])) ? $column_data[1][$dbms] : $column_data[1]['default'];
-	}
-
-	$sql = '';
-	$return_array = array();
-
-	switch ($dbms)
-	{
-		case 'firebird':
-			$sql .= " {$column_type} ";
-
-			if (!is_null($column_data[1]))
-			{
-				$sql .= 'DEFAULT ' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ' ';
-			}
-
-			$sql .= 'NOT NULL';
-
-			// This is a UNICODE column and thus should be given it's fair share
-			if (preg_match('/^X?STEXT_UNI|VCHAR_(CI|UNI:?)/', $column_data[0]))
-			{
-				$sql .= ' COLLATE UNICODE';
-			}
-
-		break;
-
-		case 'mssql':
-			$sql .= " {$column_type} ";
-			$sql_default = " {$column_type} ";
-
-			// For adding columns we need the default definition
-			if (!is_null($column_data[1]))
-			{
-				// For hexadecimal values do not use single quotes
-				if (strpos($column_data[1], '0x') === 0)
-				{
-					$sql_default .= 'DEFAULT (' . $column_data[1] . ') ';
-				}
-				else
-				{
-					$sql_default .= 'DEFAULT (' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ') ';
-				}
-			}
-
-			$sql .= 'NOT NULL';
-			$sql_default .= 'NOT NULL';
-
-			$return_array['column_type_sql_default'] = $sql_default;
-		break;
-
-		case 'mysql':
-			$sql .= " {$column_type} ";
-
-			// For hexadecimal values do not use single quotes
-			if (!is_null($column_data[1]) && substr($column_type, -4) !== 'text' && substr($column_type, -4) !== 'blob')
-			{
-				$sql .= (strpos($column_data[1], '0x') === 0) ? "DEFAULT {$column_data[1]} " : "DEFAULT '{$column_data[1]}' ";
-			}
-			$sql .= 'NOT NULL';
-
-			if (isset($column_data[2]))
-			{
-				if ($column_data[2] == 'auto_increment')
-				{
-					$sql .= ' auto_increment';
-				}
-				else if ($column_data[2] == 'true_sort')
-				{
-					$sql .= ' COLLATE utf8_unicode_ci';
-				}
-			}
-
-		break;
-
-		case 'oracle':
-			$sql .= " {$column_type} ";
-			$sql .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}' " : '';
-
-			// In Oracle empty strings ('') are treated as NULL.
-			// Therefore in oracle we allow NULL's for all DEFAULT '' entries
-			// Oracle does not like setting NOT NULL on a column that is already NOT NULL (this happens only on number fields)
-			if (preg_match('/number/i', $column_type))
-			{
-				$sql .= ($column_data[1] === '') ? '' : 'NOT NULL';
-			}
-		break;
-
-		case 'postgres':
-			$return_array['column_type'] = $column_type;
-
-			$sql .= " {$column_type} ";
-
-			if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-			{
-				$default_val = "nextval('{$table_name}_seq')";
-			}
-			else if (!is_null($column_data[1]))
-			{
-				$default_val = "'" . $column_data[1] . "'";
-				$return_array['null'] = 'NOT NULL';
-				$sql .= 'NOT NULL ';
-			}
-
-			$return_array['default'] = $default_val;
-
-			$sql .= "DEFAULT {$default_val}";
-
-			// Unsigned? Then add a CHECK contraint
-			if (in_array($orig_column_type, $unsigned_types))
-			{
-				$return_array['constraint'] = "CHECK ({$column_name} >= 0)";
-				$sql .= " CHECK ({$column_name} >= 0)";
-			}
-		break;
-
-		case 'sqlite':
-			if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-			{
-				$sql .= ' INTEGER PRIMARY KEY';
-			}
-			else
-			{
-				$sql .= ' ' . $column_type;
-			}
-
-			$sql .= ' NOT NULL ';
-			$sql .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}'" : '';
-		break;
-	}
-
-	$return_array['column_type_sql'] = $sql;
-
-	return $return_array;
-}
-
-/**
-* Add new column
-*/
-function sql_column_add($dbms, $table_name, $column_name, $column_data)
-{
-	global $errored, $error_ary;
-
-	$column_data = prepare_column_data($dbms, $column_data, $table_name, $column_name);
-
-	switch ($dbms)
-	{
-		case 'firebird':
-			$sql = 'ALTER TABLE "' . $table_name . '" ADD "' . $column_name . '" ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = 'ALTER TABLE [' . $table_name . '] ADD [' . $column_name . '] ' . $column_data['column_type_sql_default'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'ALTER TABLE `' . $table_name . '` ADD COLUMN `' . $column_name . '` ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'oracle':
-			$sql = 'ALTER TABLE ' . $table_name . ' ADD ' . $column_name . ' ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'postgres':
-			$sql = 'ALTER TABLE ' . $table_name . ' ADD COLUMN "' . $column_name . '" ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'sqlite':
-			if (version_compare(sqlite_libversion(), '3.0') == -1)
-			{
-				global $db;
-				$sql = "SELECT sql
-					FROM sqlite_master
-					WHERE type = 'table'
-						AND name = '{$table_name}'
-					ORDER BY type DESC, name;";
-				$result = $db->sql_query($sql);
-
-				if (!$result)
-				{
-					break;
-				}
-
-				$row = $db->sql_fetchrow($result);
-				$db->sql_freeresult($result);
-
-				$db->sql_transaction('begin');
-
-				// Create a backup table and populate it, destroy the existing one
-				$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));
-				$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);
-				$db->sql_query('DROP TABLE ' . $table_name);
-
-				preg_match('#\((.*)\)#s', $row['sql'], $matches);
-
-				$new_table_cols = trim($matches[1]);
-				$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);
-				$column_list = array();
-
-				foreach ($old_table_cols as $declaration)
-				{
-					$entities = preg_split('#\s+#', trim($declaration));
-					if ($entities[0] == 'PRIMARY')
-					{
-						continue;
-					}
-					$column_list[] = $entities[0];
-				}
-
-				$columns = implode(',', $column_list);
-
-				$new_table_cols = $column_name . ' ' . $column_data['column_type_sql'] . ',' . $new_table_cols;
-
-				// create a new table and fill it up. destroy the temp one
-				$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');');
-				$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');
-				$db->sql_query('DROP TABLE ' . $table_name . '_temp');
-
-				$db->sql_transaction('commit');
-			}
-			else
-			{
-				$sql = 'ALTER TABLE ' . $table_name . ' ADD ' . $column_name . ' [' . $column_data['column_type_sql'] . ']';
-				_sql($sql, $errored, $error_ary);
-			}
-		break;
-	}
-}
-
-/**
-* Drop column
-*/
-function sql_column_remove($dbms, $table_name, $column_name)
-{
-	global $errored, $error_ary;
-
-	switch ($dbms)
-	{
-		case 'firebird':
-			$sql = 'ALTER TABLE "' . $table_name . '" DROP "' . $column_name . '"';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = 'ALTER TABLE [' . $table_name . '] DROP COLUMN [' . $column_name . ']';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'ALTER TABLE `' . $table_name . '` DROP COLUMN `' . $column_name . '`';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'oracle':
-			$sql = 'ALTER TABLE ' . $table_name . ' DROP ' . $column_name;
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'postgres':
-			$sql = 'ALTER TABLE ' . $table_name . ' DROP COLUMN "' . $column_name . '"';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'sqlite':
-			if (version_compare(sqlite_libversion(), '3.0') == -1)
-			{
-				global $db;
-				$sql = "SELECT sql
-					FROM sqlite_master
-					WHERE type = 'table'
-						AND name = '{$table_name}'
-					ORDER BY type DESC, name;";
-				$result = $db->sql_query($sql);
-
-				if (!$result)
-				{
-					break;
-				}
-
-				$row = $db->sql_fetchrow($result);
-				$db->sql_freeresult($result);
-
-				$db->sql_transaction('begin');
-
-				// Create a backup table and populate it, destroy the existing one
-				$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));
-				$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);
-				$db->sql_query('DROP TABLE ' . $table_name);
-
-				preg_match('#\((.*)\)#s', $row['sql'], $matches);
-
-				$new_table_cols = trim($matches[1]);
-				$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);
-				$column_list = array();
-
-				foreach ($old_table_cols as $declaration)
-				{
-					$entities = preg_split('#\s+#', trim($declaration));
-					if ($entities[0] == 'PRIMARY' || $entities[0] === $column_name)
-					{
-						continue;
-					}
-					$column_list[] = $entities[0];
-				}
-
-				$columns = implode(',', $column_list);
-
-				$new_table_cols = $new_table_cols = preg_replace('/' . $column_name . '[^,]+(?:,|$)/m', '', $new_table_cols);
-
-				// create a new table and fill it up. destroy the temp one
-				$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');');
-				$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');
-				$db->sql_query('DROP TABLE ' . $table_name . '_temp');
-
-				$db->sql_transaction('commit');
-			}
-			else
-			{
-				$sql = 'ALTER TABLE ' . $table_name . ' DROP COLUMN ' . $column_name;
-				_sql($sql, $errored, $error_ary);
-			}
-		break;
-	}
-}
-
-function sql_index_drop($dbms, $index_name, $table_name)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	switch ($dbms)
-	{
-		case 'mssql':
-			$sql = 'DROP INDEX ' . $table_name . '.' . $index_name;
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'DROP INDEX ' . $index_name . ' ON ' . $table_name;
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'firebird':
-		case 'oracle':
-		case 'postgres':
-		case 'sqlite':
-			$sql = 'DROP INDEX ' . $table_name . '_' . $index_name;
-			_sql($sql, $errored, $error_ary);
-		break;
-	}
-}
-
-function sql_create_primary_key($dbms, $table_name, $column)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	switch ($dbms)
-	{
-		case 'firebird':
-		case 'postgres':
-			$sql = 'ALTER TABLE ' . $table_name . ' ADD PRIMARY KEY (' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = "ALTER TABLE [{$table_name}] WITH NOCHECK ADD ";
-			$sql .= "CONSTRAINT [PK_{$table_name}] PRIMARY KEY  CLUSTERED (";
-			$sql .= '[' . implode("],\n\t\t[", $column) . ']';
-			$sql .= ') ON [PRIMARY]';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'ALTER TABLE ' . $table_name . ' ADD PRIMARY KEY (' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'oracle':
-			$sql = 'ALTER TABLE ' . $table_name . 'add CONSTRAINT pk_' . $table_name . ' PRIMARY KEY (' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'sqlite':
-			$sql = "SELECT sql
-				FROM sqlite_master
-				WHERE type = 'table'
-					AND name = '{$table_name}'
-				ORDER BY type DESC, name;";
-			$result = _sql($sql, $errored, $error_ary);
-
-			if (!$result)
-			{
-				break;
-			}
-
-			$row = $db->sql_fetchrow($result);
-			$db->sql_freeresult($result);
-
-			$db->sql_transaction('begin');
-
-			// Create a backup table and populate it, destroy the existing one
-			$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));
-			$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);
-			$db->sql_query('DROP TABLE ' . $table_name);
-
-			preg_match('#\((.*)\)#s', $row['sql'], $matches);
-
-			$new_table_cols = trim($matches[1]);
-			$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);
-			$column_list = array();
-
-			foreach ($old_table_cols as $declaration)
-			{
-				$entities = preg_split('#\s+#', trim($declaration));
-				if ($entities[0] == 'PRIMARY')
-				{
-					continue;
-				}
-				$column_list[] = $entities[0];
-			}
-
-			$columns = implode(',', $column_list);
-
-			// create a new table and fill it up. destroy the temp one
-			$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ', PRIMARY KEY (' . implode(', ', $column) . '));');
-			$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');
-			$db->sql_query('DROP TABLE ' . $table_name . '_temp');
-
-			$db->sql_transaction('commit');
-		break;
-	}
-}
-
-function sql_create_unique_index($dbms, $index_name, $table_name, $column)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	switch ($dbms)
-	{
-		case 'firebird':
-		case 'postgres':
-		case 'oracle':
-		case 'sqlite':
-			$sql = 'CREATE UNIQUE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'CREATE UNIQUE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = 'CREATE UNIQUE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ') ON [PRIMARY]';
-			_sql($sql, $errored, $error_ary);
-		break;
-	}
-}
-
-function sql_create_index($dbms, $index_name, $table_name, $column)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	switch ($dbms)
-	{
-		case 'firebird':
-		case 'postgres':
-		case 'oracle':
-		case 'sqlite':
-			$sql = 'CREATE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'CREATE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = 'CREATE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ') ON [PRIMARY]';
-			_sql($sql, $errored, $error_ary);
-		break;
-	}
-}
-
-// List all of the indices that belong to a table,
-// does not count:
-// * UNIQUE indices
-// * PRIMARY keys
-function sql_list_index($dbms, $table_name)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	$index_array = array();
-
-	if ($dbms == 'mssql')
-	{
-		$sql = "EXEC sp_statistics '$table_name'";
-		$result = $db->sql_query($sql);
-		while ($row = $db->sql_fetchrow($result))
-		{
-			if ($row['TYPE'] == 3)
-			{
-				$index_array[] = $row['INDEX_NAME'];
-			}
-		}
-		$db->sql_freeresult($result);
-	}
-	else
-	{
-		switch ($dbms)
-		{
-			case 'firebird':
-				$sql = "SELECT LOWER(RDB\$INDEX_NAME) as index_name
-					FROM RDB\$INDICES
-					WHERE RDB\$RELATION_NAME = " . strtoupper($table_name) . "
-						AND RDB\$UNIQUE_FLAG IS NULL
-						AND RDB\$FOREIGN_KEY IS NULL";
-				$col = 'index_name';
-			break;
-
-			case 'postgres':
-				$sql = "SELECT ic.relname as index_name
-					FROM pg_class bc, pg_class ic, pg_index i
-					WHERE (bc.oid = i.indrelid)
-						AND (ic.oid = i.indexrelid)
-						AND (bc.relname = '" . $table_name . "')
-						AND (i.indisunique != 't')
-						AND (i.indisprimary != 't')";
-				$col = 'index_name';
-			break;
-
-			case 'mysql':
-				$sql = 'SHOW KEYS
-					FROM ' . $table_name;
-				$col = 'Key_name';
-			break;
-
-			case 'oracle':
-				$sql = "SELECT index_name
-					FROM user_indexes
-					WHERE table_name = '" . $table_name . "'
-						AND generated = 'N'";
-			break;
-
-			case 'sqlite':
-				$sql = "PRAGMA index_info('" . $table_name . "');";
-				$col = 'name';
-			break;
-		}
-
-		$result = $db->sql_query($sql);
-		while ($row = $db->sql_fetchrow($result))
-		{
-			if ($dbms == 'mysql' && !$row['Non_unique'])
-			{
-				continue;
-			}
-
-			switch ($dbms)
-			{
-				case 'firebird':
-				case 'oracle':
-				case 'postgres':
-				case 'sqlite':
-					$row[$col] = substr($row[$col], strlen($table_name) + 1);
-				break;
-			}
-
-			$index_array[] = $row[$col];
-		}
-		$db->sql_freeresult($result);
-	}
-
-	return array_map('strtolower', $index_array);
-}
-
-// This is totally fake, never use it
-// it exists only to mend bad update functions introduced
-// * UNIQUE indices
-// * PRIMARY keys
-function sql_list_fake($dbms, $table_name)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	$index_array = array();
-
-	if ($dbms == 'mssql')
-	{
-		$sql = "EXEC sp_statistics '$table_name'";
-		$result = $db->sql_query($sql);
-		while ($row = $db->sql_fetchrow($result))
-		{
-			if ($row['TYPE'] == 3)
-			{
-				$index_array[] = $row['INDEX_NAME'];
-			}
-		}
-		$db->sql_freeresult($result);
-	}
-	else
-	{
-		switch ($dbms)
-		{
-			case 'firebird':
-				$sql = "SELECT LOWER(RDB\$INDEX_NAME) as index_name
-					FROM RDB\$INDICES
-					WHERE RDB\$RELATION_NAME = " . strtoupper($table_name) . "
-						AND RDB\$UNIQUE_FLAG IS NULL
-						AND RDB\$FOREIGN_KEY IS NULL";
-				$col = 'index_name';
-			break;
-
-			case 'postgres':
-				$sql = "SELECT ic.relname as index_name
-					FROM pg_class bc, pg_class ic, pg_index i
-					WHERE (bc.oid = i.indrelid)
-						AND (ic.oid = i.indexrelid)
-						AND (bc.relname = '" . $table_name . "')
-						AND (i.indisunique != 't')
-						AND (i.indisprimary != 't')";
-				$col = 'index_name';
-			break;
-
-			case 'mysql':
-				$sql = 'SHOW KEYS
-					FROM ' . $table_name;
-				$col = 'Key_name';
-			break;
-
-			case 'oracle':
-				$sql = "SELECT index_name
-					FROM user_indexes
-					WHERE table_name = '" . $table_name . "'
-						AND generated = 'N'";
-			break;
-
-			case 'sqlite':
-				$sql = "PRAGMA index_info('" . $table_name . "');";
-				$col = 'name';
-			break;
-		}
-
-		$result = $db->sql_query($sql);
-		while ($row = $db->sql_fetchrow($result))
-		{
-			if ($dbms == 'mysql' && !$row['Non_unique'])
-			{
-				continue;
-			}
-
-			$index_array[] = $row[$col];
-		}
-		$db->sql_freeresult($result);
-	}
-
-	return array_map('strtolower', $index_array);
-}
-
-/**
-* Change column type (not name!)
-*/
-function sql_column_change($dbms, $table_name, $column_name, $column_data)
-{
-	global $dbms_type_map, $db;
-	global $errored, $error_ary;
-
-	$column_data = prepare_column_data($dbms, $column_data, $table_name, $column_name);
-
-	switch ($dbms)
-	{
-		case 'firebird':
-			// Change type...
-			$sql = 'ALTER TABLE "' . $table_name . '" ALTER COLUMN "' . $column_name . '" TYPE ' . ' ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mssql':
-			$sql = 'ALTER TABLE [' . $table_name . '] ALTER COLUMN [' . $column_name . '] ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'mysql':
-			$sql = 'ALTER TABLE `' . $table_name . '` CHANGE `' . $column_name . '` `' . $column_name . '` ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'oracle':
-			$sql = 'ALTER TABLE ' . $table_name . ' MODIFY ' . $column_name . ' ' . $column_data['column_type_sql'];
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'postgres':
-			$sql = 'ALTER TABLE ' . $table_name . ' ';
-
-			$sql_array = array();
-			$sql_array[] = 'ALTER COLUMN ' . $column_name . ' TYPE ' . $column_data['column_type'];
-
-			if (isset($column_data['null']))
-			{
-				if ($column_data['null'] == 'NOT NULL')
-				{
-					$sql_array[] = 'ALTER COLUMN ' . $column_name . ' SET NOT NULL';
-				}
-				else if ($column_data['null'] == 'NULL')
-				{
-					$sql_array[] = 'ALTER COLUMN ' . $column_name . ' DROP NOT NULL';
-				}
-			}
-
-			if (isset($column_data['default']))
-			{
-				$sql_array[] = 'ALTER COLUMN ' . $column_name . ' SET DEFAULT ' . $column_data['default'];
-			}
-
-			// we don't want to double up on constraints if we change different number data types
-			if (isset($column_data['constraint']))
-			{
-				$constraint_sql = "SELECT consrc as constraint_data
-							FROM pg_constraint, pg_class bc
-							WHERE conrelid = bc.oid
-								AND bc.relname = '{$table_name}'
-								AND NOT EXISTS (
-									SELECT *
-										FROM pg_constraint as c, pg_inherits as i
-										WHERE i.inhrelid = pg_constraint.conrelid
-											AND c.conname = pg_constraint.conname
-											AND c.consrc = pg_constraint.consrc
-											AND c.conrelid = i.inhparent
-								)";
-
-				$constraint_exists = false;
-
-				$result = $db->sql_query($constraint_sql);
-				while ($row = $db->sql_fetchrow($result))
-				{
-					if (trim($row['constraint_data']) == trim($column_data['constraint']))
-					{
-						$constraint_exists = true;
-						break;
-					}
-				}
-				$db->sql_freeresult($result);
-
-				if (!$constraint_exists)
-				{
-					$sql_array[] = 'ADD ' . $column_data['constraint'];
-				}
-			}
-
-			$sql .= implode(', ', $sql_array);
-
-			_sql($sql, $errored, $error_ary);
-		break;
-
-		case 'sqlite':
-
-			$sql = "SELECT sql
-				FROM sqlite_master
-				WHERE type = 'table'
-					AND name = '{$table_name}'
-				ORDER BY type DESC, name;";
-			$result = _sql($sql, $errored, $error_ary);
-
-			if (!$result)
-			{
-				break;
-			}
-
-			$row = $db->sql_fetchrow($result);
-			$db->sql_freeresult($result);
-
-			$db->sql_transaction('begin');
-
-			// Create a temp table and populate it, destroy the existing one
-			$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));
-			$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);
-			$db->sql_query('DROP TABLE ' . $table_name);
-
-			preg_match('#\((.*)\)#s', $row['sql'], $matches);
-
-			$new_table_cols = trim($matches[1]);
-			$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);
-			$column_list = array();
-
-			foreach ($old_table_cols as $key => $declaration)
-			{
-				$entities = preg_split('#\s+#', trim($declaration));
-				$column_list[] = $entities[0];
-				if ($entities[0] == $column_name)
-				{
-					$old_table_cols[$key] = $column_name . ' ' . $column_data['column_type_sql'];
-				}
-			}
-
-			$columns = implode(',', $column_list);
-
-			// create a new table and fill it up. destroy the temp one
-			$db->sql_query('CREATE TABLE ' . $table_name . ' (' . implode(',', $old_table_cols) . ');');
-			$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');
-			$db->sql_query('DROP TABLE ' . $table_name . '_temp');
-
-			$db->sql_transaction('commit');
-
-		break;
 	}
 }