Newer
Older
variable_set($menus[$loop]['menu_var'], $menus[$loop]['pid']);
}

Dries Buytaert
committed
variable_del('phptemplate_' .$menus[$loop]['links_var']);
variable_del('phptemplate_'. $menus[$loop]['links_var'] .'_more');
variable_del($menus[$loop]['toggle_var']);
variable_del($menus[$loop]['more_var']);

Dries Buytaert
committed
// If user has old xtemplate links in a string, leave them in the var.
if (isset($ts) && is_array($ts) && is_array($ts[$menus[$loop]['links_var']])) {
variable_del($menus[$loop]['links_var']);
}

Dries Buytaert
committed
if (isset($ts) && is_array($ts)) {
variable_set('theme_settings', $ts);
}
$ret[] = update_sql("UPDATE {system} SET status = 1 WHERE name = 'menu'");
return $ret;
}
function system_update_152() {
$ret = array();
// Postgresql only update
switch ($GLOBALS['db_type']) {
case 'pgsql':
$ret[] = update_sql("ALTER TABLE {forum} DROP shadow");
break;
case 'mysql':
case 'mysqli':
break;
}
return $ret;
}
function system_update_153(){
$ret = array();
switch ($GLOBALS['db_type']) {
case 'pgsql':
$ret[] = update_sql("ALTER TABLE {contact} DROP CONSTRAINT {contact}_pkey");
$ret[] = update_sql("CREATE SEQUENCE {contact}_cid_seq");
db_add_column($ret, 'contact', 'cid', 'int', array('not null' => TRUE, 'default' => "nextval('{contact}_cid_seq')"));
$ret[] = update_sql("ALTER TABLE {contact} ADD PRIMARY KEY (cid)");
$ret[] = update_sql("ALTER TABLE {contact} ADD CONSTRAINT {contact}_category_key UNIQUE (category)");
break;
case 'mysql':
case 'mysqli':
$ret[] = update_sql("ALTER TABLE {contact} DROP PRIMARY KEY");
$ret[] = update_sql("ALTER TABLE {contact} ADD COLUMN cid int(11) NOT NULL PRIMARY KEY auto_increment");
$ret[] = update_sql("ALTER TABLE {contact} ADD UNIQUE KEY category (category)");
break;
}
return $ret;
}
function system_update_154() {
$ret = array();
switch ($GLOBALS['db_type']) {
case 'pgsql':
db_add_column($ret, 'contact', 'weight', 'smallint', array('not null' => TRUE, 'default' => 0));
db_add_column($ret, 'contact', 'selected', 'smallint', array('not null' => TRUE, 'default' => 0));
break;
case 'mysql':
case 'mysqli':
$ret[] = update_sql("ALTER TABLE {contact} ADD COLUMN weight tinyint(3) NOT NULL DEFAULT 0");
$ret[] = update_sql("ALTER TABLE {contact} ADD COLUMN selected tinyint(1) NOT NULL DEFAULT 0");
break;
}
return $ret;
}
function system_update_155() {
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
$ret = array();
// Postgresql only update
switch ($GLOBALS['db_type']) {
case 'pgsql':
$ret[] = update_sql("DROP TABLE {cache}");
$ret[] = update_sql("CREATE TABLE {cache} (
cid varchar(255) NOT NULL default '',
data bytea default '',
expire integer NOT NULL default '0',
created integer NOT NULL default '0',
headers text default '',
PRIMARY KEY (cid)
)");
$ret[] = update_sql("CREATE INDEX {cache}_expire_idx ON {cache}(expire)");
break;
case 'mysql':
case 'mysqli':
break;
}
return $ret;
}
function system_update_156() {
$ret = array();
$ret[] = update_sql("DELETE FROM {cache}");
system_themes();

Dries Buytaert
committed
function system_update_157() {
$ret = array();
$ret[] = update_sql("DELETE FROM {url_alias} WHERE src = 'node/feed' AND dst = 'rss.xml'");
$ret[] = update_sql("INSERT INTO {url_alias} (src, dst) VALUES ('rss.xml', 'node/feed')");

Dries Buytaert
committed
}
function system_update_158() {
$ret = array();
switch ($GLOBALS['db_type']) {
case 'mysqli':
case 'mysql':
$ret[] = update_sql("ALTER TABLE {old_revisions} ADD done tinyint(1) NOT NULL DEFAULT 0");
$ret[] = update_sql("ALTER TABLE {old_revisions} ADD INDEX (done)");
break;
case 'pgsql':

Dries Buytaert
committed
db_add_column($ret, 'old_revisions', 'done', 'smallint', array('not null' => TRUE, 'default' => 0));
$ret[] = update_sql('CREATE INDEX {old_revisions}_done_idx ON {old_revisions}(done)');
break;
}
return $ret;
}
/**
* Retrieve data out of the old_revisions table and put into new revision
* system.
*
* The old_revisions table is not deleted because any data which could not be
* put into the new system is retained.
*/
function system_update_159() {
$ret = array();
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
$result = db_query_range("SELECT * FROM {old_revisions} WHERE done = 0 AND type IN ('page', 'story', 'poll', 'book', 'forum', 'blog') ORDER BY nid DESC", 0, 20);
if (db_num_rows($result)) {
$vid = db_next_id('{node_revisions}_vid');
while ($node = db_fetch_object($result)) {
$revisions = unserialize($node->revisions);
if (isset($revisions) && is_array($revisions) && count($revisions) > 0) {
$revisions_query = array();
$revisions_args = array();
$book_query = array();
$book_args = array();
$forum_query = array();
$forum_args = array();
foreach ($revisions as $version) {
$revision = array();
foreach ($version['node'] as $node_field => $node_value) {
$revision[$node_field] = $node_value;
}
$revision['uid'] = $version['uid'];
$revision['timestamp'] = $version['timestamp'];
$vid++;
$revisions_query[] = "(%d, %d, %d, '%s', '%s', '%s', '%s', %d, %d)";
$revisions_args = array_merge($revisions_args, array($node->nid, $vid, $revision['uid'], $revision['title'], $revision['body'], $revision['teaser'], $revision['log'], $revision['timestamp'], $revision['format']));
switch ($node->type) {
case 'forum':
if ($revision['tid'] > 0) {
$forum_query[] = "(%d, %d, %d)";
$forum_args = array_merge($forum_args, array($vid, $node->nid, $revision['tid']));
}
break;
case 'book':
$book_query[] = "(%d, %d, %d, %d)";
$book_args = array_merge($book_args, array($vid, $node->nid, $revision['parent'], $revision['weight']));
break;
}
if (count($revisions_query)) {
$revision_status = db_query("INSERT INTO {node_revisions} (nid, vid, uid, title, body, teaser, log, timestamp, format) VALUES ". implode(',', $revisions_query), $revisions_args);
}
if (count($forum_query)) {
$forum_status = db_query("INSERT INTO {forum} (vid, nid, tid) VALUES ". implode(',', $forum_query), $forum_args);
}
if (count($book_query)) {
$book_status = db_query("INSERT INTO {book} (vid, nid, parent, weight) VALUES ". implode(',', $book_query), $book_args);
}
$delete = FALSE;
switch ($node->type) {
case 'forum':
if ($forum_status && $revision_status) {
$delete = TRUE;
}
break;
case 'book':
if ($book_status && $revision_status) {
$delete = TRUE;
}
break;
default:
if ($revision_status) {
$delete = TRUE;
}
break;
}
if ($delete) {
db_query('DELETE FROM {old_revisions} WHERE nid = %d', $node->nid);
}
else {
db_query('UPDATE {old_revisions} SET done = 1 WHERE nid = %d', $node->nid);
}
switch ($GLOBALS['db_type']) {
case 'mysqli':
case 'mysql':
$ret[] = update_sql("UPDATE {sequences} SET id = $vid WHERE name = '{node_revisions}_vid'");
break;

Dries Buytaert
committed
case 'pgsql':
$ret[] = update_sql("SELECT setval('{node_revisions}_vid_seq', $vid)");
break;
}
}
else {
db_query('UPDATE {old_revisions} SET done = 1 WHERE nid = %d', $node->nid);
watchdog('php', "Recovering old revisions for node $node->nid failed.", WATCHDOG_WARNING);
}
}
}
if (db_num_rows($result) < 20) {
$ret[] = update_sql('ALTER TABLE {old_revisions} DROP done');
}
else {
$ret['#finished'] = FALSE;
}
return $ret;
}
function system_update_160() {
$types = module_invoke('node', 'get_types');
if (is_array($types)) {
foreach($types as $type) {
if (!is_array(variable_get("node_options_$type", array()))) {
variable_set("node_options_$type", array());
}
}
}
return array();
}
function system_update_161() {
variable_del('forum_icon_path');
return array();
}
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
function system_update_162() {
$ret = array();
// PostgreSQL only update
switch ($GLOBALS['db_type']) {
case 'pgsql':
$ret[] = update_sql('DROP INDEX {book}_parent');
$ret[] = update_sql('CREATE INDEX {book}_parent_idx ON {book}(parent)');
$ret[] = update_sql('DROP INDEX {node_comment_statistics}_timestamp_idx');
$ret[] = update_sql('CREATE INDEX {node_comment_statistics}_last_comment_timestamp_idx ON {node_comment_statistics}(last_comment_timestamp)');
$ret[] = update_sql('ALTER TABLE {filters} ALTER delta SET DEFAULT 0');
$ret[] = update_sql('DROP INDEX {filters}_module_idx');
$ret[] = update_sql('DROP INDEX {locales_target}_lid_idx');
$ret[] = update_sql('DROP INDEX {locales_target}_lang_idx');
$ret[] = update_sql('CREATE INDEX {locales_target}_locale_idx ON {locales_target}(locale)');
$ret[] = update_sql('DROP INDEX {node}_created');
$ret[] = update_sql('CREATE INDEX {node}_created_idx ON {node}(created)');
$ret[] = update_sql('DROP INDEX {node}_changed');
$ret[] = update_sql('CREATE INDEX {node}_changed_idx ON {node}(changed)');
$ret[] = update_sql('DROP INDEX {profile_fields}_category');
$ret[] = update_sql('CREATE INDEX {profile_fields}_category_idx ON {profile_fields}(category)');
$ret[] = update_sql('DROP INDEX {url_alias}_dst_idx');
$ret[] = update_sql('CREATE UNIQUE INDEX {url_alias}_dst_idx ON {url_alias}(dst)');
$ret[] = update_sql('CREATE INDEX {sessions}_uid_idx ON {sessions}(uid)');
$ret[] = update_sql('CREATE INDEX {sessions}_timestamp_idx ON {sessions}(timestamp)');
$ret[] = update_sql('ALTER TABLE {accesslog} DROP mask');
db_change_column($ret, 'accesslog', 'path', 'path', 'text');
db_change_column($ret, 'accesslog', 'url', 'url', 'text');
db_change_column($ret, 'watchdog', 'link', 'link', 'text', array('not null' => TRUE, 'default' => "''"));
db_change_column($ret, 'watchdog', 'location', 'location', 'text', array('not null' => TRUE, 'default' => "''"));
db_change_column($ret, 'watchdog', 'referer', 'referer', 'text', array('not null' => TRUE, 'default' => "''"));
break;
}
return $ret;
}

Dries Buytaert
committed
function system_update_163() {
$ret = array();
if ($GLOBALS['db_type'] == 'mysql' || $GLOBALS['db_type'] == 'mysqli') {

Dries Buytaert
committed
$ret[] = update_sql('ALTER TABLE {cache} CHANGE data data LONGBLOB');
}
return $ret;
}
function system_update_164() {
$ret = array();
switch ($GLOBALS['db_type']) {
case 'mysql':
case 'mysqli':
$ret[] = update_sql("CREATE TABLE {poll_votes} (
nid int(10) unsigned NOT NULL,
uid int(10) unsigned NOT NULL default 0,
hostname varchar(128) NOT NULL default '',
INDEX (nid),
INDEX (uid),
INDEX (hostname)
break;
case 'pgsql':
$ret[] = update_sql("CREATE TABLE {poll_votes} (
nid int NOT NULL,
uid int NOT NULL default 0,
hostname varchar(128) NOT NULL default ''
)");
$ret[] = update_sql('CREATE INDEX {poll_votes}_nid_idx ON {poll_votes} (nid)');
$ret[] = update_sql('CREATE INDEX {poll_votes}_uid_idx ON {poll_votes} (uid)');
$ret[] = update_sql('CREATE INDEX {poll_votes}_hostname_idx ON {poll_votes} (hostname)');
break;
}
$result = db_query('SELECT nid, polled FROM {poll}');
while ($poll = db_fetch_object($result)) {
foreach (explode(' ', $poll->polled) as $polled) {
if ($polled[0] == '_') {
// $polled is a user id
db_query('INSERT INTO {poll_votes} (nid, uid) VALUES (%d, %d)', $poll->nid, substr($polled, 1, -1));
}
else {
// $polled is a host
db_query("INSERT INTO {poll_votes} (nid, hostname) VALUES (%d, '%s')", $poll->nid, $polled);
}
}
}
$ret[] = update_sql('ALTER TABLE {poll} DROP polled');
return $ret;
}

Dries Buytaert
committed
function system_update_165() {
$cron_last = max(variable_get('drupal_cron_last', 0), variable_get('ping_cron_last', 0));

Dries Buytaert
committed
variable_set('cron_last', $cron_last);
variable_del('drupal_cron_last');
variable_del('ping_cron_last');
return array();
}

Dries Buytaert
committed
function system_update_166() {
$ret = array();
$ret[] = update_sql("DROP TABLE {directory}");
switch ($GLOBALS['db_type']) {
case 'mysqli':
case 'mysql':

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {client} (

Dries Buytaert
committed
cid int(10) unsigned NOT NULL auto_increment,
link varchar(255) NOT NULL default '',
name varchar(128) NOT NULL default '',
mail varchar(128) NOT NULL default '',
slogan longtext NOT NULL,
mission longtext NOT NULL,
users int(10) NOT NULL default '0',
nodes int(10) NOT NULL default '0',
version varchar(35) NOT NULL default'',
created int(11) NOT NULL default '0',
changed int(11) NOT NULL default '0',
PRIMARY KEY (cid)
)");

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {client_system} (

Dries Buytaert
committed
cid int(10) NOT NULL default '0',
name varchar(255) NOT NULL default '',
type varchar(255) NOT NULL default '',
PRIMARY KEY (cid,name)
)");

Dries Buytaert
committed
break;
case 'pgsql':

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {client} (

Dries Buytaert
committed
cid SERIAL,
link varchar(255) NOT NULL default '',
name varchar(128) NOT NULL default '',
mail varchar(128) NOT NULL default '',
slogan text NOT NULL default '',
mission text NOT NULL default '',
users integer NOT NULL default '0',
nodes integer NOT NULL default '0',
version varchar(35) NOT NULL default'',
created integer NOT NULL default '0',
changed integer NOT NULL default '0',
PRIMARY KEY (cid)
)");

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {client_system} (

Dries Buytaert
committed
cid integer NOT NULL,
name varchar(255) NOT NULL default '',
type varchar(255) NOT NULL default '',
PRIMARY KEY (cid,name)
)");
break;
}
return $ret;
}
function system_update_167() {
$ret = array();
switch ($GLOBALS['db_type']) {
case 'mysqli':
case 'mysql':
$ret[] = update_sql("ALTER TABLE {vocabulary_node_types} CHANGE type type varchar(32) NOT NULL default ''");
break;
case 'pgsql':
db_change_column($ret, 'vocabulary_node_types', 'type', 'type', 'varchar(32)', array('not null' => TRUE, 'default' => "''"));

Dries Buytaert
committed
$ret[] = update_sql("ALTER TABLE {vocabulary_node_types} ADD PRIMARY KEY (vid, type)");
break;
}
return $ret;
}
function system_update_168() {
$ret = array();
$ret[] = update_sql("ALTER TABLE {term_hierarchy} ADD PRIMARY KEY (tid, parent)");
return $ret;
}

Steven Wittens
committed
function system_update_169() {
// Warn PGSQL admins if their database is set up incorrectly
if ($GLOBALS['db_type'] == 'pgsql') {
$encoding = db_result(db_query('SHOW server_encoding'));
if (!in_array(strtolower($encoding), array('unicode', 'utf8'))) {
$msg = 'Your PostgreSQL database is set up with the wrong character encoding ('. $encoding .'). It is possible it will not work as expected. It is advised to recreate it with UTF-8/Unicode encoding. More information can be found in the <a href="http://www.postgresql.org/docs/7.4/interactive/multibyte.html">PostgreSQL documentation</a>.';
watchdog('php', $msg, WATCHDOG_WARNING);
drupal_set_message($msg, 'status');
}
}
// Note: 'access' table manually updated in update.php

Steven Wittens
committed
return _system_update_utf8(array(
'accesslog', 'aggregator_category',

Steven Wittens
committed
'aggregator_category_feed', 'aggregator_category_item',
'aggregator_feed', 'aggregator_item', 'authmap', 'blocks',
'book', 'boxes', 'cache', 'comments', 'contact',
'node_comment_statistics', 'client', 'client_system', 'files',
'filter_formats', 'filters', 'flood', 'forum', 'history',
'locales_meta', 'locales_source', 'locales_target', 'menu',
'node', 'node_access', 'node_revisions', 'profile_fields',
'profile_values', 'url_alias', 'permission', 'poll', 'poll_votes',
'poll_choices', 'role', 'search_dataset', 'search_index',
'search_total', 'sessions', 'sequences', 'node_counter',
'system', 'term_data', 'term_hierarchy', 'term_node',
'term_relation', 'term_synonym', 'users', 'users_roles', 'variable',
'vocabulary', 'vocabulary_node_types', 'watchdog'
));
}
/**
* Converts a set of tables to UTF-8 encoding.

Dries Buytaert
committed
*

Steven Wittens
committed
* This update is designed to be re-usable by contrib modules and is
* used by system_update_169().
*/
function _system_update_utf8($tables) {
// Are we starting this update for the first time?
if (!isset($_SESSION['update_utf8'])) {
switch ($GLOBALS['db_type']) {
// Only for MySQL 4.1+
case 'mysqli':
break;
case 'mysql':
if (version_compare(mysql_get_server_info($GLOBALS['active_db']), '4.1.0', '<')) {
return array();
}
break;
case 'pgsql':
return array();
}
// See if database uses UTF-8 already
global $db_url;
$url = parse_url(is_array($db_url) ? $db_url['default'] : $db_url);

Steven Wittens
committed
$db_name = substr($url['path'], 1);
$result = db_fetch_array(db_query('SHOW CREATE DATABASE `%s`', $db_name));
if (preg_match('/utf8/i', array_pop($result))) {

Steven Wittens
committed
return array();
}
// Make list of tables to convert
$_SESSION['update_utf8'] = $tables;
// Keep track of total for progress bar
$_SESSION['update_utf8_total'] = count($tables);
}
// Fetch remaining tables list and convert next table

Steven Wittens
committed
$list = &$_SESSION['update_utf8'];
$ret = update_convert_table_utf8(array_shift($list));

Steven Wittens
committed
// Are we done?
if (count($list) == 0) {
unset($_SESSION['update_utf8']);
unset($_SESSION['update_utf8_total']);
return $ret;
}
// Progress percentage
$ret['#finished'] = 1 - (count($list) / $_SESSION['update_utf8_total']);
return $ret;
}
function system_update_170() {
if (!variable_get('update_170_done', FALSE)) {

Steven Wittens
committed
switch ($GLOBALS['db_type']) {
case 'pgsql':
$ret = array();
db_change_column($ret, 'system', 'schema_version', 'schema_version', 'smallint', array('not null' => TRUE, 'default' => -1));
break;
case 'mysql':
case 'mysqli':
db_query('ALTER TABLE {system} CHANGE schema_version schema_version smallint(3) not null default -1');
break;
}
// Set schema version -1 (uninstalled) for disabled modules (only affects contrib).
db_query('UPDATE {system} SET schema_version = -1 WHERE status = 0 AND schema_version = 0');
}
return array();
}

Dries Buytaert
committed
function system_update_171() {
$ret = array();
$ret[] = update_sql('DELETE FROM {users_roles} WHERE rid IN ('. DRUPAL_ANONYMOUS_RID. ', '. DRUPAL_AUTHENTICATED_RID. ')');
return $ret;
}
function system_update_172() {
// Multi-part update
if (!isset($_SESSION['system_update_172'])) {
$_SESSION['system_update_172'] = 0;
$_SESSION['system_update_172_max'] = db_result(db_query('SELECT MAX(cid) FROM {comments}'));
}
include_once './modules/comment.module';
$limit = 20;
$result = db_query_range("SELECT cid, thread FROM {comments} WHERE cid > %d ORDER BY cid ASC", $_SESSION['system_update_172'], 0, $limit);
while ($comment = db_fetch_object($result)) {
$_SESSION['system_update_172'] = $comment->cid;
$thread = explode('.', rtrim($comment->thread, '/'));
foreach ($thread as $i => $offset) {
// Decode old-style comment codes: 1,2,...,9,90,91,92,...,99,990,991,...
$thread[$i] = int2vancode((strlen($offset) - 1) * 10 + substr($offset, -1, 1));
}
$thread = implode('.', $thread) .'/';
db_query("UPDATE {comments} SET thread = '%s' WHERE cid = %d", $thread, $comment->cid);
}
if ($_SESSION['system_update_172'] == $_SESSION['system_update_172_max']) {
unset($_SESSION['system_update_172']);
unset($_SESSION['system_update_172_max']);
return array();
}
return array('#finished' => $_SESSION['system_update_172'] / $_SESSION['system_update_172_max']);
}

Dries Buytaert
committed
function system_update_173() {
$ret = array();

Gerhard Killesreiter
committed
// State tracker to determine whether we keep a backup of the files table or not.
$safe = TRUE;
// PostgreSQL needs CREATE TABLE foobar _AS_ SELECT ...
$AS = ($GLOBALS['db_type'] == 'pgsql') ? 'AS' : '';

Gerhard Killesreiter
committed
// Backup the files table.
$ret[] = update_sql("CREATE TABLE {files_backup} $AS SELECT * FROM {files}");
// Do some files table sanity checking and cleanup.
$ret[] = update_sql('DELETE FROM {files} WHERE fid = 0');
$ret[] = update_sql('UPDATE {files} SET vid = nid WHERE vid = 0');
// Create a temporary table to build the new file_revisions and files tables from.
$ret[] = update_sql("CREATE TABLE {files_tmp} $AS SELECT * FROM {files}");
$ret[] = update_sql('DROP TABLE {files}');

Dries Buytaert
committed
switch ($GLOBALS['db_type']) {
case 'pgsql':
// create file_revisions table
$ret[] = update_sql("CREATE TABLE {file_revisions} (
fid integer NOT NULL default 0,
vid integer NOT NULL default 0,
description varchar(255) NOT NULL default '',
list smallint NOT NULL default 0,
PRIMARY KEY (fid, vid))");

Gerhard Killesreiter
committed
$result = update_sql("INSERT INTO {file_revisions} SELECT DISTINCT ON (fid,vid) fid, vid, description, list FROM {files_tmp}");
$ret[] = $result;
if ($result['success'] === FALSE) {
$safe = FALSE;
}

Dries Buytaert
committed

Gerhard Killesreiter
committed
// Create normalized files table

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {files} (
fid SERIAL,
nid integer NOT NULL default 0,
filename varchar(255) NOT NULL default '',
filepath varchar(255) NOT NULL default '',
filemime varchar(255) NOT NULL default '',
filesize integer NOT NULL default 0,
PRIMARY KEY (fid))");

Gerhard Killesreiter
committed
$result = update_sql("INSERT INTO {files} SELECT DISTINCT ON (fid) fid, nid, filename, filepath, filemime, filesize FROM {files_tmp}");
$ret[] = $result;
if ($result['success'] === FALSE) {
$safe = FALSE;
}

Dries Buytaert
committed
$ret[] = update_sql("SELECT setval('{files}_fid_seq', max(fid)) FROM {files}");

Gerhard Killesreiter
committed

Dries Buytaert
committed
break;

Gerhard Killesreiter
committed

Dries Buytaert
committed
case 'mysqli':
case 'mysql':
// create file_revisions table
$ret[] = update_sql("CREATE TABLE {file_revisions} (
fid int(10) unsigned NOT NULL default 0,
vid int(10) unsigned NOT NULL default 0,
description varchar(255) NOT NULL default '',
list tinyint(1) unsigned NOT NULL default 0,
PRIMARY KEY (fid, vid)
) /*!40100 DEFAULT CHARACTER SET utf8 */");

Dries Buytaert
committed

Gerhard Killesreiter
committed
// Try as you might mysql only does distinct row if you are selecting more than 1 column.
$result = update_sql('INSERT INTO {file_revisions} SELECT DISTINCT fid , vid, description, list FROM {files_tmp}');
$ret[] = $result;
if ($result['success'] === FALSE) {
$safe = FALSE;
}

Dries Buytaert
committed
$ret[] = update_sql("CREATE TABLE {files} (
fid int(10) unsigned NOT NULL default 0,
nid int(10) unsigned NOT NULL default 0,
filename varchar(255) NOT NULL default '',
filepath varchar(255) NOT NULL default '',
filemime varchar(255) NOT NULL default '',
filesize int(10) unsigned NOT NULL default 0,
PRIMARY KEY (fid)
) /*!40100 DEFAULT CHARACTER SET utf8 */");

Gerhard Killesreiter
committed
$result = update_sql("INSERT INTO {files} SELECT DISTINCT fid, nid, filename, filepath, filemime, filesize FROM {files_tmp}");
$ret[] = $result;
if ($result['success'] === FALSE) {
$safe = FALSE;
}

Dries Buytaert
committed
break;
}

Gerhard Killesreiter
committed
$ret[] = update_sql("DROP TABLE {files_tmp}");
// Remove original files table if all went well. Otherwise preserve it and notify user.
if ($safe) {
$ret[] = update_sql("DROP TABLE {files_backup}");
}
else {
drupal_set_message('Normalizing files table failed. A backup of the original table called {files_backup} remains in your database.');

Gerhard Killesreiter
committed
}

Dries Buytaert
committed
return $ret;
}
function system_update_174() {
// This update (update comments system variables on upgrade) has been removed.
return array();
}

Dries Buytaert
committed
function system_update_175() {
$result = db_query('SELECT * FROM {url_alias}');
while ($path = db_fetch_object($result)) {
$path->src = urldecode($path->src);
$path->dst = urldecode($path->dst);
db_query("UPDATE {url_alias} SET dst = '%s', src = '%s' WHERE pid = %d", $path->dst, $path->src, $path->pid);
}
return array();

Dries Buytaert
committed
}
function system_update_176() {
$ret = array();
$ret[] = update_sql('ALTER TABLE {filter_formats} ADD UNIQUE (name)');
return $ret;
}
function system_update_177() {
$ret = array();
$message_ids = array(
'welcome_subject' => 'Welcome subject',
'welcome_body' => 'Welcome body text',
'approval_subject' => 'Approval subject',
'approval_body' => 'Approval body text',
'pass_subject' => 'Password reset subject',
'pass_body' => 'Password reset body text',
foreach ($message_ids as $message_id => $message_text) {
if ($admin_setting = variable_get('user_mail_'. $message_id, FALSE)) {
// Insert newlines and escape for display as HTML
$admin_setting = nl2br(check_plain($message_text ."\n\n". $admin_setting));
watchdog('legacy', $admin_setting);

Gerhard Killesreiter
committed
$last = db_fetch_object(db_query('SELECT max(wid) AS wid FROM {watchdog}'));
// Deleting is required, because _user_mail_text() checks for the existance of the variable.
variable_del('user_mail_'. $message_id);
$ret[] = array(
'query' => strtr('The mail template %message_id has been reset to the default. The old template <a href="%url">has been saved</a>.', array('%message_id' => 'user_mail_'. $message_id, '%url' => url('admin/logs/event/'. $last->wid))),
'success' => TRUE
);
}
}
return $ret;
}
function _update_178_url_fix($text) {
// Key is the attribute to replace.
$urlpatterns['href'] = "/<a[^>]+href=\"([^\"]+)/i";
$urlpatterns['src'] = "/<img[^>]+src=\"([^\"]+)/i";
foreach ($urlpatterns as $type => $pattern) {
if (preg_match_all($pattern, $text, $matches)) {
foreach ($matches[1] as $url) {
if ($url != '' && !strstr($url, 'mailto:') && !strstr($url, '://') && !strstr($url, '../') && !strstr($url, './') && $url[0] != '/' && $url[0] != '#') {
$text = preg_replace('|'. $type .'\s*=\s*"'. preg_quote($url) .'\s*"|', $type. '="'.base_path(). $url .'"', $text);
}
}
}
}
return $text != $old ? $text : FALSE;

Steven Wittens
committed
function _update_178_url_formats() {
$formats = array();
// Any format with the HTML filter in it
$result = db_query("SELECT format FROM {filters} WHERE module = 'filter' AND delta = 0");
while ($format = db_fetch_object($result)) {
$formats[$format->format] = TRUE;

Steven Wittens
committed
}
// Any format with only the linebreak filter in it
$result = db_query("SELECT format FROM {filters} WHERE module = 'filter' AND delta = 2");
while ($format = db_fetch_object($result)) {
if (db_result(db_query('SELECT COUNT(*) FROM {filters} WHERE format = %d', $format->format)) == 1) {
$formats[$format->format] = TRUE;

Steven Wittens
committed
}
}
// Any format with 'HTML' in its name
$result = db_query("SELECT format FROM {filter_formats} WHERE name LIKE '%HTML%'");
while ($format = db_fetch_object($result)) {
$formats[$format->format] = TRUE;

Steven Wittens
committed
}
return $formats;
}
/**
* Update base paths for relative URLs in node and comment content.
*/
function system_update_178() {
if (variable_get('clean_url', 0) == 1) {
// Multi-part update
if (!isset($_SESSION['system_update_178_comment'])) {
// Check which formats need to be converted

Steven Wittens
committed
$formats = _update_178_url_formats();
if (count($formats) == 0) {
return array();
}
// Build format query string
$_SESSION['formats'] = array_keys($formats);
$_SESSION['format_string'] = '('. substr(str_repeat('%d, ', count($formats)), 0, -2) .')';
// Begin update
$_SESSION['system_update_178_comment'] = 0;
$_SESSION['system_update_178_node'] = 0;
$_SESSION['system_update_178_comment_max'] = db_result(db_query('SELECT MAX(cid) FROM {comments} WHERE format IN '. $_SESSION['format_string'], $_SESSION['formats']));
$_SESSION['system_update_178_node_max'] = db_result(db_query('SELECT MAX(vid) FROM {node_revisions} WHERE format IN '. $_SESSION['format_string'], $_SESSION['formats']));
}
$limit = 20;
// Comments
if ($_SESSION['system_update_178_comment'] != $_SESSION['system_update_178_comment_max']) {
$args = array_merge(array($_SESSION['system_update_178_comment']), $_SESSION['formats']);
$result = db_query_range("SELECT cid, comment FROM {comments} WHERE cid > %d AND format IN ". $_SESSION['format_string'] .' ORDER BY cid ASC', $args, 0, $limit);
while ($comment = db_fetch_object($result)) {
$_SESSION['system_update_178_comment'] = $comment->cid;
$comment->comment = _update_178_url_fix($comment->comment);
if ($comment->comment !== FALSE) {
db_query("UPDATE {comments} SET comment = '%s' WHERE cid = %d", $comment->comment, $comment->cid);
}
}
// Node revisions
$args = array_merge(array($_SESSION['system_update_178_node']), $_SESSION['formats']);
$result = db_query_range("SELECT vid, teaser, body FROM {node_revisions} WHERE vid > %d AND format IN ". $_SESSION['format_string'] .' ORDER BY vid ASC', $args, 0, $limit);
while ($node = db_fetch_object($result)) {
$_SESSION['system_update_178_node'] = $node->vid;
$set = array();
$args = array();
$node->teaser = _update_178_url_fix($node->teaser);
if ($node->teaser !== FALSE) {
$set[] = "teaser = '%s'";
$args[] = $node->teaser;
}
$node->body = _update_178_url_fix($node->body);
if ($node->body !== FALSE) {
$set[] = "body = '%s'";
$args[] = $node->body;
}
if (count($set)) {
$args[] = $node->vid;
db_query('UPDATE {node_revisions} SET '. implode(', ', $set) .' WHERE vid = %d', $args);
}
}
if ($_SESSION['system_update_178_comment'] == $_SESSION['system_update_178_comment_max'] &&
$_SESSION['system_update_178_node'] == $_SESSION['system_update_178_node_max']) {
unset($_SESSION['system_update_178_comment']);
unset($_SESSION['system_update_178_comment_max']);
unset($_SESSION['system_update_178_node']);
unset($_SESSION['system_update_178_node_max']);
return array();
}
else {
// Report percentage finished
return array('#finished' =>
($_SESSION['system_update_178_comment'] + $_SESSION['system_update_178_node']) /
($_SESSION['system_update_178_comment_max'] + $_SESSION['system_update_178_node_max'])
);
}
}
return array();
}

Steven Wittens
committed
1872
1873
1874
1875
1876
1877
1878
1879
1880
1881
1882
1883
1884
1885
1886
1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
1897
1898
1899
1900
1901
1902
1903
1904
1905
1906
1907
1908
1909
1910
1911
1912
1913
1914
1915
1916
1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
1930
1931
1932
1933
1934
1935
1936
1937
1938
1939
1940
1941
1942
1943
/**
* Update base paths for relative URLs in custom blocks, profiles and various variables.
*/
function system_update_179() {
if (variable_get('clean_url', 0) == 1) {
// Multi-part update
if (!isset($_SESSION['system_update_179_uid'])) {
// Check which formats need to be converted
$formats = _update_178_url_formats();
if (count($formats) == 0) {
return array();
}
// Custom Blocks (too small for multipart)
$format_string = '('. substr(str_repeat('%d, ', count($formats)), 0, -2) .')';
$result = db_query("SELECT bid, body FROM {boxes} WHERE format IN ". $format_string, array_keys($formats));
while ($block = db_fetch_object($result)) {
$block->body = _update_178_url_fix($block->body);
if ($block->body !== FALSE) {
db_query("UPDATE {boxes} SET body = '%s' WHERE bid = %d", $block->body, $block->bid);
}
}
// Variables (too small for multipart)
$vars = array('site_mission', 'site_footer', 'user_registration_help');
foreach (node_get_types() as $type => $name) {
$vars[] = $type .'_help';
}
foreach ($vars as $var) {
$value = variable_get($var, NULL);
if (!is_null($value)) {
$value = _update_178_url_fix($value);
if ($value !== FALSE) {
variable_set($var, $value);
}
}
}
// See if profiles need to be updated: is the default format HTML?
if (!isset($formats[variable_get('filter_default_format', 1)])) {
return array();
}
$result = db_query("SELECT fid FROM {profile_fields} WHERE type = 'textarea'");
$fields = array();
while ($field = db_fetch_object($result)) {
$fields[] = $field->fid;
}
if (count($fields) == 0) {
return array();
}
// Begin multi-part update for profiles
$_SESSION['system_update_179_fields'] = $fields;
$_SESSION['system_update_179_field_string'] = '('. substr(str_repeat('%d, ', count($fields)), 0, -2) .')';
$_SESSION['system_update_179_uid'] = 0;
$_SESSION['system_update_179_fid'] = 0;
$_SESSION['system_update_179_max'] = db_result(db_query('SELECT MAX(uid) FROM {profile_values} WHERE fid IN '. $_SESSION['system_update_179_field_string'], $_SESSION['system_update_179_fields']));
}
// Fetch next 20 profile values to convert
$limit = 20;
$args = array_merge(array($_SESSION['system_update_179_uid'], $_SESSION['system_update_179_fid'], $_SESSION['system_update_179_uid']), $_SESSION['system_update_179_fields']);
$result = db_query_range("SELECT fid, uid, value FROM {profile_values} WHERE ((uid = %d AND fid > %d) OR uid > %d) AND fid IN ". $_SESSION['system_update_179_field_string'] .' ORDER BY uid ASC, fid ASC', $args, 0, $limit);
while ($field = db_fetch_object($result)) {
$_SESSION['system_update_179_uid'] = $field->uid;
$_SESSION['system_update_179_fid'] = $field->fid;
$field->value = _update_178_url_fix($field->value);
if ($field->value !== FALSE) {
db_query("UPDATE {profile_values} SET value = '%s' WHERE uid = %d AND fid = %d", $field->value, $field->uid, $field->fid);
}

Steven Wittens
committed
}
// Done?
if (db_num_rows($result) == 0) {
unset($_SESSION['system_update_179_uid']);
unset($_SESSION['system_update_179_fid']);
unset($_SESSION['system_update_179_max']);
return array();
}
else {
// Report percentage finished
// (Note: make sure we complete all fields for the last user by not reporting 100% too early)
return array('#finished' => $_SESSION['system_update_179_uid'] / ($_SESSION['system_update_179_max'] + 1));
}
}
return array();
}
function system_update_180() {
$ret = array();

Dries Buytaert
committed
switch ($GLOBALS['db_type']) {
case 'mysql':
case 'mysqli':
$ret[] = update_sql("ALTER TABLE {node} DROP PRIMARY KEY");
$ret[] = update_sql("ALTER TABLE {node} ADD PRIMARY KEY (nid, vid)");
$ret[] = update_sql("ALTER TABLE {node} DROP INDEX vid");
$ret[] = update_sql("ALTER TABLE {node} ADD UNIQUE (vid)");
$ret[] = update_sql("ALTER TABLE {node} ADD INDEX (nid)");

Dries Buytaert
committed
$ret[] = update_sql("ALTER TABLE {node_counter} CHANGE nid nid INT(10) NOT NULL DEFAULT '0'");
break;
case 'pgsql':
$ret[] = update_sql("ALTER TABLE {node} DROP CONSTRAINT {node}_pkey"); // Change PK
$ret[] = update_sql("ALTER TABLE {node} ADD PRIMARY KEY (nid, vid)");
$ret[] = update_sql('DROP INDEX {node}_vid_idx'); // Change normal index to UNIQUE index
$ret[] = update_sql('CREATE UNIQUE INDEX {node}_vid_idx ON {node}(vid)');
$ret[] = update_sql('CREATE INDEX {node}_nid_idx ON {node}(nid)'); // Add index on nid
break;
}
return $ret;
}

Dries Buytaert
committed
function system_update_181() {
$ret = array();
switch ($GLOBALS['db_type']) {
case 'mysql':
case 'mysqli':
$ret[] = update_sql("ALTER TABLE {profile_fields} ADD autocomplete TINYINT(1) NOT NULL AFTER visibility ;");
break;
case 'pgsql':

Dries Buytaert
committed
db_add_column($ret, 'profile_fields', 'autocomplete', 'smallint', array('not null' => TRUE, 'default' => 0));