~azzar1/unity/add-show-desktop-key

'CHANGE_CLEAN_NAMES' => 'The method used to make sure a username is not used by multiple users has been changed. There are some users which have the same name when compared with the new method. You have to delete or rename these users to make sure that each name is only used by one user before you can proceed.',

593

'USER_ACTIVE' => 'Active user',

594

'USER_INACTIVE' => 'Inactive user',

595

'BOT' => 'Spider/Robot',

596

'UPDATE_REQUIRES_FILE' => 'The updater requires that the following file is present: %s',

597

598

'DELETE_USER_REMOVE' => 'Delete user and remove posts',

599

'DELETE_USER_RETAIN' => 'Delete user but keep posts',

600

'EDIT_USERNAME' => 'Edit username',

601

'KEEP_OLD_NAME' => 'Keep username',

602

'NEW_USERNAME' => 'New username',

603

));

604

}

605

606

607

608

609

610

<br />

611

612

<?php

613

flush();

614

615

$submit = (isset($_POST['resolve_conflicts'])) ? true : false;

616

$modify_users = request_var('modify_users', array(0 => ''));

617

$new_usernames = request_var('new_usernames', array(0 => ''), true);

618

619

if (!class_exists('utf_new_normalizer'))

620

{

621

if (!file_exists($phpbb_root_path . 'install/data/new_normalizer.' . $phpEx))

622

{

623

global $lang;

624

trigger_error(sprintf($lang['UPDATE_REQUIRES_FILE'], $phpbb_root_path . 'install/data/new_normalizer.' . $phpEx), E_USER_ERROR);

625

}

626

include($phpbb_root_path . 'install/data/new_normalizer.' . $phpEx);

627

}

628

629

// the admin decided to change some usernames

630

if (sizeof($modify_users) && $submit)

631

{

632

$sql = 'SELECT user_id, username, user_type

633

FROM ' . USERS_TABLE . '

634

WHERE ' . $db->sql_in_set('user_id', array_keys($modify_users));

635

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

636

637

$users = 0;

638

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

639

{

640

$users++;

641

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

642

643

if (isset($modify_users[$user_id]))

644

{

645

$row['action'] = $modify_users[$user_id];

646

$modify_users[$user_id] = $row;

647

}

648

}

649

$db->sql_freeresult($result);

650

651

// only if all ids really existed

652

if (sizeof($modify_users) == $users)

653

{

654

$user->data['user_id'] = ANONYMOUS;

655

include($phpbb_root_path . 'includes/functions_user.' . $phpEx);

656

foreach ($modify_users as $user_id => $row)

657

{

658

switch ($row['action'])

659

{

660

case 'edit':

661

if (isset($new_usernames[$user_id]))

662

{

663

$data = array('username' => utf8_new_normalize_nfc($new_usernames[$user_id]));

664

// Need to update config, forum, topic, posting, messages, etc.

665

if ($data['username'] != $row['username'])

666

{

667

$check_ary = array('username' => array(

668

array('string', false, $config['min_name_chars'], $config['max_name_chars']),

669

array('username'),

670

));

671

// need a little trick for this to work properly

672

$user->data['username_clean'] = utf8_clean_string($data['username']) . 'a';

673

$errors = validate_data($data, $check_ary);

674

675

if ($errors)

676

{

677

include($phpbb_root_path . 'language/' . $language . '/ucp.' . $phpEx);

678

echo '<div class="errorbox">';

679

foreach ($errors as $error)

680

{

681

echo '<p>' . $lang[$error] . '</p>';

682

}

683

echo '</div>';

684

}

685

686

if (!$errors)

687

{

688

$sql = 'UPDATE ' . USERS_TABLE . '

689

SET ' . $db->sql_build_array('UPDATE', array(

690

'username' => $data['username'],

691

'username_clean' => utf8_clean_string($data['username'])

692

)) . '

693

WHERE user_id = ' . $user_id;

694

$db->sql_query($sql);

695

696

add_log('user', $user_id, 'LOG_USER_UPDATE_NAME', $row['username'], $data['username']);

697

user_update_name($row['username'], $data['username']);

698

}

699

}

700

}

701

break;

702

703

case 'delete_retain':

704

case 'delete_remove':

705

if ($user_id != ANONYMOUS && $row['user_type'] != USER_FOUNDER)

706

{

707

user_delete(substr($row['action'], 7), $user_id, $row['username']);

708

add_log('admin', 'LOG_USER_DELETED', $row['username']);

709

}

710

break;

711

}

712

}

713

}

714

}

715

716

717

718

719

720

<?php

721

flush();

722

723

// after RC3 a different utf8_clean_string function is used, this requires that

724

// the unique column username_clean is recalculated, during this recalculation

725

// duplicates might be created. Since the column has to be unique such usernames

726

// must not exist. We need identify them and let the admin decide what to do

727

// about them.

728

// After RC8 this was changed again, but this time only usernames containing spaces

729

// are affected.

730

$sql_where = (version_compare($current_version, '3.0.RC4', '<=')) ? '' : "WHERE username_clean LIKE '% %'";

731

$sql = 'SELECT user_id, username, username_clean

732

FROM ' . USERS_TABLE . "

733

$sql_where

734

ORDER BY user_id ASC";

735

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

736

737

$colliding_users = $found_names = array();

738

$echos = 0;

739

740

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

741

{

742

// Calculate the new clean name. If it differs from the old one we need

743

// to make sure there is no collision

744

$clean_name = utf8_new_clean_string($row['username']);

745

746

if ($clean_name != $row['username_clean'])

747

{

748

// Check if there would be a collission, if not put it up for changing

749

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

750

751

// If this clean name was not the result of another user already ...

752

if (!isset($found_names[$clean_name]))

753

{

754

// then we need to figure out whether there are any other users

755

// who already had this clean name with the old version

756

$sql = 'SELECT user_id, username

757

FROM ' . USERS_TABLE . '

758

WHERE username_clean = \'' . $db->sql_escape($clean_name) . '\'';

759

$result2 = $db->sql_query($sql);

760

761

$user_ids = array($user_id);

762

while ($row = $db->sql_fetchrow($result2))

763

{

764

// For not trimmed entries this could happen, yes. ;)

765

if ($row['user_id'] == $user_id)

766

{

767

continue;

768

}

769

770

// Make sure this clean name will still be the same with the

771

// new function. If it is, then we have to add it to the list

772

// of user ids for this clean name

773

if (utf8_new_clean_string($row['username']) == $clean_name)

774

{

775

$user_ids[] = (int) $row['user_id'];

776

}

777

}

778

$db->sql_freeresult($result2);

779

780

// if we already found a collision save it

781

if (sizeof($user_ids) > 1)

782

{

783

$colliding_users[$clean_name] = $user_ids;

784

$found_names[$clean_name] = true;

785

}

786

else

787

{

788

// otherwise just mark this name as found

789

$found_names[$clean_name] = $user_id;

790

}

791

}

792

// Else, if we already found the username

793

else

794

{

795

// If the value in the found_names lookup table is only true ...

796

if ($found_names[$clean_name] === true)

797

{

798

// then the actual data was already added to $colliding_users

799

// and we only need to append the user_id

800

$colliding_users[$clean_name][] = $user_id;

801

}

802

else

803

{

804

// otherwise it still keeps the first user_id for this name

805

// and we need to move the data to $colliding_users, and set

806

// the value in the found_names lookup table to true, so

807

// following users will directly be appended to $colliding_users

808

$colliding_users[$clean_name] = array($found_names[$clean_name], $user_id);

809

$found_names[$clean_name] = true;

810

}

811

}

812

}

813

814

if (($echos % 1000) == 0)

815

{

816

echo '.';

817

flush();

818

}

819

$echos++;

820

}

821

$db->sql_freeresult($result);

822

823

_write_result(false, $errored, $error_ary);

824

825

// now retrieve all information about the users and let the admin decide what to do

826

if (sizeof($colliding_users))

827

{

828

$exit = true;

829

include($phpbb_root_path . 'includes/functions_display.' . $phpEx);

830

include($phpbb_root_path . 'language/' . $language . '/memberlist.' . $phpEx);

831

include($phpbb_root_path . 'language/' . $language . '/acp/users.' . $phpEx);

832

833

// link a few things to the correct place so we don't get any problems

834

$user->lang = &$lang;

835

$user->data['user_id'] = ANONYMOUS;

836

$user->date_format = $config['default_dateformat'];

837

838

// a little trick to get all user_ids

839

$user_ids = call_user_func_array('array_merge', array_values($colliding_users));

840

841

$sql = 'SELECT session_user_id, MAX(session_time) AS session_time

842

FROM ' . SESSIONS_TABLE . '

843

WHERE session_time >= ' . (time() - $config['session_length']) . '

844

AND ' . $db->sql_in_set('session_user_id', $user_ids) . '

845

GROUP BY session_user_id';

846

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

847

848

$session_times = array();

849

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

850

{

851

$session_times[$row['session_user_id']] = $row['session_time'];

852

}

853

$db->sql_freeresult($result);

854

855

$sql = 'SELECT *

856

FROM ' . USERS_TABLE . '

857

WHERE ' . $db->sql_in_set('user_id', $user_ids);

858

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

859

860

$users = array();

861

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

862

{

863

if (isset($session_times[$row['user_id']]))

864

{

865

$row['session_time'] = $session_times[$row['user_id']];

866

}

867

else

868

{

869

$row['session_time'] = 0;

870

}

871

$users[(int) $row['user_id']] = $row;

872

}

873

$db->sql_freeresult($result);

874

unset($session_times);

875

876

// now display a table with all users, some information about them and options

877

// for the admin: keep name, change name (with text input) or delete user

878

$u_action = "database_update.$phpEx?language=$language&type=$inline_update";

879

880

881

882

883

884

885

886

<?php

887

foreach ($colliding_users as $clean_name => $user_ids)

888

{

889

890

891

<table>

892

893

<thead>

894

<tr>

895

896

897

898

899

900

901

902

</tr>

903

</thead>

904

<tbody>

905

<?php

906

foreach ($user_ids as $i => $user_id)

907

{

908

$row = $users[$user_id];

909

910

$rank_title = $rank_img = '';

911

get_user_rank($row['user_rank'], $row['user_posts'], $rank_title, $rank_img, $rank_img_src);

912

913

$last_visit = (!empty($row['session_time'])) ? $row['session_time'] : $row['user_lastvisit'];

914

915

$info = '';

916

switch ($row['user_type'])

917

{

918

case USER_INACTIVE:

919

$info .= $lang['USER_INACTIVE'];

920

break;

921

922

case USER_IGNORE:

923

$info .= $lang['BOT'];

924

break;

925

926

case USER_FOUNDER:

927

$info .= $lang['FOUNDER'];

928

break;

929

930

default:

931

$info .= $lang['USER_ACTIVE'];

932

}

933

934

if ($user_id == ANONYMOUS)

935

{

936

$info = $lang['GUEST'];

937

}

938

939

940

<td>

941

942

<?php echo get_username_string('full', $row['user_id'], $row['username'], $row['user_colour']); ?>

943

</td>

944

945

946

<td><?php echo $user->format_date($row['user_regdate']) ?></td>

947

<td><?php echo (empty($last_visit)) ? ' - ' : $user->format_date($last_visit); ?> </td>

948

<td>

949

<label><input type="radio" class="radio" id="keep_user_<?php echo $user_id; ?>" name="modify_users[<?php echo $user_id; ?>]" value="keep" checked="checked" /> <?php echo $lang['KEEP_OLD_NAME']; ?></label><br />

950

<label><input type="radio" class="radio" id="edit_user_<?php echo $user_id; ?>" name="modify_users[<?php echo $user_id; ?>]" value="edit" /> <?php echo $lang['EDIT_USERNAME']; ?></label><br />

951

<?php

952

// some users must not be deleted

953

if ($user_id != ANONYMOUS && $row['user_type'] != USER_FOUNDER)

954

{

955

956

<label><input type="radio" class="radio" id="delete_user_retain_<?php echo $user_id; ?>" name="modify_users[<?php echo $user_id; ?>]" value="delete_retain" /> <?php echo $lang['DELETE_USER_RETAIN']; ?></label><br />

957

<label><input type="radio" class="radio" id="delete_user_remove_<?php echo $user_id; ?>" name="modify_users[<?php echo $user_id; ?>]" value="delete_remove" /> <?php echo $lang['DELETE_USER_REMOVE']; ?></label>

958

<?php

959

}

960

961

</td>

962

<td>

963

<input id="new_username_<?php echo $user_id; ?>" type="text" name="new_usernames[<?php echo $user_id; ?>]" value="<?php echo $row['username']; ?>" />

964

</td>

965

</tr>

966

<?php

967

}

968

969

</tbody>

970

</table>

971

</fieldset>

972

<?php

973

}

974

975

976

977

</p>

978

</form>

979

<?php

980

}

981

else if (sizeof($found_names))

982

{

983

$sql = 'SELECT user_id, username, username_clean

984

FROM ' . USERS_TABLE . '

985

WHERE ' . $db->sql_in_set('user_id', array_values($found_names));

986

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

987

988

$found_names = array();

989

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

990

{

991

$clean_name = utf8_new_clean_string($row['username']);

992

993

if ($clean_name != $row['username_clean'])

994

{

995

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

996

$found_names[$user_id] = $clean_name;

997

998

// impossible unique clean name

999

$sql = 'UPDATE ' . USERS_TABLE . "

1000

SET username_clean = ' {$user_id}'

1001

WHERE user_id = {$user_id}";

1002

$db->sql_query($sql);

1003

}

1004

}

1005

$db->sql_freeresult($result);

1006

1007

foreach ($found_names as $user_id => $clean_name)

1008

{

1009

$sql = 'UPDATE ' . USERS_TABLE . '

1010

SET username_clean = \'' . $db->sql_escape($clean_name) . '\'

1011

WHERE user_id = ' . $user_id;

1012

$db->sql_query($sql);

1013

}

1014

}

1015

unset($found_names);

1016

unset($colliding_users);

1017

}

1018

1019

if ($exit)

1020

{

1021

1022

1023

</div>

1024

</div>

1025

1026

</div>

1027

</div>

1028

</div>

1029

1030

1031

1032

</div>

1033

</div>

1034

1035

</body>

1036

</html>

1037

1038

<?php

1039

if (function_exists('exit_handler'))

1040

{

1041

exit_handler();

1042

}

1043

}

1044

1045

// Schema updates

1046

1047

1048

1049

1050

1051

<br />

1052

1053

1054

<?php

1055

1056

flush();

1057

1058

// We go through the schema changes from the lowest to the highest version

1059

// We skip those versions older than the current version

1060

$no_updates = true;

1061

foreach ($database_update_info as $version => $schema_changes)

1062

{

1063

if (version_compare($version, $current_version, '<'))

1064

{

1065

continue;

1066

}

1067

1068

if (!sizeof($schema_changes))

1069

{

1070

continue;

1071

}

1072

1073

$no_updates = false;

1074

1075

// Change columns?

1076

if (!empty($schema_changes['change_columns']))

1077

{

1078

foreach ($schema_changes['change_columns'] as $table => $columns)

1079

{

1080

foreach ($columns as $column_name => $column_data)

1081

{

1082

sql_column_change($map_dbms, $table, $column_name, $column_data);

1083

}

1084

}

1085

}

1086

1087

// Add columns?

1088

if (!empty($schema_changes['add_columns']))

1089

{

1090

foreach ($schema_changes['add_columns'] as $table => $columns)

1091

{

1092

foreach ($columns as $column_name => $column_data)

1093

{

1094

// Only add the column if it does not exist yet

1095

if (!column_exists($map_dbms, $table, $column_name))

1096

{

1097

sql_column_add($map_dbms, $table, $column_name, $column_data);

1098

}

1099

}

1100

}

1101

}

1102

1103

// Remove keys?

1104

if (!empty($schema_changes['drop_keys']))

1105

{

1106

foreach ($schema_changes['drop_keys'] as $table => $indexes)

1107

{

1108

foreach ($indexes as $index_name)

1109

{

1110

sql_index_drop($map_dbms, $index_name, $table);

1111

}

1112

}

1113

}

1114

1115

// Drop columns?

1116

if (!empty($schema_changes['drop_columns']))

1117

{

1118

foreach ($schema_changes['drop_columns'] as $table => $columns)

1119

{

1120

foreach ($columns as $column)

1121

{

1122

sql_column_remove($map_dbms, $table, $column);

1123

}

1124

}

1125

}

1126

1127

// Add primary keys?

1128

if (!empty($schema_changes['add_primary_keys']))

1129

{

1130

foreach ($schema_changes['add_primary_keys'] as $table => $columns)

1131

{

1132

sql_create_primary_key($map_dbms, $table, $columns);

1133

}

1134

}

1135

1136

// Add unqiue indexes?

1137

if (!empty($schema_changes['add_unique_index']))

1138

{

1139

foreach ($schema_changes['add_unique_index'] as $table => $index_array)

1140

{

1141

foreach ($index_array as $index_name => $column)

1142

{

1143

sql_create_unique_index($map_dbms, $index_name, $table, $column);

1144

}

1145

}

1146

}

1147

1148

// Add indexes?

1149

if (!empty($schema_changes['add_index']))

1150

{

1151

foreach ($schema_changes['add_index'] as $table => $index_array)

1152

{

1153

foreach ($index_array as $index_name => $column)

1154

{

1155

sql_create_index($map_dbms, $index_name, $table, $column);

1156

}

1157

}

1158

}

1159

}

1160

1161

_write_result($no_updates, $errored, $error_ary);

1162

1163

// Data updates

1164

$error_ary = array();

1165

$errored = $no_updates = false;

1166

1167

1168

1169

1170

1171

<br />

1172

1173

1174

<?php

1175

1176

flush();

1177

1178

$no_updates = true;

1179

1180

// some code magic

1181

if (version_compare($current_version, '3.0.RC2', '<='))

1182

{

1183

$smileys = array();

1184

$sql = 'SELECT smiley_id, code

1185

FROM ' . SMILIES_TABLE;

1186

1187

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

1188

1189

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

1190

{

1191

$smileys[$row['smiley_id']] = $row['code'];

1192

}

1193

$db->sql_freeresult($result);

1194

1195

foreach ($smileys as $id => $code)

1196

{

1197

// 2.0 only entitized lt and gt; We need to do something about double quotes.

1198

if (strchr($code, '"') === false)

1199

{

1200

continue;

1201

}

1202

1203

$new_code = str_replace('&', '&', $code);

1204

$new_code = str_replace('<', '<', $new_code);

1205

$new_code = str_replace('>', '>', $new_code);

1206

$new_code = utf8_htmlspecialchars($new_code);

1207

1208

$sql = 'UPDATE ' . SMILIES_TABLE . '

1209

SET code = \'' . $db->sql_escape($new_code) . '\'

1210

WHERE smiley_id = ' . (int) $id;

1211

$db->sql_query($sql);

1212

}

1213

1214

$index_list = sql_list_index($map_dbms, ACL_ROLES_DATA_TABLE);

1215

1216

if (in_array('ath_opt_id', $index_list))

1217

{

1218

sql_index_drop($map_dbms, 'ath_opt_id', ACL_ROLES_DATA_TABLE);

1219

sql_create_index($map_dbms, 'ath_op_id', ACL_ROLES_DATA_TABLE, array('auth_option_id'));

1220

}

1221

1222

$no_updates = false;

1223

}

1224

1225

if (version_compare($current_version, '3.0.RC3', '<='))

1226

{

1227

if ($map_dbms === 'postgres')

1228

{

1229

$sql = "SELECT SETVAL('" . FORUMS_TABLE . "_seq',(select case when max(forum_id)>0 then max(forum_id)+1 else 1 end from " . FORUMS_TABLE . '));';

1230

_sql($sql, $errored, $error_ary);

1231

}

1232

1233

// we check for:

1234

// ath_opt_id

1235

// ath_op_id

1236

// ACL_ROLES_DATA_TABLE_ath_opt_id

1237

// we want ACL_ROLES_DATA_TABLE_ath_op_id

1238

1239

$table_index_fix = array(

1240

ACL_ROLES_DATA_TABLE => array(

1241

'ath_opt_id' => 'ath_op_id',

1242

'ath_op_id' => 'ath_op_id',

1243

ACL_ROLES_DATA_TABLE . '_ath_opt_id' => 'ath_op_id'

1244

1245

STYLES_IMAGESET_DATA_TABLE => array(

1246

'i_id' => 'i_d',

1247

'i_d' => 'i_d',

1248

STYLES_IMAGESET_DATA_TABLE . '_i_id' => 'i_d'

1249

)

1250

);

1251

1252

// we need to create some indicies...

1253

$needed_creation = array();

1254

1255

foreach ($table_index_fix as $table_name => $index_info)

1256

{

1257

$index_list = sql_list_fake($map_dbms, $table_name);

1258

foreach ($index_info as $bad_index => $good_index)

1259

{

1260

if (in_array($bad_index, $index_list))

1261

{

1262

// mysql is actually OK, it won't get a hand in this crud

1263

switch ($map_dbms)

1264

{

1265

// last version, mssql had issues with index removal

1266

case 'mssql':

1267

$sql = 'DROP INDEX ' . $table_name . '.' . $bad_index;

1268

_sql($sql, $errored, $error_ary);

1269

break;

1270

1271

// last version, firebird, oracle, postgresql and sqlite all got bad index names

1272

// we got kinda lucky, tho: they all support the same syntax

1273

case 'firebird':

1274

case 'oracle':

1275

case 'postgres':

1276

case 'sqlite':

1277

$sql = 'DROP INDEX ' . $bad_index;

1278

_sql($sql, $errored, $error_ary);

1279

break;

1280

}

1281

1282

// If the good index already exist we do not need to create it again...

1283

if (($map_dbms == 'mysql_40' || $map_dbms == 'mysql_41') && $bad_index == $good_index)

1284

{

1285

}

1286

else

1287

{

1288

$needed_creation[$table_name][$good_index] = 1;

1289

}

1290

}

1291

}

1292

}

1293

1294

$new_index_defs = array('ath_op_id' => array('auth_option_id'), 'i_d' => array('imageset_id'));

1295

1296

foreach ($needed_creation as $bad_table => $index_repair_list)

1297

{

1298

foreach ($index_repair_list as $new_index => $garbage)

1299

{

1300

sql_create_index($map_dbms, $new_index, $bad_table, $new_index_defs[$new_index]);

1301

$no_updates = false;

1302

}

1303

}

1304

1305

// Make sure empty smiley codes do not exist

1306

$sql = 'DELETE FROM ' . SMILIES_TABLE . "

1307

WHERE code = ''";

1308

_sql($sql, $errored, $error_ary);

1309

1310

set_config('allow_birthdays', '1');

1311

set_config('cron_lock', '0', true);

1312

1313

$no_updates = false;

1314

}

1315

1316

if (version_compare($current_version, '3.0.RC4', '<='))

1317

{

1318

$update_auto_increment = array(

1319

STYLES_TABLE => 'style_id',

1320

STYLES_TEMPLATE_TABLE => 'template_id',

1321

STYLES_THEME_TABLE => 'theme_id',

1322

STYLES_IMAGESET_TABLE => 'imageset_id'

1323

);

1324

1325

$sql = 'SELECT *

1326

FROM ' . STYLES_TABLE . '

1327

WHERE style_id = 0';

1328

$result = _sql($sql, $errored, $error_ary);

1329

$bad_style_row = $db->sql_fetchrow($result);

1330

$db->sql_freeresult($result);

1331

1332

if ($bad_style_row)

1333

{

1334

$sql = 'SELECT MAX(style_id) as max_id

1335

FROM ' . STYLES_TABLE;

1336

$result = _sql($sql, $errored, $error_ary);

1337

$row = $db->sql_fetchrow($result);

1338

$db->sql_freeresult($result);

1339

1340

$proper_id = $row['max_id'] + 1;

1341

1342

_sql('UPDATE ' . STYLES_TABLE . " SET style_id = $proper_id WHERE style_id = 0", $errored, $error_ary);

1343

_sql('UPDATE ' . FORUMS_TABLE . " SET forum_style = $proper_id WHERE forum_style = 0", $errored, $error_ary);

1344

_sql('UPDATE ' . USERS_TABLE . " SET user_style = $proper_id WHERE user_style = 0", $errored, $error_ary);

1345

1346

$sql = 'SELECT config_value

1347

FROM ' . CONFIG_TABLE . "

1348

WHERE config_name = 'default_style'";

1349

$result = _sql($sql, $errored, $error_ary);

1350

$style_config = $db->sql_fetchrow($result);

1351

$db->sql_freeresult($result);

1352

1353

if ($style_config['config_value'] === '0')

1354

{

1355

set_config('default_style', (string) $proper_id);

1356

}

1357

}

1358

1359

$sql = 'SELECT *

1360

FROM ' . STYLES_TEMPLATE_TABLE . '

1361

WHERE template_id = 0';

1362

$result = _sql($sql, $errored, $error_ary);

1363

$bad_style_row = $db->sql_fetchrow($result);

1364

$db->sql_freeresult($result);

1365

1366

if ($bad_style_row)

1367

{

1368

$sql = 'SELECT MAX(template_id) as max_id

1369

FROM ' . STYLES_TEMPLATE_TABLE;

1370

$result = _sql($sql, $errored, $error_ary);

1371

$row = $db->sql_fetchrow($result);

1372

$db->sql_freeresult($result);

1373

1374

$proper_id = $row['max_id'] + 1;

1375

1376

_sql('UPDATE ' . STYLES_TABLE . " SET template_id = $proper_id WHERE template_id = 0", $errored, $error_ary);

1377

}

1378

1379

$sql = 'SELECT *

1380

FROM ' . STYLES_THEME_TABLE . '

1381

WHERE theme_id = 0';

1382

$result = _sql($sql, $errored, $error_ary);

1383

$bad_style_row = $db->sql_fetchrow($result);

1384

$db->sql_freeresult($result);

1385

1386

if ($bad_style_row)

1387

{

1388

$sql = 'SELECT MAX(theme_id) as max_id

1389

FROM ' . STYLES_THEME_TABLE;

1390

$result = _sql($sql, $errored, $error_ary);

1391

$row = $db->sql_fetchrow($result);

1392

$db->sql_freeresult($result);

1393

1394

$proper_id = $row['max_id'] + 1;

1395

1396

_sql('UPDATE ' . STYLES_TABLE . " SET theme_id = $proper_id WHERE theme_id = 0", $errored, $error_ary);

1397

}

1398

1399

$sql = 'SELECT *

1400

FROM ' . STYLES_IMAGESET_TABLE . '

1401

WHERE imageset_id = 0';

1402

$result = _sql($sql, $errored, $error_ary);

1403

$bad_style_row = $db->sql_fetchrow($result);

1404

$db->sql_freeresult($result);

1405

1406

if ($bad_style_row)

1407

{

1408

$sql = 'SELECT MAX(imageset_id) as max_id

1409

FROM ' . STYLES_IMAGESET_TABLE;

1410

$result = _sql($sql, $errored, $error_ary);

1411

$row = $db->sql_fetchrow($result);

1412

$db->sql_freeresult($result);

1413

1414

$proper_id = $row['max_id'] + 1;

1415

1416

_sql('UPDATE ' . STYLES_TABLE . " SET imageset_id = $proper_id WHERE imageset_id = 0", $errored, $error_ary);

1417

_sql('UPDATE ' . STYLES_IMAGESET_DATA_TABLE . " SET imageset_id = $proper_id WHERE imageset_id = 0", $errored, $error_ary);

1418

}

1419

1420

if ($map_dbms == 'mysql_40' || $map_dbms == 'mysql_41')

1421

{

1422

foreach ($update_auto_increment as $auto_table_name => $auto_column_name)

1423

{

1424

$sql = "SELECT MAX({$auto_column_name}) as max_id

1425

FROM {$auto_table_name}";

1426

$result = _sql($sql, $errored, $error_ary);

1427

$row = $db->sql_fetchrow($result);

1428

$db->sql_freeresult($result);

1429

1430

$max_id = ((int) $row['max_id']) + 1;

1431

_sql("ALTER TABLE {$auto_table_name} AUTO_INCREMENT = {$max_id}", $errored, $error_ary);

1432

}

1433

1434

$no_updates = false;

1435

}

1436

else if ($map_dbms == 'postgres')

1437

{

1438

foreach ($update_auto_increment as $auto_table_name => $auto_column_name)

1439

{

1440

$sql = "SELECT SETVAL('" . $auto_table_name . "_seq',(select case when max({$auto_column_name})>0 then max({$auto_column_name})+1 else 1 end from " . $auto_table_name . '));';

1441

_sql($sql, $errored, $error_ary);

1442

}

1443

1444

$sql = 'DROP SEQUENCE ' . STYLES_TEMPLATE_DATA_TABLE . '_seq';

1445

_sql($sql, $errored, $error_ary);

1446

}

1447

else if ($map_dbms == 'firebird')

1448

{

1449

$sql = 'DROP TRIGGER t_' . STYLES_TEMPLATE_DATA_TABLE;

1450

_sql($sql, $errored, $error_ary);

1451

1452

$sql = 'DROP GENERATOR ' . STYLES_TEMPLATE_DATA_TABLE . '_gen';

1453

_sql($sql, $errored, $error_ary);

1454

}

1455

else if ($map_dbms == 'oracle')

1456

{

1457

$sql = 'DROP TRIGGER t_' . STYLES_TEMPLATE_DATA_TABLE;

1458

_sql($sql, $errored, $error_ary);

1459

1460

$sql = 'DROP SEQUENCE ' . STYLES_TEMPLATE_DATA_TABLE . '_seq';

1461

_sql($sql, $errored, $error_ary);

1462

}

1463

else if ($map_dbms == 'mssql')

1464

{

1465

// we use transactions because we need to have a working DB at the end of all of this

1466

$db->sql_transaction('begin');

1467

1468

$sql = 'SELECT *

1469

FROM ' . STYLES_TEMPLATE_DATA_TABLE;

1470

$result = _sql($sql, $errored, $error_ary);

1471

$old_style_rows = array();

1472

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

1473

{

1474

$old_style_rows[] = $row;

1475

}

1476

$db->sql_freeresult($result);

1477

1478

// death to the table, it is evil!

1479

$sql = 'DROP TABLE ' . STYLES_TEMPLATE_DATA_TABLE;

1480

_sql($sql, $errored, $error_ary);

1481

1482

// the table of awesomeness, praise be to it (or something)

1483

$sql = 'CREATE TABLE [' . STYLES_TEMPLATE_DATA_TABLE . "] (

1484

[template_id] [int] DEFAULT (0) NOT NULL ,

1485

[template_filename] [varchar] (100) DEFAULT ('') NOT NULL ,

1486

[template_included] [varchar] (8000) DEFAULT ('') NOT NULL ,

1487

[template_mtime] [int] DEFAULT (0) NOT NULL ,

1488

[template_data] [text] DEFAULT ('') NOT NULL

1489

) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY]";

1490

_sql($sql, $errored, $error_ary);

1491

1492

// index? index

1493

$sql = 'CREATE INDEX [tid] ON [' . STYLES_TEMPLATE_DATA_TABLE . ']([template_id]) ON [PRIMARY]';

1494

_sql($sql, $errored, $error_ary);

1495

1496

// yet another index

1497

$sql = 'CREATE INDEX [tfn] ON [' . STYLES_TEMPLATE_DATA_TABLE . ']([template_filename]) ON [PRIMARY]';

1498

_sql($sql, $errored, $error_ary);

1499

1500

foreach ($old_style_rows as $return_row)

1501

{

1502

_sql('INSERT INTO ' . STYLES_TEMPLATE_DATA_TABLE . ' ' . $db->sql_build_array('INSERT', $return_row), $errored, $error_ary);

1503

}

1504

1505

$db->sql_transaction('commit');

1506

}

1507

1508

// Setting this here again because new installations may not have it...

1509

set_config('cron_lock', '0', true);

1510

set_config('ldap_port', '');

1511

set_config('ldap_user_filter', '');

1512

1513

$no_updates = false;

1514

}

1515

1516

if (version_compare($current_version, '3.0.RC5', '<='))

1517

{

1518

// In case the user is having the bot mediapartner google "as is", adjust it.

1519

$sql = 'UPDATE ' . BOTS_TABLE . "

1520

SET bot_agent = '" . $db->sql_escape('Mediapartners-Google') . "'

1521

WHERE bot_agent = '" . $db->sql_escape('Mediapartners-Google/') . "'";

1522

_sql($sql, $errored, $error_ary);

1523

1524

set_config('form_token_lifetime', '7200');

1525

set_config('form_token_mintime', '0');

1526

set_config('min_time_reg', '5');

1527

set_config('min_time_terms', '2');

1528

set_config('form_token_sid_guests', '1');

1529

1530

$db->sql_transaction('begin');

1531

1532

$sql = 'SELECT forum_id, forum_password

1533

FROM ' . FORUMS_TABLE;

1534

$result = _sql($sql, $errored, $error_ary);

1535

1536

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

1537

{

1538

if (!empty($row['forum_password']))

1539

{

1540

_sql('UPDATE ' . FORUMS_TABLE . " SET forum_password = '" . md5($row['forum_password']) . "' WHERE forum_id = {$row['forum_id']}", $errored, $error_ary);

1541

}

1542

}

1543

$db->sql_freeresult($result);

1544

1545

$db->sql_transaction('commit');

1546

1547

$no_updates = false;

1548

}

1549

1550

_write_result($no_updates, $errored, $error_ary);

1551

1552

$error_ary = array();

1553

$errored = $no_updates = false;

1554

1555

1556

1557

1558

1559

<br />

1560

1561

1562

<?php

1563

1564

flush();

1565

1566

// update the version

1567

$sql = "UPDATE " . CONFIG_TABLE . "

1568

SET config_value = '$updates_to_version'

1569

WHERE config_name = 'version'";

1570

_sql($sql, $errored, $error_ary);

1571

1572

// Reset permissions

1573

$sql = 'UPDATE ' . USERS_TABLE . "

1574

SET user_permissions = ''";

1575

_sql($sql, $errored, $error_ary);

1576

1577

/* Optimize/vacuum analyze the tables where appropriate

1578

// this should be done for each version in future along with

1579

// the version number update

1580

switch ($db->sql_layer)

1581

{

1582

case 'mysql':

1583

case 'mysqli':

1584

case 'mysql4':

1585

$sql = 'OPTIMIZE TABLE ' . $table_prefix . 'auth_access, ' . $table_prefix . 'banlist, ' . $table_prefix . 'categories, ' . $table_prefix . 'config, ' . $table_prefix . 'disallow, ' . $table_prefix . 'forum_prune, ' . $table_prefix . 'forums, ' . $table_prefix . 'groups, ' . $table_prefix . 'posts, ' . $table_prefix . 'posts_text, ' . $table_prefix . 'privmsgs, ' . $table_prefix . 'privmsgs_text, ' . $table_prefix . 'ranks, ' . $table_prefix . 'search_results, ' . $table_prefix . 'search_wordlist, ' . $table_prefix . 'search_wordmatch, ' . $table_prefix . 'sessions_keys' . $table_prefix . 'smilies, ' . $table_prefix . 'themes, ' . $table_prefix . 'themes_name, ' . $table_prefix . 'topics, ' . $table_prefix . 'topics_watch, ' . $table_prefix . 'user_group, ' . $table_prefix . 'users, ' . $table_prefix . 'vote_desc, ' . $table_prefix . 'vote_results, ' . $table_prefix . 'vote_voters, ' . $table_prefix . 'words';

1586

_sql($sql, $errored, $error_ary);

1587

break;

1588

1589

case 'postgresql':

1590

_sql("VACUUM ANALYZE", $errored, $error_ary);

1591

break;

1592

}

1593

1594

1595

_write_result($no_updates, $errored, $error_ary);

1596

1597

1598

1599

<br />

1600

1601

1602

<br />

1603

1604

<?php

1605

1606

if (!$inline_update)

1607

{

1608

1609

1610

1611

1612

1613

1614

<?php

1615

}

1616

else

1617

{

1618

1619

1620

1621

1622

<p><a href="<?php echo append_sid("{$phpbb_root_path}install/index.{$phpEx}", "mode=update&sub=file_check&lang=$language"); ?>" class="button1"><?php echo (isset($lang['CONTINUE_UPDATE_NOW'])) ? $lang['CONTINUE_UPDATE_NOW'] : 'Continue the update process now'; ?></a></p>

1623

1624

<?php

1625

}

1626

1627

// Add database update to log

1628

add_log('admin', 'LOG_UPDATE_DATABASE', $orig_version, $updates_to_version);

1629

1630

// Now we purge the session table as well as all cache files

1631

$cache->purge();

1632

1633

1634

1635

</div>

1636

</div>

1637

1638

</div>

1639

</div>

1640

</div>

1641

1642

1643

1644

</div>

1645

</div>

1646

1647

</body>

1648

</html>

1649

1650

<?php

1651

1652

garbage_collection();

1653

1654

if (function_exists('exit_handler'))

1655

{

1656

exit_handler();

1657

}

1658

1659

1660

/**

1661

* Function for triggering an sql statement

1662

1663

function _sql($sql, &$errored, &$error_ary, $echo_dot = true)

1664

{

1665

global $db;

1666

1667

if (defined('DEBUG_EXTRA'))

1668

{

1669

echo "<br />\n{$sql}\n<br />";

1670

}

1671

1672

$db->sql_return_on_error(true);

1673

1674

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

1675

if ($db->sql_error_triggered)

1676

{

1677

$errored = true;

1678

$error_ary['sql'][] = $db->sql_error_sql;

1679

$error_ary['error_code'][] = $db->_sql_error();

1680

}

1681

1682

$db->sql_return_on_error(false);

1683

1684

if ($echo_dot)

1685

{

1686

echo ". \n";

1687

flush();

1688

}

1689

1690

return $result;

1691

}

1692

1693

function _write_result($no_updates, $errored, $error_ary)

1694

{

1695

global $lang;

1696

1697

if ($no_updates)

1698

{

1699

echo ' ' . $lang['NO_UPDATES_REQUIRED'] . '</strong></p>';

1700

}

1701

else

1702

{

1703

echo ' <span class="success">' . $lang['DONE'] . '</span></strong><br />' . $lang['RESULT'] . ' :: ';

1704

1705

if ($errored)

1706

{

1707

echo ' <strong>' . $lang['SOME_QUERIES_FAILED'] . '</strong> <ul>';

1708

1709

for ($i = 0; $i < sizeof($error_ary['sql']); $i++)

1710

{

1711

echo '<li>' . $lang['ERROR'] . ' :: <strong>' . htmlspecialchars($error_ary['error_code'][$i]['message']) . '</strong><br />';

1712

echo $lang['SQL'] . ' :: <strong>' . htmlspecialchars($error_ary['sql'][$i]) . '</strong><br /><br /></li>';

1713

}

1714

1715

echo '</ul> <br /><br />' . $lang['SQL_FAILURE_EXPLAIN'] . '</p>';

1716

}

1717

else

1718

{

1719

echo '<strong>' . $lang['NO_ERRORS'] . '</strong></p>';

1720

}

1721

}

1722

}

1723

1724

/**

1725

* Check if a specified column exist

1726

1727

function column_exists($dbms, $table, $column_name)

1728

{

1729

global $db;

1730

1731

switch ($dbms)

1732

{

1733

case 'mysql_40':

1734

case 'mysql_41':

1735

$sql = "SHOW COLUMNS

1736

FROM $table";

1737

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

1738

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

1739

{

1740

// lower case just in case

1741

if (strtolower($row['Field']) == $column_name)

1742

{

1743

$db->sql_freeresult($result);

1744

return true;

1745

}

1746

}

1747

$db->sql_freeresult($result);

1748

return false;

1749

break;

1750

1751

// PostgreSQL has a way of doing this in a much simpler way but would

1752

// not allow us to support all versions of PostgreSQL

1753

case 'postgres':

1754

$sql = "SELECT a.attname

1755

FROM pg_class c, pg_attribute a

1756

WHERE c.relname = '{$table}'

1757

AND a.attnum > 0

1758

AND a.attrelid = c.oid";

1759

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

1760

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

1761

{

1762

// lower case just in case

1763

if (strtolower($row['attname']) == $column_name)

1764

{

1765

$db->sql_freeresult($result);

1766

return true;

1767

}

1768

}

1769

$db->sql_freeresult($result);

1770

return false;

1771

break;

1772

1773

// same deal with PostgreSQL, we must perform more complex operations than

1774

// we technically could

1775

case 'mssql':

1776

$sql = "SELECT c.name

1777

FROM syscolumns c

1778

LEFT JOIN sysobjects o ON c.id = o.id

1779

WHERE o.name = '{$table}'";

1780

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

1781

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

1782

{

1783

// lower case just in case

1784

if (strtolower($row['name']) == $column_name)

1785

{

1786

$db->sql_freeresult($result);

1787

return true;

1788

}

1789

}

1790

$db->sql_freeresult($result);

1791

return false;

1792

break;

1793

1794

case 'oracle':

1795

$sql = "SELECT column_name

1796

FROM user_tab_columns

1797

WHERE table_name = '{$table}'";

1798

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

1799

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

1800

{

1801

// lower case just in case

1802

if (strtolower($row['column_name']) == $column_name)

1803

{

1804

$db->sql_freeresult($result);

1805

return true;

1806

}

1807

}

1808

$db->sql_freeresult($result);

1809

return false;

1810

break;

1811

1812

case 'firebird':

1813

$sql = "SELECT RDB\$FIELD_NAME as FNAME

1814

FROM RDB\$RELATION_FIELDS

1815

WHERE RDB\$RELATION_NAME = '{$table}'";

1816

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

1817

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

1818

{

1819

// lower case just in case

1820

if (strtolower($row['fname']) == $column_name)

1821

{

1822

$db->sql_freeresult($result);

1823

return true;

1824

}

1825

}

1826

$db->sql_freeresult($result);

1827

return false;

1828

break;

1829

1830

// ugh, SQLite

1831

case 'sqlite':

1832

$sql = "SELECT sql

1833

FROM sqlite_master

1834

WHERE type = 'table'

1835

AND name = '{$table}'";

1836

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

1837

1838

if (!$result)

1839

{

1840

return false;

1841

}

1842

1843

$row = $db->sql_fetchrow($result);

1844

$db->sql_freeresult($result);

1845

1846

preg_match('#$(.*)$#s', $row['sql'], $matches);

1847

1848

$cols = trim($matches[1]);

1849

$col_array = preg_split('/,(?![\s\w]+\))/m', $cols);

1850

1851

foreach ($col_array as $declaration)

1852

{

1853

$entities = preg_split('#\s+#', trim($declaration));

1854

if ($entities[0] == 'PRIMARY')

1855

{

1856

continue;

1857

}

1858

1859

if (strtolower($entities[0]) == $column_name)

1860

{

1861

return true;

1862

}

1863

}

1864

return false;

1865

break;

1866

}

1867

}

1868

1869

/**

1870

* Function to prepare some column information for better usage

1871

1872

function prepare_column_data($dbms, $column_data, $table_name, $column_name)

1873

{

1874

global $dbms_type_map, $unsigned_types;

1875

1876

// Get type

1877

if (strpos($column_data[0], ':') !== false)

1878

{

1879

list($orig_column_type, $column_length) = explode(':', $column_data[0]);

1880

1881

if (!is_array($dbms_type_map[$dbms][$orig_column_type . ':']))

1882

{

1883

$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'], $column_length);

1884

}

1885

else

1886

{

1887

if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['rule']))

1888

{

1889

switch ($dbms_type_map[$dbms][$orig_column_type . ':']['rule'][0])

1890

{

1891

case 'div':

1892

$column_length /= $dbms_type_map[$dbms][$orig_column_type . ':']['rule'][1];

1893

$column_length = ceil($column_length);

1894

$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);

1895

break;

1896

}

1897

}

1898

1899

if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['limit']))

1900

{

1901

switch ($dbms_type_map[$dbms][$orig_column_type . ':']['limit'][0])

1902

{

1903

case 'mult':

1904

$column_length *= $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][1];

1905

if ($column_length > $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][2])

1906

{

1907

$column_type = $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][3];

1908

}

1909

else

1910

{

1911

$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);

1912

}

1913

break;

1914

}

1915

}

1916

}

1917

$orig_column_type .= ':';

1918

}

1919

else

1920

{

1921

$orig_column_type = $column_data[0];

1922

$column_type = $dbms_type_map[$dbms][$column_data[0]];

1923

}

1924

1925

// Adjust default value if db-dependant specified

1926

if (is_array($column_data[1]))

1927

{

1928

$column_data[1] = (isset($column_data[1][$dbms])) ? $column_data[1][$dbms] : $column_data[1]['default'];

1929

}

1930

1931

$sql = '';

1932

$return_array = array();

1933

1934

switch ($dbms)

1935

{

1936

case 'firebird':

1937

$sql .= " {$column_type} ";

1938

1939

if (!is_null($column_data[1]))

1940

{

1941

$sql .= 'DEFAULT ' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ' ';

1942

}

1943

1944

$sql .= 'NOT NULL';

1945

1946

// This is a UNICODE column and thus should be given it's fair share

1947

if (preg_match('/^X?STEXT_UNI|VCHAR_(CI|UNI:?)/', $column_data[0]))

1948

{

1949

$sql .= ' COLLATE UNICODE';

1950

}

1951

1952

break;

1953

1954

case 'mssql':

1955

$sql .= " {$column_type} ";

1956

$sql_default = " {$column_type} ";

1957

1958

// For adding columns we need the default definition

1959

if (!is_null($column_data[1]))

1960

{

1961

// For hexadecimal values do not use single quotes

1962

if (strpos($column_data[1], '0x') === 0)

1963

{

1964

$sql_default .= 'DEFAULT (' . $column_data[1] . ') ';

1965

}

1966

else

1967

{

1968

$sql_default .= 'DEFAULT (' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ') ';

1969

}

1970

}

1971

1972

$sql .= 'NOT NULL';

1973

$sql_default .= 'NOT NULL';

1974

1975

$return_array['column_type_sql_default'] = $sql_default;

1976

break;

1977

1978

case 'mysql_40':

1979

case 'mysql_41':

1980

$sql .= " {$column_type} ";

1981

1982

// For hexadecimal values do not use single quotes

1983

if (!is_null($column_data[1]) && substr($column_type, -4) !== 'text' && substr($column_type, -4) !== 'blob')

1984

{

1985

$sql .= (strpos($column_data[1], '0x') === 0) ? "DEFAULT {$column_data[1]} " : "DEFAULT '{$column_data[1]}' ";

1986

}

1987

$sql .= 'NOT NULL';

1988

1989

if (isset($column_data[2]))

1990

{

1991

if ($column_data[2] == 'auto_increment')

1992

{

1993

$sql .= ' auto_increment';

1994

}

1995

else if ($dbms === 'mysql_41' && $column_data[2] == 'true_sort')

1996

{

1997

$sql .= ' COLLATE utf8_unicode_ci';

1998

}

1999

}

2000

2001

break;

2002

2003

case 'oracle':

2004

$sql .= " {$column_type} ";

2005

$sql .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}' " : '';

2006

2007

// In Oracle empty strings ('') are treated as NULL.

2008

// Therefore in oracle we allow NULL's for all DEFAULT '' entries

2009

// Oracle does not like setting NOT NULL on a column that is already NOT NULL (this happens only on number fields)

2010

if (preg_match('/number/i', $column_type))

2011

{

2012

$sql .= ($column_data[1] === '') ? '' : 'NOT NULL';

2013

}

2014

break;

2015

2016

case 'postgres':

2017

$return_array['column_type'] = $column_type;

2018

2019

$sql .= " {$column_type} ";

2020

2021

if (isset($column_data[2]) && $column_data[2] == 'auto_increment')

2022

{

2023

$default_val = "nextval('{$table_name}_seq')";

2024

}

2025

else if (!is_null($column_data[1]))

2026

{

2027

$default_val = "'" . $column_data[1] . "'";

2028

$return_array['null'] = 'NOT NULL';

2029

$sql .= 'NOT NULL ';

2030

}

2031

2032

$return_array['default'] = $default_val;

2033

2034

$sql .= "DEFAULT {$default_val}";

2035

2036

// Unsigned? Then add a CHECK contraint

2037

if (in_array($orig_column_type, $unsigned_types))

2038

{

2039

$return_array['constraint'] = "CHECK ({$column_name} >= 0)";

2040

$sql .= " CHECK ({$column_name} >= 0)";

2041

}

2042

break;

2043

2044

case 'sqlite':

2045

if (isset($column_data[2]) && $column_data[2] == 'auto_increment')

2046

{

2047

$sql .= ' INTEGER PRIMARY KEY';

2048

}

2049

else

2050

{

2051

$sql .= ' ' . $column_type;

2052

}

2053

2054

$sql .= ' NOT NULL ';

2055

$sql .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}'" : '';

2056

break;

2057

}

2058

2059

$return_array['column_type_sql'] = $sql;

2060

2061

return $return_array;

2062

}

2063

2064

/**

2065

* Add new column

2066

2067

function sql_column_add($dbms, $table_name, $column_name, $column_data)

2068

{

2069

global $errored, $error_ary;

2070

2071

$column_data = prepare_column_data($dbms, $column_data, $table_name, $column_name);

2072

2073

switch ($dbms)

2074

{

2075

case 'firebird':

2076

$sql = 'ALTER TABLE "' . $table_name . '" ADD "' . $column_name . '" ' . $column_data['column_type_sql'];

2077

_sql($sql, $errored, $error_ary);

2078

break;

2079

2080

case 'mssql':

2081

$sql = 'ALTER TABLE [' . $table_name . '] ADD [' . $column_name . '] ' . $column_data['column_type_sql_default'];

2082

_sql($sql, $errored, $error_ary);

2083

break;

2084

2085

case 'mysql_40':

2086

case 'mysql_41':

2087

$sql = 'ALTER TABLE `' . $table_name . '` ADD COLUMN `' . $column_name . '` ' . $column_data['column_type_sql'];

2088

_sql($sql, $errored, $error_ary);

2089

break;

2090

2091

case 'oracle':

2092

$sql = 'ALTER TABLE ' . $table_name . ' ADD ' . $column_name . ' ' . $column_data['column_type_sql'];

2093

_sql($sql, $errored, $error_ary);

2094

break;

2095

2096

case 'postgres':

2097

$sql = 'ALTER TABLE ' . $table_name . ' ADD COLUMN "' . $column_name . '" ' . $column_data['column_type_sql'];

2098

_sql($sql, $errored, $error_ary);

2099

break;

2100

2101

case 'sqlite':

2102

if (version_compare(sqlite_libversion(), '3.0') == -1)

2103

{

2104

global $db;

2105

$sql = "SELECT sql

2106

FROM sqlite_master

2107

WHERE type = 'table'

2108

AND name = '{$table_name}'

2109

ORDER BY type DESC, name;";

2110

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

2111

2112

if (!$result)

2113

{

2114

break;

2115

}

2116

2117

$row = $db->sql_fetchrow($result);

2118

$db->sql_freeresult($result);

2119

2120

$db->sql_transaction('begin');

2121

2122

// Create a backup table and populate it, destroy the existing one

2123

$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));

2124

$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);

2125

$db->sql_query('DROP TABLE ' . $table_name);

2126

2127

preg_match('#$(.*)$#s', $row['sql'], $matches);

2128

2129

$new_table_cols = trim($matches[1]);

2130

$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);

2131

$column_list = array();

2132

2133

foreach ($old_table_cols as $declaration)

2134

{

2135

$entities = preg_split('#\s+#', trim($declaration));

2136

if ($entities[0] == 'PRIMARY')

2137

{

2138

continue;

2139

}

2140

$column_list[] = $entities[0];

2141

}

2142

2143

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

2144

2145

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

2146

2147

// create a new table and fill it up. destroy the temp one

2148

$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');');

2149

$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');

2150

$db->sql_query('DROP TABLE ' . $table_name . '_temp');

2151

2152

$db->sql_transaction('commit');

2153

}

2154

else

2155

{

2156

$sql = 'ALTER TABLE ' . $table_name . ' ADD ' . $column_name . ' [' . $column_data['column_type_sql'] . ']';

2157

_sql($sql, $errored, $error_ary);

2158

}

2159

break;

2160

}

2161

}

2162

2163

/**

2164

* Drop column

2165

2166

function sql_column_remove($dbms, $table_name, $column_name)

2167

{

2168

global $errored, $error_ary;

2169

2170

switch ($dbms)

2171

{

2172

case 'firebird':

2173

$sql = 'ALTER TABLE "' . $table_name . '" DROP "' . $column_name . '"';

2174

_sql($sql, $errored, $error_ary);

2175

break;

2176

2177

case 'mssql':

2178

$sql = 'ALTER TABLE [' . $table_name . '] DROP COLUMN [' . $column_name . ']';

2179

_sql($sql, $errored, $error_ary);

2180

break;

2181

2182

case 'mysql_40':

2183

case 'mysql_41':

2184

$sql = 'ALTER TABLE `' . $table_name . '` DROP COLUMN `' . $column_name . '`';

2185

_sql($sql, $errored, $error_ary);

2186

break;

2187

2188

case 'oracle':

2189

$sql = 'ALTER TABLE ' . $table_name . ' DROP ' . $column_name;

2190

_sql($sql, $errored, $error_ary);

2191

break;

2192

2193

case 'postgres':

2194

$sql = 'ALTER TABLE ' . $table_name . ' DROP COLUMN "' . $column_name . '"';

2195

_sql($sql, $errored, $error_ary);

2196

break;

2197

2198

case 'sqlite':

2199

if (version_compare(sqlite_libversion(), '3.0') == -1)

2200

{

2201

global $db;

2202

$sql = "SELECT sql

2203

FROM sqlite_master

2204

WHERE type = 'table'

2205

AND name = '{$table_name}'

2206

ORDER BY type DESC, name;";

2207

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

2208

2209

if (!$result)

2210

{

2211

break;

2212

}

2213

2214

$row = $db->sql_fetchrow($result);

2215

$db->sql_freeresult($result);

2216

2217

$db->sql_transaction('begin');

2218

2219

// Create a backup table and populate it, destroy the existing one

2220

$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));

2221

$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);

2222

$db->sql_query('DROP TABLE ' . $table_name);

2223

2224

preg_match('#$(.*)$#s', $row['sql'], $matches);

2225

2226

$new_table_cols = trim($matches[1]);

2227

$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);

2228

$column_list = array();

2229

2230

foreach ($old_table_cols as $declaration)

2231

{

2232

$entities = preg_split('#\s+#', trim($declaration));

2233

if ($entities[0] == 'PRIMARY' || $entities[0] === $column_name)

2234

{

2235

continue;

2236

}

2237

$column_list[] = $entities[0];

2238

}

2239

2240

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

2241

2242

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

2243

2244

// create a new table and fill it up. destroy the temp one

2245

$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ');');

2246

$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');

2247

$db->sql_query('DROP TABLE ' . $table_name . '_temp');

2248

2249

$db->sql_transaction('commit');

2250

}

2251

else

2252

{

2253

$sql = 'ALTER TABLE ' . $table_name . ' DROP COLUMN ' . $column_name;

2254

_sql($sql, $errored, $error_ary);

2255

}

2256

break;

2257

}

2258

}

2259

2260

function sql_index_drop($dbms, $index_name, $table_name)

2261

{

2262

global $dbms_type_map, $db;

2263

global $errored, $error_ary;

2264

2265

switch ($dbms)

2266

{

2267

case 'mssql':

2268

$sql = 'DROP INDEX ' . $table_name . '.' . $index_name;

2269

_sql($sql, $errored, $error_ary);

2270

break;

2271

2272

case 'mysql_40':

2273

case 'mysql_41':

2274

$sql = 'DROP INDEX ' . $index_name . ' ON ' . $table_name;

2275

_sql($sql, $errored, $error_ary);

2276

break;

2277

2278

case 'firebird':

2279

case 'oracle':

2280

case 'postgres':

2281

case 'sqlite':

2282

$sql = 'DROP INDEX ' . $table_name . '_' . $index_name;

2283

_sql($sql, $errored, $error_ary);

2284

break;

2285

}

2286

}

2287

2288

function sql_create_primary_key($dbms, $table_name, $column)

2289

{

2290

global $dbms_type_map, $db;

2291

global $errored, $error_ary;

2292

2293

switch ($dbms)

2294

{

2295

case 'firebird':

2296

case 'postgres':

2297

$sql = 'ALTER TABLE ' . $table_name . ' ADD PRIMARY KEY (' . implode(', ', $column) . ')';

2298

_sql($sql, $errored, $error_ary);

2299

break;

2300

2301

case 'mssql':

2302

$sql = "ALTER TABLE [{$table_name}] WITH NOCHECK ADD ";

2303

$sql .= "CONSTRAINT [PK_{$table_name}] PRIMARY KEY CLUSTERED (";

2304

$sql .= '[' . implode("],\n\t\t[", $column) . ']';

2305

$sql .= ') ON [PRIMARY]';

2306

_sql($sql, $errored, $error_ary);

2307

break;

2308

2309

case 'mysql_40':

2310

case 'mysql_41':

2311

$sql = 'ALTER TABLE ' . $table_name . ' ADD PRIMARY KEY (' . implode(', ', $column) . ')';

2312

_sql($sql, $errored, $error_ary);

2313

break;

2314

2315

case 'oracle':

2316

$sql = 'ALTER TABLE ' . $table_name . 'add CONSTRAINT pk_' . $table_name . ' PRIMARY KEY (' . implode(', ', $column) . ')';

2317

_sql($sql, $errored, $error_ary);

2318

break;

2319

2320

case 'sqlite':

2321

$sql = "SELECT sql

2322

FROM sqlite_master

2323

WHERE type = 'table'

2324

AND name = '{$table_name}'

2325

ORDER BY type DESC, name;";

2326

$result = _sql($sql, $errored, $error_ary);

2327

2328

if (!$result)

2329

{

2330

break;

2331

}

2332

2333

$row = $db->sql_fetchrow($result);

2334

$db->sql_freeresult($result);

2335

2336

$db->sql_transaction('begin');

2337

2338

// Create a backup table and populate it, destroy the existing one

2339

$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));

2340

$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);

2341

$db->sql_query('DROP TABLE ' . $table_name);

2342

2343

preg_match('#$(.*)$#s', $row['sql'], $matches);

2344

2345

$new_table_cols = trim($matches[1]);

2346

$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);

2347

$column_list = array();

2348

2349

foreach ($old_table_cols as $declaration)

2350

{

2351

$entities = preg_split('#\s+#', trim($declaration));

2352

if ($entities[0] == 'PRIMARY')

2353

{

2354

continue;

2355

}

2356

$column_list[] = $entities[0];

2357

}

2358

2359

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

2360

2361

// create a new table and fill it up. destroy the temp one

2362

$db->sql_query('CREATE TABLE ' . $table_name . ' (' . $new_table_cols . ', PRIMARY KEY (' . implode(', ', $column) . '));');

2363

$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');

2364

$db->sql_query('DROP TABLE ' . $table_name . '_temp');

2365

2366

$db->sql_transaction('commit');

2367

break;

2368

}

2369

}

2370

2371

function sql_create_unique_index($dbms, $index_name, $table_name, $column)

2372

{

2373

global $dbms_type_map, $db;

2374

global $errored, $error_ary;

2375

2376

switch ($dbms)

2377

{

2378

case 'firebird':

2379

case 'postgres':

2380

case 'oracle':

2381

case 'sqlite':

2382

$sql = 'CREATE UNIQUE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';

2383

_sql($sql, $errored, $error_ary);

2384

break;

2385

2386

case 'mysql_40':

2387

case 'mysql_41':

2388

$sql = 'CREATE UNIQUE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';

2389

_sql($sql, $errored, $error_ary);

2390

break;

2391

2392

case 'mssql':

2393

$sql = 'CREATE UNIQUE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ') ON [PRIMARY]';

2394

_sql($sql, $errored, $error_ary);

2395

break;

2396

}

2397

}

2398

2399

function sql_create_index($dbms, $index_name, $table_name, $column)

2400

{

2401

global $dbms_type_map, $db;

2402

global $errored, $error_ary;

2403

2404

switch ($dbms)

2405

{

2406

case 'firebird':

2407

case 'postgres':

2408

case 'oracle':

2409

case 'sqlite':

2410

$sql = 'CREATE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';

2411

_sql($sql, $errored, $error_ary);

2412

break;

2413

2414

case 'mysql_40':

2415

case 'mysql_41':

2416

$sql = 'CREATE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';

2417

_sql($sql, $errored, $error_ary);

2418

break;

2419

2420

case 'mssql':

2421

$sql = 'CREATE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ') ON [PRIMARY]';

2422

_sql($sql, $errored, $error_ary);

2423

break;

2424

}

2425

}

2426

2427

// List all of the indices that belong to a table,

2428

// does not count:

2429

// * UNIQUE indices

2430

// * PRIMARY keys

2431

function sql_list_index($dbms, $table_name)

2432

{

2433

global $dbms_type_map, $db;

2434

global $errored, $error_ary;

2435

2436

$index_array = array();

2437

2438

if ($dbms == 'mssql')

2439

{

2440

$sql = "EXEC sp_statistics '$table_name'";

2441

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

2442

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

2443

{

2444

if ($row['TYPE'] == 3)

2445

{

2446

$index_array[] = $row['INDEX_NAME'];

2447

}

2448

}

2449

$db->sql_freeresult($result);

2450

}

2451

else

2452

{

2453

switch ($dbms)

2454

{

2455

case 'firebird':

2456

$sql = "SELECT LOWER(RDB\$INDEX_NAME) as index_name

2457

FROM RDB\$INDICES

2458

WHERE RDB\$RELATION_NAME = " . strtoupper($table_name) . "

2459

AND RDB\$UNIQUE_FLAG IS NULL

2460

AND RDB\$FOREIGN_KEY IS NULL";

2461

$col = 'index_name';

2462

break;

2463

2464

case 'postgres':

2465

$sql = "SELECT ic.relname as index_name

2466

FROM pg_class bc, pg_class ic, pg_index i

2467

WHERE (bc.oid = i.indrelid)

2468

AND (ic.oid = i.indexrelid)

2469

AND (bc.relname = '" . $table_name . "')

2470

AND (i.indisunique != 't')

2471

AND (i.indisprimary != 't')";

2472

$col = 'index_name';

2473

break;

2474

2475

case 'mysql_40':

2476

case 'mysql_41':

2477

$sql = 'SHOW KEYS

2478

FROM ' . $table_name;

2479

$col = 'Key_name';

2480

break;

2481

2482

case 'oracle':

2483

$sql = "SELECT index_name

2484

FROM user_indexes

2485

WHERE table_name = '" . $table_name . "'

2486

AND generated = 'N'";

2487

break;

2488

2489

case 'sqlite':

2490

$sql = "PRAGMA index_info('" . $table_name . "');";

2491

$col = 'name';

2492

break;

2493

}

2494

2495

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

2496

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

2497

{

2498

if (($dbms == 'mysql_40' || $dbms == 'mysql_41') && !$row['Non_unique'])

2499

{

2500

continue;

2501

}

2502

2503

switch ($dbms)

2504

{

2505

case 'firebird':

2506

case 'oracle':

2507

case 'postgres':

2508

case 'sqlite':

2509

$row[$col] = substr($row[$col], strlen($table_name) + 1);

2510

break;

2511

}

2512

2513

$index_array[] = $row[$col];

2514

}

2515

$db->sql_freeresult($result);

2516

}

2517

2518

return array_map('strtolower', $index_array);

2519

}

2520

2521

// This is totally fake, never use it

2522

// it exists only to mend bad update functions introduced

2523

// * UNIQUE indices

2524

// * PRIMARY keys

2525

function sql_list_fake($dbms, $table_name)

2526

{

2527

global $dbms_type_map, $db;

2528

global $errored, $error_ary;

2529

2530

$index_array = array();

2531

2532

if ($dbms == 'mssql')

2533

{

2534

$sql = "EXEC sp_statistics '$table_name'";

2535

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

2536

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

2537

{

2538

if ($row['TYPE'] == 3)

2539

{

2540

$index_array[] = $row['INDEX_NAME'];

2541

}

2542

}

2543

$db->sql_freeresult($result);

2544

}

2545

else

2546

{

2547

switch ($dbms)

2548

{

2549

case 'firebird':

2550

$sql = "SELECT LOWER(RDB\$INDEX_NAME) as index_name

2551

FROM RDB\$INDICES

2552

WHERE RDB\$RELATION_NAME = " . strtoupper($table_name) . "

2553

AND RDB\$UNIQUE_FLAG IS NULL

2554

AND RDB\$FOREIGN_KEY IS NULL";

2555

$col = 'index_name';

2556

break;

2557

2558

case 'postgres':

2559

$sql = "SELECT ic.relname as index_name

2560

FROM pg_class bc, pg_class ic, pg_index i

2561

WHERE (bc.oid = i.indrelid)

2562

AND (ic.oid = i.indexrelid)

2563

AND (bc.relname = '" . $table_name . "')

2564

AND (i.indisunique != 't')

2565

AND (i.indisprimary != 't')";

2566

$col = 'index_name';

2567

break;

2568

2569

case 'mysql_40':

2570

case 'mysql_41':

2571

$sql = 'SHOW KEYS

2572

FROM ' . $table_name;

2573

$col = 'Key_name';

2574

break;

2575

2576

case 'oracle':

2577

$sql = "SELECT index_name

2578

FROM user_indexes

2579

WHERE table_name = '" . $table_name . "'

2580

AND generated = 'N'";

2581

break;

2582

2583

case 'sqlite':

2584

$sql = "PRAGMA index_info('" . $table_name . "');";

2585

$col = 'name';

2586

break;

2587

}

2588

2589

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

2590

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

2591

{

2592

if (($dbms == 'mysql_40' || $dbms == 'mysql_41') && !$row['Non_unique'])

2593

{

2594

continue;

2595

}

2596

2597

$index_array[] = $row[$col];

2598

}

2599

$db->sql_freeresult($result);

2600

}

2601

2602

return array_map('strtolower', $index_array);

2603

}

2604

2605

/**

2606

* Change column type (not name!)

2607

2608

function sql_column_change($dbms, $table_name, $column_name, $column_data)

2609

{

2610

global $dbms_type_map, $db;

2611

global $errored, $error_ary;

2612

2613

$column_data = prepare_column_data($dbms, $column_data, $table_name, $column_name);

2614

2615

switch ($dbms)

2616

{

2617

case 'firebird':

2618

// Change type...

2619

$sql = 'ALTER TABLE "' . $table_name . '" ALTER COLUMN "' . $column_name . '" TYPE ' . ' ' . $column_data['column_type_sql'];

2620

_sql($sql, $errored, $error_ary);

2621

break;

2622

2623

case 'mssql':

2624

$sql = 'ALTER TABLE [' . $table_name . '] ALTER COLUMN [' . $column_name . '] ' . $column_data['column_type_sql'];

2625

_sql($sql, $errored, $error_ary);

2626

break;

2627

2628

case 'mysql_40':

2629

case 'mysql_41':

2630

$sql = 'ALTER TABLE `' . $table_name . '` CHANGE `' . $column_name . '` `' . $column_name . '` ' . $column_data['column_type_sql'];

2631

_sql($sql, $errored, $error_ary);

2632

break;

2633

2634

case 'oracle':

2635

$sql = 'ALTER TABLE ' . $table_name . ' MODIFY ' . $column_name . ' ' . $column_data['column_type_sql'];

2636

_sql($sql, $errored, $error_ary);

2637

break;

2638

2639

case 'postgres':

2640

$sql = 'ALTER TABLE ' . $table_name . ' ';

2641

2642

$sql_array = array();

2643

$sql_array[] = 'ALTER COLUMN ' . $column_name . ' TYPE ' . $column_data['column_type'];

2644

2645

if (isset($column_data['null']))

2646

{

2647

if ($column_data['null'] == 'NOT NULL')

2648

{

2649

$sql_array[] = 'ALTER COLUMN ' . $column_name . ' SET NOT NULL';

2650

}

2651

else if ($column_data['null'] == 'NULL')

2652

{

2653

$sql_array[] = 'ALTER COLUMN ' . $column_name . ' DROP NOT NULL';

2654

}

2655

}

2656

2657

if (isset($column_data['default']))

2658

{

2659

$sql_array[] = 'ALTER COLUMN ' . $column_name . ' SET DEFAULT ' . $column_data['default'];

2660

}

2661

2662

// we don't want to double up on constraints if we change different number data types

2663

if (isset($column_data['constraint']))

2664

{

2665

$constraint_sql = "SELECT consrc as constraint_data

2666

FROM pg_constraint, pg_class bc

2667

WHERE conrelid = bc.oid

2668

AND bc.relname = '{$table_name}'

2669

AND NOT EXISTS (

2670

SELECT *

2671

FROM pg_constraint as c, pg_inherits as i

2672

WHERE i.inhrelid = pg_constraint.conrelid

2673

AND c.conname = pg_constraint.conname

2674

AND c.consrc = pg_constraint.consrc

2675

AND c.conrelid = i.inhparent

2676

)";

2677

2678

$constraint_exists = false;

2679

2680

$result = $db->sql_query($constraint_sql);

2681

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

2682

{

2683

if (trim($row['constraint_data']) == trim($column_data['constraint']))

2684

{

2685

$constraint_exists = true;

2686

break;

2687

}

2688

}

2689

$db->sql_freeresult($result);

2690

2691

if (!$constraint_exists)

2692

{

2693

$sql_array[] = 'ADD ' . $column_data['constraint'];

2694

}

2695

}

2696

2697

$sql .= implode(', ', $sql_array);

2698

2699

_sql($sql, $errored, $error_ary);

2700

break;

2701

2702

case 'sqlite':

2703

2704

$sql = "SELECT sql

2705

FROM sqlite_master

2706

WHERE type = 'table'

2707

AND name = '{$table_name}'

2708

ORDER BY type DESC, name;";

2709

$result = _sql($sql, $errored, $error_ary);

2710

2711

if (!$result)

2712

{

2713

break;

2714

}

2715

2716

$row = $db->sql_fetchrow($result);

2717

$db->sql_freeresult($result);

2718

2719

$db->sql_transaction('begin');

2720

2721

// Create a temp table and populate it, destroy the existing one

2722

$db->sql_query(preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', 'CREATE TEMPORARY TABLE ' . $table_name . '_temp', $row['sql']));

2723

$db->sql_query('INSERT INTO ' . $table_name . '_temp SELECT * FROM ' . $table_name);

2724

$db->sql_query('DROP TABLE ' . $table_name);

2725

2726

preg_match('#$(.*)$#s', $row['sql'], $matches);

2727

2728

$new_table_cols = trim($matches[1]);

2729

$old_table_cols = preg_split('/,(?![\s\w]+\))/m', $new_table_cols);

2730

$column_list = array();

2731

2732

foreach ($old_table_cols as $key => $declaration)

2733

{

2734

$entities = preg_split('#\s+#', trim($declaration));

2735

$column_list[] = $entities[0];

2736

if ($entities[0] == $column_name)

2737

{

2738

$old_table_cols[$key] = $column_name . ' ' . $column_data['column_type_sql'];

2739

}

2740

}

2741

2742

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

2743

2744

// create a new table and fill it up. destroy the temp one

2745

$db->sql_query('CREATE TABLE ' . $table_name . ' (' . implode(',', $old_table_cols) . ');');

2746

$db->sql_query('INSERT INTO ' . $table_name . ' (' . $columns . ') SELECT ' . $columns . ' FROM ' . $table_name . '_temp;');

2747

$db->sql_query('DROP TABLE ' . $table_name . '_temp');

2748

2749

$db->sql_transaction('commit');

2750

2751

break;

2752

}

2753

}

2754

2755

function utf8_new_clean_string($text)

2756

{

2757

static $homographs = array();

2758

static $utf8_case_fold_nfkc = '';

2759

if (empty($homographs))

2760

{

2761

global $phpbb_root_path, $phpEx;

2762

if (!function_exists('utf8_case_fold_nfkc') || !file_exists($phpbb_root_path . 'includes/utf/data/confusables.' . $phpEx))

2763

{

2764

if (!file_exists($phpbb_root_path . 'install/data/confusables.' . $phpEx))

2765

{

2766

global $lang;

2767

trigger_error(sprintf($lang['UPDATE_REQUIRES_FILE'], $phpbb_root_path . 'install/data/confusables.' . $phpEx), E_USER_ERROR);

2768

}

2769

$homographs = include($phpbb_root_path . 'install/data/confusables.' . $phpEx);

2770

$utf8_case_fold_nfkc = 'utf8_new_case_fold_nfkc';

2771

}

2772

else

2773

{

2774

$homographs = include($phpbb_root_path . 'includes/utf/data/confusables.' . $phpEx);

2775

$utf8_case_fold_nfkc = 'utf8_case_fold_nfkc';

2776

}

2777

}

2778

2779

$text = $utf8_case_fold_nfkc($text);

2780

$text = strtr($text, $homographs);

2781

// Other control characters

2782

$text = preg_replace('#(?:[\x00-\x1F\x7F]+|(?:\xC2[\x80-\x9F])+)#', '', $text);

2783

2784

$text = preg_replace('# {2,}#', ' ', $text);

2785

2786

// we can use trim here as all the other space characters should have been turned

2787

// into normal ASCII spaces by now

2788

return trim($text);

2789

}

2790

2791

b'\\ No newline at end of file'

Older »