?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
do not display ban link for own profile
[phpbb.git] / phpBB / install / install_convert.php
blobeaec24ef4fdf9f670bfb25a8a216cd8f0ce2890f
1 <?php
2 /**
3 *
4 * @package install
5 * @version $Id$
6 * @copyright (c) 2006 phpBB Group
7 * @license http://opensource.org/licenses/gpl-license.php GNU Public License
8 *
9 */
10
11 /**
12 */
13
14 if (!defined('IN_INSTALL'))
15 {
16 // Someone has tried to access the file direct. This is not a good idea, so exit
17 exit;
18 }
19
20 if (!empty($setmodules))
21 {
22 $module[] = array(
23 'module_type' => 'install',
24 'module_title' => 'CONVERT',
25 'module_filename' => substr(basename(__FILE__), 0, -strlen(PHP_EXT)-1),
26 'module_order' => 20,
27 'module_subs' => '',
28 'module_stages' => array('INTRO', 'SETTINGS', 'IN_PROGRESS', 'FINAL'),
29 'module_reqs' => ''
30 );
31 }
32
33 /**
34 * Class holding all convertor-specific details.
35 * @package install
36 */
37 class convert
38 {
39 var $options = array();
40
41 var $convertor_tag = '';
42 var $src_dbms = '';
43 var $src_dbhost = '';
44 var $src_dbport = '';
45 var $src_dbuser = '';
46 var $src_dbpasswd = '';
47 var $src_dbname = '';
48 var $src_table_prefix = '';
49
50 var $convertor_data = array();
51 var $tables = array();
52 var $config_schema = array();
53 var $convertor = array();
54 var $src_truncate_statement = 'DELETE FROM ';
55 var $truncate_statement = 'DELETE FROM ';
56
57 var $fulltext_search;
58
59 // Batch size, can be adjusted by the conversion file
60 // For big boards a value of 6000 seems to be optimal
61 var $batch_size = 2000;
62 // Number of rows to be inserted at once (extended insert) if supported
63 // For installations having enough memory a value of 60 may be good.
64 var $num_wait_rows = 20;
65
66 // Mysqls internal recoding engine messing up with our (better) functions? We at least support more encodings than mysql so should use it in favor.
67 var $mysql_convert = false;
68
69 var $p_master;
70
71 function __construct(&$p_master)
72 {
73 $this->p_master = &$p_master;
74 }
75 }
76
77 /**
78 * Convert class for conversions
79 * @package install
80 */
81 class install_convert extends module
82 {
83 /**
84 * Variables used while converting, they are accessible from the global variable $convert
85 */
86 function install_convert(&$p_master)
87 {
88 $this->p_master = &$p_master;
89 }
90
91 function main($mode, $sub)
92 {
93 global $lang, $template, $cache, $config, $language, $table_prefix;
94 global $convert;
95
96 $this->tpl_name = 'install_convert';
97 $this->mode = $mode;
98
99 $convert = new convert($this->p_master);
100
101 switch ($sub)
102 {
103 case 'intro':
104 // Try opening config file
105 // @todo If phpBB is not installed, we need to do a cut-down installation here
106 // For now, we redirect to the installation script instead
107 if (@file_exists(PHPBB_ROOT_PATH . 'config.' . PHP_EXT))
108 {
109 include(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
110 }
111
112 if (!defined('PHPBB_INSTALLED'))
113 {
114 $template->assign_vars(array(
115 'S_NOT_INSTALLED' => true,
116 'TITLE' => $lang['BOARD_NOT_INSTALLED'],
117 'BODY' => sprintf($lang['BOARD_NOT_INSTALLED_EXPLAIN'], append_sid('install/index', 'mode=install&amp;language=' . $language)),
118 ));
119
120 return;
121 }
122
123 require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
124 require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);
125 require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);
126 require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);
127
128 $db = new $sql_db();
129 $db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);
130 unset($dbpasswd);
131
132 // We need to fill the config to let internal functions correctly work
133 $sql = 'SELECT *
134 FROM ' . CONFIG_TABLE;
135 $result = $db->sql_query($sql);
136
137 $config = array();
138 while ($row = $db->sql_fetchrow($result))
139 {
140 $config[$row['config_name']] = $row['config_value'];
141 }
142 $db->sql_freeresult($result);
143
144 // Detect if there is already a conversion in progress at this point and offer to resume
145 // It's quite possible that the user will get disconnected during a large conversion so they need to be able to resume it
146 $new_conversion = request_var('new_conv', 0);
147
148 if ($new_conversion)
149 {
150 $config['convert_progress'] = '';
151 $config['convert_db_server'] = '';
152 $config['convert_db_user'] = '';
153 $db->sql_query('DELETE FROM ' . CONFIG_TABLE . "
154 WHERE config_name = 'convert_progress'
155 OR config_name = 'convert_db_server'
156 OR config_name = 'convert_db_user'"
157 );
158 }
159
160 // Let's see if there is a conversion in the works...
161 $options = array();
162 if (!empty($config['convert_progress']) && !empty($config['convert_db_server']) && !empty($config['convert_db_user']) && !empty($config['convert_options']))
163 {
164 $options = unserialize($config['convert_progress']);
165 $options = array_merge($options, unserialize($config['convert_db_server']), unserialize($config['convert_db_user']), unserialize($config['convert_options']));
166 }
167
168 // This information should have already been checked once, but do it again for safety
169 if (!empty($options) && !empty($options['tag']) &&
170 isset($options['dbms']) &&
171 isset($options['dbhost']) &&
172 isset($options['dbport']) &&
173 isset($options['dbuser']) &&
174 isset($options['dbpasswd']) &&
175 isset($options['dbname']) &&
176 isset($options['table_prefix']))
177 {
178 $this->page_title = $lang['CONTINUE_CONVERT'];
179
180 $template->assign_vars(array(
181 'TITLE' => $lang['CONTINUE_CONVERT'],
182 'BODY' => $lang['CONTINUE_CONVERT_BODY'],
183 'L_NEW' => $lang['CONVERT_NEW_CONVERSION'],
184 'L_CONTINUE' => $lang['CONTINUE_OLD_CONVERSION'],
185 'S_CONTINUE' => true,
186
187 'U_NEW_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&amp;sub=intro&amp;new_conv=1&amp;language=$language",
188 'U_CONTINUE_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&amp;sub=in_progress&amp;tag={$options['tag']}{$options['step']}&amp;language=$language",
189 ));
190
191 return;
192 }
193
194 $this->list_convertors($sub);
195
196 break;
197
198 case 'settings':
199 $this->get_convert_settings($sub);
200 break;
201
202 case 'in_progress':
203 $this->convert_data($sub);
204 break;
205
206 case 'final':
207 $this->page_title = $lang['CONVERT_COMPLETE'];
208
209 $template->assign_vars(array(
210 'TITLE' => $lang['CONVERT_COMPLETE'],
211 'BODY' => $lang['CONVERT_COMPLETE_EXPLAIN'],
212 ));
213
214 // If we reached this step (conversion completed) we want to purge the cache and log the user out.
215 // This is for making sure the session get not screwed due to the 3.0.x users table being completely new.
216 $cache->purge();
217
218 require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
219 require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);
220 require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);
221 require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);
222
223 $db = new $sql_db();
224 $db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);
225 unset($dbpasswd);
226
227 $sql = 'SELECT config_value
228 FROM ' . CONFIG_TABLE . '
229 WHERE config_name = \'search_type\'';
230 $result = $db->sql_query($sql);
231
232 if ($db->sql_fetchfield('config_value') != 'fulltext_mysql')
233 {
234 $template->assign_vars(array(
235 'S_ERROR_BOX' => true,
236 'ERROR_TITLE' => $lang['SEARCH_INDEX_UNCONVERTED'],
237 'ERROR_MSG' => $lang['SEARCH_INDEX_UNCONVERTED_EXPLAIN'],
238 ));
239 }
240
241 if ($db->truncate)
242 {
243 $db->sql_query('TRUNCATE TABLE ' . SESSIONS_KEYS_TABLE);
244 $db->sql_query('TRUNCATE TABLE ' . SESSIONS_TABLE);
245 }
246 else
247 {
248 $db->sql_query('DELETE FROM ' . SESSIONS_KEYS_TABLE);
249 $db->sql_query('DELETE FROM ' . SESSIONS_TABLE);
250 }
251
252 break;
253 }
254 }
255
256 /**
257 * Generate a list of all available conversion modules
258 */
259 function list_convertors($sub)
260 {
261 global $lang, $language, $template;
262
263 $this->page_title = $lang['SUB_INTRO'];
264
265 $template->assign_vars(array(
266 'TITLE' => $lang['CONVERT_INTRO'],
267 'BODY' => $lang['CONVERT_INTRO_BODY'],
268
269 'L_AUTHOR' => $lang['AUTHOR'],
270 'L_AVAILABLE_CONVERTORS' => $lang['AVAILABLE_CONVERTORS'],
271 'L_CONVERT' => $lang['CONVERT'],
272 'L_NO_CONVERTORS' => $lang['NO_CONVERTORS'],
273 'L_OPTIONS' => $lang['CONVERT_OPTIONS'],
274 'L_SOFTWARE' => $lang['SOFTWARE'],
275 'L_VERSION' => $lang['VERSION'],
276
277 'S_LIST' => true,
278 ));
279
280 $convertors = $sort = array();
281 $get_info = true;
282
283 $handle = @opendir('./convertors/');
284
285 if (!$handle)
286 {
287 $this->error('Unable to access the convertors directory', __LINE__, __FILE__);
288 }
289
290 while ($entry = readdir($handle))
291 {
292 if (preg_match('/^convert_([a-z0-9_]+).' . PHP_EXT . '$/i', $entry, $m))
293 {
294 include('./convertors/' . $entry);
295 if (isset($convertor_data))
296 {
297 $sort[strtolower($convertor_data['forum_name'])] = sizeof($convertors);
298
299 $convertors[] = array(
300 'tag' => $m[1],
301 'forum_name' => $convertor_data['forum_name'],
302 'version' => $convertor_data['version'],
303 'dbms' => $convertor_data['dbms'],
304 'dbhost' => $convertor_data['dbhost'],
305 'dbport' => $convertor_data['dbport'],
306 'dbuser' => $convertor_data['dbuser'],
307 'dbpasswd' => $convertor_data['dbpasswd'],
308 'dbname' => $convertor_data['dbname'],
309 'table_prefix' => $convertor_data['table_prefix'],
310 'author' => $convertor_data['author']
311 );
312 }
313 unset($convertor_data);
314 }
315 }
316 closedir($handle);
317
318 @ksort($sort);
319
320 foreach ($sort as $void => $index)
321 {
322 $template->assign_block_vars('convertors', array(
323 'AUTHOR' => $convertors[$index]['author'],
324 'SOFTWARE' => $convertors[$index]['forum_name'],
325 'VERSION' => $convertors[$index]['version'],
326
327 'U_CONVERT' => $this->p_master->module_url . "?mode={$this->mode}&amp;language=$language&amp;sub=settings&amp;tag=" . $convertors[$index]['tag'],
328 ));
329 }
330 }
331
332 /**
333 */
334 function get_convert_settings($sub)
335 {
336 global $lang, $language, $template, $db, $config, $cache;
337
338 require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
339 require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);
340 require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);
341 require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);
342
343 $db = new $sql_db();
344 $db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);
345 unset($dbpasswd);
346
347 $this->page_title = $lang['STAGE_SETTINGS'];
348
349 // We need to fill the config to let internal functions correctly work
350 $sql = 'SELECT *
351 FROM ' . CONFIG_TABLE;
352 $result = $db->sql_query($sql);
353
354 $config = array();
355 while ($row = $db->sql_fetchrow($result))
356 {
357 $config[$row['config_name']] = $row['config_value'];
358 }
359 $db->sql_freeresult($result);
360
361 $convertor_tag = request_var('tag', '');
362
363 if (empty($convertor_tag))
364 {
365 $this->p_master->error($lang['NO_CONVERT_SPECIFIED'], __LINE__, __FILE__);
366 }
367 $get_info = true;
368
369 // check security implications of direct inclusion
370 $convertor_tag = basename($convertor_tag);
371 if (!file_exists('./convertors/convert_' . $convertor_tag . '.' . PHP_EXT))
372 {
373 $this->p_master->error($lang['CONVERT_NOT_EXIST'], __LINE__, __FILE__);
374 }
375
376 include('./convertors/convert_' . $convertor_tag . '.' . PHP_EXT);
377
378 // The test_file is a file that should be present in the location of the old board.
379 if (!isset($test_file))
380 {
381 $this->p_master->error($lang['DEV_NO_TEST_FILE'], __LINE__, __FILE__);
382 }
383
384 $submit = request::is_set_post('submit');
385
386 $src_dbms = request_var('src_dbms', $convertor_data['dbms']);
387 $src_dbhost = request_var('src_dbhost', $convertor_data['dbhost']);
388 $src_dbport = request_var('src_dbport', $convertor_data['dbport']);
389 $src_dbuser = request_var('src_dbuser', $convertor_data['dbuser']);
390 $src_dbpasswd = request_var('src_dbpasswd', $convertor_data['dbpasswd']);
391 $src_dbname = request_var('src_dbname', $convertor_data['dbname']);
392 $src_table_prefix = request_var('src_table_prefix', $convertor_data['table_prefix']);
393 $forum_path = request_var('forum_path', $convertor_data['forum_path']);
394 $refresh = request_var('refresh', 1);
395
396 // Default URL of the old board
397 // @todo Are we going to use this for attempting to convert URL references in posts, or should we remove it?
398 // -> We should convert old urls to the new relative urls format
399 // $src_url = request_var('src_url', 'Not in use at the moment');
400
401 // strip trailing slash from old forum path
402 $forum_path = (strlen($forum_path) && $forum_path[strlen($forum_path) - 1] == '/') ? substr($forum_path, 0, -1) : $forum_path;
403
404 $error = array();
405 if ($submit)
406 {
407 if (!@file_exists('./../' . $forum_path . '/' . $test_file))
408 {
409 $error[] = sprintf($lang['COULD_NOT_FIND_PATH'], $forum_path);
410 }
411
412 $connect_test = false;
413 $available_dbms = get_available_dbms(false, true, true);
414
415 if (!isset($available_dbms[$src_dbms]) || !$available_dbms[$src_dbms]['AVAILABLE'])
416 {
417 $error['db'][] = $lang['INST_ERR_NO_DB'];
418 $connect_test = false;
419 }
420 else
421 {
422 $connect_test = connect_check_db(true, $error, $available_dbms[$src_dbms], $src_table_prefix, $src_dbhost, $src_dbuser, htmlspecialchars_decode($src_dbpasswd), $src_dbname, $src_dbport, true, ($src_dbms == $dbms) ? false : true, false);
423 }
424
425 // The forum prefix of the old and the new forum can only be the same if two different databases are used.
426 if ($src_table_prefix == $table_prefix && $src_dbms == $dbms && $src_dbhost == $dbhost && $src_dbport == $dbport && $src_dbname == $dbname)
427 {
428 $error[] = sprintf($lang['TABLE_PREFIX_SAME'], $src_table_prefix);
429 }
430
431 // Check table prefix
432 if (!sizeof($error))
433 {
434 // initiate database connection to old db if old and new db differ
435 global $src_db, $same_db;
436 $src_db = $same_db = false;
437
438 if ($src_dbms != $dbms || $src_dbhost != $dbhost || $src_dbport != $dbport || $src_dbname != $dbname || $src_dbuser != $dbuser)
439 {
440 $sql_db = 'dbal_' . $src_dbms;
441 $src_db = new $sql_db();
442 $src_db->sql_connect($src_dbhost, $src_dbuser, htmlspecialchars_decode($src_dbpasswd), $src_dbname, $src_dbport, false, true);
443 $same_db = false;
444 }
445 else
446 {
447 $src_db = $db;
448 $same_db = true;
449 }
450
451 $src_db->sql_return_on_error(true);
452 $db->sql_return_on_error(true);
453
454 // Try to select one row from the first table to see if the prefix is OK
455 $result = $src_db->sql_query_limit('SELECT * FROM ' . $src_table_prefix . $tables[0], 1);
456
457 if (!$result)
458 {
459 $prefixes = array();
460
461 $tables_existing = get_tables($src_db);
462 $tables_existing = array_map('strtolower', $tables_existing);
463 foreach ($tables_existing as $table_name)
464 {
465 compare_table($tables, $table_name, $prefixes);
466 }
467 unset($tables_existing);
468
469 foreach ($prefixes as $prefix => $count)
470 {
471 if ($count >= sizeof($tables))
472 {
473 $possible_prefix = $prefix;
474 break;
475 }
476 }
477
478 $msg = '';
479 if (!empty($convertor_data['table_prefix']))
480 {
481 $msg .= sprintf($lang['DEFAULT_PREFIX_IS'], $convertor_data['forum_name'], $convertor_data['table_prefix']);
482 }
483
484 if (!empty($possible_prefix))
485 {
486 $msg .= '<br />';
487 $msg .= ($possible_prefix == '*') ? $lang['BLANK_PREFIX_FOUND'] : sprintf($lang['PREFIX_FOUND'], $possible_prefix);
488 $src_table_prefix = ($possible_prefix == '*') ? '' : $possible_prefix;
489 }
490
491 $error[] = $msg;
492 }
493 $src_db->sql_freeresult($result);
494 $src_db->sql_return_on_error(false);
495 }
496
497 if (!sizeof($error))
498 {
499 // Save convertor Status
500 set_config('convert_progress', serialize(array(
501 'step' => '',
502 'table_prefix' => $src_table_prefix,
503 'tag' => $convertor_tag,
504 )), true);
505 set_config('convert_db_server', serialize(array(
506 'dbms' => $src_dbms,
507 'dbhost' => $src_dbhost,
508 'dbport' => $src_dbport,
509 'dbname' => $src_dbname,
510 )), true);
511 set_config('convert_db_user', serialize(array(
512 'dbuser' => $src_dbuser,
513 'dbpasswd' => $src_dbpasswd,
514 )), true);
515
516 // Save options
517 set_config('convert_options', serialize(array('forum_path' => './../' . $forum_path, 'refresh' => $refresh)), true);
518
519 $template->assign_block_vars('checks', array(
520 'TITLE' => $lang['VERIFY_OPTIONS'],
521 'RESULT' => $lang['CONVERT_SETTINGS_VERIFIED'],
522 ));
523
524 $template->assign_vars(array(
525 'L_SUBMIT' => $lang['BEGIN_CONVERT'],
526 // 'S_HIDDEN' => $s_hidden_fields,
527 'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&amp;sub=in_progress&amp;tag=$convertor_tag&amp;language=$language",
528 ));
529
530 return;
531 }
532 else
533 {
534 $template->assign_block_vars('checks', array(
535 'TITLE' => $lang['VERIFY_OPTIONS'],
536 'RESULT' => '<b style="color:red">' . implode('<br />', $error) . '</b>',
537 ));
538 }
539 } // end submit
540
541 foreach ($this->convert_options as $config_key => $vars)
542 {
543 if (!is_array($vars) && strpos($config_key, 'legend') === false)
544 {
545 continue;
546 }
547
548 if (strpos($config_key, 'legend') !== false)
549 {
550 $template->assign_block_vars('options', array(
551 'S_LEGEND' => true,
552 'LEGEND' => $lang[$vars])
553 );
554
555 continue;
556 }
557
558 $options = isset($vars['options']) ? $vars['options'] : '';
559
560 $template->assign_block_vars('options', array(
561 'KEY' => $config_key,
562 'TITLE' => $lang[$vars['lang']],
563 'S_EXPLAIN' => $vars['explain'],
564 'S_LEGEND' => false,
565 'TITLE_EXPLAIN' => ($vars['explain']) ? $lang[$vars['lang'] . '_EXPLAIN'] : '',
566 'CONTENT' => $this->p_master->input_field($config_key, $vars['type'], $$config_key, $options),
567 )
568 );
569 }
570
571 $template->assign_vars(array(
572 'TITLE' => $lang['STAGE_SETTINGS'],
573 'BODY' => $lang['CONV_OPTIONS_BODY'],
574 'L_SUBMIT' => $lang['BEGIN_CONVERT'],
575 'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&amp;sub=settings&amp;tag=$convertor_tag&amp;language=$language",
576 ));
577 }
578
579 /**
580 * The function which does the actual work (or dispatches it to the relevant places)
581 */
582 function convert_data($sub)
583 {
584 global $template, $user, $db, $lang, $config, $cache;
585 global $convert, $convert_row, $message_parser, $skip_rows, $language;
586
587 require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);
588 require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);
589 require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);
590 require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);
591
592 $db = new $sql_db();
593 $db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);
594 unset($dbpasswd);
595
596 $sql = 'SELECT *
597 FROM ' . CONFIG_TABLE;
598 $result = $db->sql_query($sql);
599
600 $config = array();
601 while ($row = $db->sql_fetchrow($result))
602 {
603 $config[$row['config_name']] = $row['config_value'];
604 }
605 $db->sql_freeresult($result);
606
607 // Override a couple of config variables for the duration
608 $config['max_quote_depth'] = 0;
609
610 // @todo Need to confirm that max post length in source is <= max post length in destination or there may be interesting formatting issues
611 $config['max_post_chars'] = 0;
612
613 // Set up a user as well. We _should_ have enough of a database here at this point to do this
614 // and it helps for any core code we call
615 $user->session_begin();
616 $user->page = session::extract_current_page(PHPBB_ROOT_PATH);
617
618 // This is a little bit of a fudge, but it allows the language entries to be available to the
619 // core code without us loading them again
620 $user->lang = &$lang;
621
622 $this->page_title = $user->lang['STAGE_IN_PROGRESS'];
623
624 $convert->options = array();
625 if (isset($config['convert_progress']))
626 {
627 $convert->options = unserialize($config['convert_progress']);
628 $convert->options = array_merge($convert->options, unserialize($config['convert_db_server']), unserialize($config['convert_db_user']), unserialize($config['convert_options']));
629 }
630
631 // This information should have already been checked once, but do it again for safety
632 if (empty($convert->options) || empty($convert->options['tag']) ||
633 !isset($convert->options['dbms']) ||
634 !isset($convert->options['dbhost']) ||
635 !isset($convert->options['dbport']) ||
636 !isset($convert->options['dbuser']) ||
637 !isset($convert->options['dbpasswd']) ||
638 !isset($convert->options['dbname']) ||
639 !isset($convert->options['table_prefix']))
640 {
641 $this->p_master->error($user->lang['NO_CONVERT_SPECIFIED'], __LINE__, __FILE__);
642 }
643
644 // Make some short variables accessible, for easier referencing
645 $convert->convertor_tag = basename($convert->options['tag']);
646 $convert->src_dbms = $convert->options['dbms'];
647 $convert->src_dbhost = $convert->options['dbhost'];
648 $convert->src_dbport = $convert->options['dbport'];
649 $convert->src_dbuser = $convert->options['dbuser'];
650 $convert->src_dbpasswd = $convert->options['dbpasswd'];
651 $convert->src_dbname = $convert->options['dbname'];
652 $convert->src_table_prefix = $convert->options['table_prefix'];
653
654 // initiate database connection to old db if old and new db differ
655 global $src_db, $same_db;
656 $src_db = $same_db = null;
657 if ($convert->src_dbms != $dbms || $convert->src_dbhost != $dbhost || $convert->src_dbport != $dbport || $convert->src_dbname != $dbname || $convert->src_dbuser != $dbuser)
658 {
659 if ($convert->src_dbms != $dbms)
660 {
661 require(PHPBB_ROOT_PATH . 'includes/db/' . $convert->src_dbms . '.' . PHP_EXT);
662 }
663 $sql_db = 'dbal_' . $convert->src_dbms;
664 $src_db = new $sql_db();
665 $src_db->sql_connect($convert->src_dbhost, $convert->src_dbuser, htmlspecialchars_decode($convert->src_dbpasswd), $convert->src_dbname, $convert->src_dbport, false, true);
666 $same_db = false;
667 }
668 else
669 {
670 $src_db = $db;
671 $same_db = true;
672 }
673
674 $convert->mysql_convert = false;
675 switch ($src_db->sql_layer)
676 {
677 case 'sqlite':
678 case 'firebird':
679 $convert->src_truncate_statement = 'DELETE FROM ';
680 break;
681
682 // Thanks MySQL, for silently converting...
683 case 'mysql':
684 if (version_compare($src_db->sql_server_info(true), '4.1.3', '>='))
685 {
686 $convert->mysql_convert = true;
687 }
688 $convert->src_truncate_statement = 'TRUNCATE TABLE ';
689 break;
690
691 case 'mysqli':
692 $convert->mysql_convert = true;
693 $convert->src_truncate_statement = 'TRUNCATE TABLE ';
694 break;
695
696 default:
697 $convert->src_truncate_statement = 'TRUNCATE TABLE ';
698 break;
699 }
700
701 if ($convert->mysql_convert && !$same_db)
702 {
703 $src_db->sql_query("SET NAMES 'binary'");
704 }
705
706 if ($db->truncate)
707 {
708 $convert->truncate_statement = 'TRUNCATE TABLE ';
709 }
710 else
711 {
712 $convert->truncate_statement = 'DELETE FROM ';
713 }
714
715 $get_info = false;
716
717 // check security implications of direct inclusion
718 if (!file_exists('./convertors/convert_' . $convert->convertor_tag . '.' . PHP_EXT))
719 {
720 $this->p_master->error($user->lang['CONVERT_NOT_EXIST'], __LINE__, __FILE__);
721 }
722
723 if (file_exists('./convertors/functions_' . $convert->convertor_tag . '.' . PHP_EXT))
724 {
725 include('./convertors/functions_' . $convert->convertor_tag . '.' . PHP_EXT);
726 }
727
728 $get_info = true;
729 include('./convertors/convert_' . $convert->convertor_tag . '.' . PHP_EXT);
730
731 // Map some variables...
732 $convert->convertor_data = $convertor_data;
733 $convert->tables = $tables;
734 $convert->config_schema = $config_schema;
735
736 // Now include the real data
737 $get_info = false;
738 include('./convertors/convert_' . $convert->convertor_tag . '.' . PHP_EXT);
739
740 $convert->convertor_data = $convertor_data;
741 $convert->tables = $tables;
742 $convert->config_schema = $config_schema;
743 $convert->convertor = $convertor;
744
745 // The test_file is a file that should be present in the location of the old board.
746 if (!file_exists($convert->options['forum_path'] . '/' . $test_file))
747 {
748 $this->p_master->error(sprintf($user->lang['COULD_NOT_FIND_PATH'], $convert->options['forum_path']), __LINE__, __FILE__);
749 }
750
751 $search_type = basename(trim($config['search_type']));
752
753 // For conversions we are a bit less strict and set to a search backend we know exist...
754 if (!file_exists(PHPBB_ROOT_PATH . 'includes/search/' . $search_type . '.' . PHP_EXT))
755 {
756 $search_type = 'fulltext_native';
757 set_config('search_type', $search_type);
758 }
759
760 if (!file_exists(PHPBB_ROOT_PATH . 'includes/search/' . $search_type . '.' . PHP_EXT))
761 {
762 trigger_error('NO_SUCH_SEARCH_MODULE');
763 }
764
765 require(PHPBB_ROOT_PATH . 'includes/search/' . $search_type . '.' . PHP_EXT);
766
767 $error = false;
768 $convert->fulltext_search = new $search_type($error);
769
770 if ($error)
771 {
772 trigger_error($error);
773 }
774
775 include(PHPBB_ROOT_PATH . 'includes/message_parser.' . PHP_EXT);
776 $message_parser = new parse_message();
777
778 $jump = request_var('jump', 0);
779 $final_jump = request_var('final_jump', 0);
780 $sync_batch = request_var('sync_batch', -1);
781 $last_statement = request_var('last', 0);
782
783 // We are running sync...
784 if ($sync_batch >= 0)
785 {
786 $this->sync_forums($sync_batch);
787 return;
788 }
789
790 if ($jump)
791 {
792 $this->jump($jump, $last_statement);
793 return;
794 }
795
796 if ($final_jump)
797 {
798 $this->final_jump($final_jump);
799 return;
800 }
801
802 $current_table = request_var('current_table', 0);
803 $old_current_table = min(-1, $current_table - 1);
804 $skip_rows = request_var('skip_rows', 0);
805
806 if (!$current_table && !$skip_rows)
807 {
808 if (!request::variable('confirm', false))
809 {
810 // If avatars / ranks / smilies folders are specified make sure they are writable
811 $bad_folders = array();
812
813 $local_paths = array(
814 'avatar_path' => path($config['avatar_path']),
815 'avatar_gallery_path' => path($config['avatar_gallery_path']),
816 'icons_path' => path($config['icons_path']),
817 'ranks_path' => path($config['ranks_path']),
818 'smilies_path' => path($config['smilies_path'])
819 );
820
821 foreach ($local_paths as $folder => $local_path)
822 {
823 if (isset($convert->convertor[$folder]))
824 {
825 if (empty($convert->convertor['test_file']))
826 {
827 // test_file is mandantory at the moment so this should never be reached, but just in case...
828 $this->p_master->error($user->lang['DEV_NO_TEST_FILE'], __LINE__, __FILE__);
829 }
830
831 if (!$local_path || !@is_writable(PHPBB_ROOT_PATH . $local_path))
832 {
833 if (!$local_path)
834 {
835 $bad_folders[] = sprintf($user->lang['CONFIG_PHPBB_EMPTY'], $folder);
836 }
837 else
838 {
839 $bad_folders[] = $local_path;
840 }
841 }
842 }
843 }
844
845 if (sizeof($bad_folders))
846 {
847 $msg = (sizeof($bad_folders) == 1) ? $user->lang['MAKE_FOLDER_WRITABLE'] : $user->lang['MAKE_FOLDERS_WRITABLE'];
848 sort($bad_folders);
849 $this->p_master->error(sprintf($msg, implode('<br />', $bad_folders)), __LINE__, __FILE__, true);
850
851 $template->assign_vars(array(
852 'L_SUBMIT' => $user->lang['INSTALL_TEST'],
853 'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&amp;sub=in_progress&amp;tag={$convert->convertor_tag}&amp;language=$language",
854 ));
855 return;
856 }
857
858 // Grab all the tables used in convertor
859 $missing_tables = $tables_list = $aliases = array();
860
861 foreach ($convert->convertor['schema'] as $schema)
862 {
863 // Skip those not used (because of addons/plugins not detected)
864 if (!$schema['target'])
865 {
866 continue;
867 }
868
869 foreach ($schema as $key => $val)
870 {
871 // we're dealing with an array like:
872 // array('forum_status', 'forums.forum_status', 'is_item_locked')
873 if (is_int($key) && !empty($val[1]))
874 {
875 $temp_data = $val[1];
876 if (!is_array($temp_data))
877 {
878 $temp_data = array($temp_data);
879 }
880
881 foreach ($temp_data as $val)
882 {
883 if (preg_match('/([a-z0-9_]+)\.([a-z0-9_]+)\)* ?A?S? ?([a-z0-9_]*?)\.?([a-z0-9_]*)$/i', $val, $m))
884 {
885 $table = $convert->src_table_prefix . $m[1];
886 $tables_list[$table] = $table;
887
888 if (!empty($m[3]))
889 {
890 $aliases[] = $convert->src_table_prefix . $m[3];
891 }
892 }
893 }
894 }
895 // 'left_join' => 'topics LEFT JOIN vote_desc ON topics.topic_id = vote_desc.topic_id AND topics.topic_vote = 1'
896 else if ($key == 'left_join')
897 {
898 // Convert the value if it wasn't an array already.
899 if (!is_array($val))
900 {
901 $val = array($val);
902 }
903
904 for ($j = 0; $j < sizeof($val); ++$j)
905 {
906 if (preg_match('/LEFT JOIN ([a-z0-9_]+) AS ([a-z0-9_]+)/i', $val[$j], $m))
907 {
908 $table = $convert->src_table_prefix . $m[1];
909 $tables_list[$table] = $table;
910
911 if (!empty($m[2]))
912 {
913 $aliases[] = $convert->src_table_prefix . $m[2];
914 }
915 }
916 }
917 }
918 }
919 }
920
921 // Remove aliased tables from $tables_list
922 foreach ($aliases as $alias)
923 {
924 unset($tables_list[$alias]);
925 }
926
927 // Check if the tables that we need exist
928 $src_db->sql_return_on_error(true);
929 foreach ($tables_list as $table => $null)
930 {
931 $sql = 'SELECT 1 FROM ' . $table;
932 $_result = $src_db->sql_query_limit($sql, 1);
933
934 if (!$_result)
935 {
936 $missing_tables[] = $table;
937 }
938 $src_db->sql_freeresult($_result);
939 }
940 $src_db->sql_return_on_error(false);
941
942 // Throw an error if some tables are missing
943 // We used to do some guessing here, but since we have a suggestion of possible values earlier, I don't see it adding anything here to do it again
944
945 if (sizeof($missing_tables) == sizeof($tables_list))
946 {
947 $this->p_master->error($user->lang['NO_TABLES_FOUND'] . ' ' . $user->lang['CHECK_TABLE_PREFIX'], __LINE__, __FILE__);
948 }
949 else if (sizeof($missing_tables))
950 {
951 $this->p_master->error(sprintf($user->lang['TABLES_MISSING'], implode(', ', $missing_tables)) . '<br /><br />' . $user->lang['CHECK_TABLE_PREFIX'], __LINE__, __FILE__);
952 }
953
954 $url = $this->save_convert_progress('&amp;confirm=1');
955 $msg = $user->lang['PRE_CONVERT_COMPLETE'];
956
957 if ($convert->convertor_data['author_notes'])
958 {
959 $msg .= '</p><p>' . sprintf($user->lang['AUTHOR_NOTES'], $convert->convertor_data['author_notes']);
960 }
961
962 $template->assign_vars(array(
963 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
964 'L_MESSAGE' => $msg,
965 'U_ACTION' => $url,
966 ));
967
968 return;
969 } // if (!request::variable('confirm', false))
970
971 $template->assign_block_vars('checks', array(
972 'S_LEGEND' => true,
973 'LEGEND' => $user->lang['STARTING_CONVERT'],
974 ));
975
976 // Convert the config table and load the settings of the old board
977 if (!empty($convert->config_schema))
978 {
979 restore_config($convert->config_schema);
980
981 // Override a couple of config variables for the duration
982 $config['max_quote_depth'] = 0;
983
984 // @todo Need to confirm that max post length in source is <= max post length in destination or there may be interesting formatting issues
985 $config['max_post_chars'] = 0;
986 }
987
988 $template->assign_block_vars('checks', array(
989 'TITLE' => $user->lang['CONFIG_CONVERT'],
990 'RESULT' => $user->lang['DONE'],
991 ));
992
993 // Now process queries and execute functions that have to be executed prior to the conversion
994 if (!empty($convert->convertor['execute_first']))
995 {
996 eval($convert->convertor['execute_first']);
997 }
998
999 if (!empty($convert->convertor['query_first']))
1000 {
1001 if (!is_array($convert->convertor['query_first']))
1002 {
1003 $convert->convertor['query_first'] = array('target', array($convert->convertor['query_first']));
1004 }
1005 else if (!is_array($convert->convertor['query_first'][0]))
1006 {
1007 $convert->convertor['query_first'] = array(array($convert->convertor['query_first'][0], $convert->convertor['query_first'][1]));
1008 }
1009
1010 foreach ($convert->convertor['query_first'] as $query_first)
1011 {
1012 if ($query_first[0] == 'src')
1013 {
1014 if ($convert->mysql_convert && $same_db)
1015 {
1016 $src_db->sql_query("SET NAMES 'binary'");
1017 }
1018
1019 $src_db->sql_query($query_first[1]);
1020
1021 if ($convert->mysql_convert && $same_db)
1022 {
1023 $src_db->sql_query("SET NAMES 'utf8'");
1024 }
1025 }
1026 else
1027 {
1028 $db->sql_query($query_first[1]);
1029 }
1030 }
1031 }
1032
1033 $template->assign_block_vars('checks', array(
1034 'TITLE' => $user->lang['PREPROCESS_STEP'],
1035 'RESULT' => $user->lang['DONE'],
1036 ));
1037 } // if (!$current_table && !$skip_rows)
1038
1039 $template->assign_block_vars('checks', array(
1040 'S_LEGEND' => true,
1041 'LEGEND' => $user->lang['FILLING_TABLES'],
1042 ));
1043
1044 // This loop takes one target table and processes it
1045 while ($current_table < sizeof($convert->convertor['schema']))
1046 {
1047 $schema = $convert->convertor['schema'][$current_table];
1048
1049 // The target table isn't set, this can be because a module (for example the attachement mod) is taking care of this.
1050 if (empty($schema['target']))
1051 {
1052 $current_table++;
1053 continue;
1054 }
1055
1056 $template->assign_block_vars('checks', array(
1057 'TITLE' => sprintf($user->lang['FILLING_TABLE'], $schema['target']),
1058 ));
1059
1060 // This is only the case when we first start working on the tables.
1061 if (!$skip_rows)
1062 {
1063 // process execute_first and query_first for this table...
1064 if (!empty($schema['execute_first']))
1065 {
1066 eval($schema['execute_first']);
1067 }
1068
1069 if (!empty($schema['query_first']))
1070 {
1071 if (!is_array($schema['query_first']))
1072 {
1073 $schema['query_first'] = array('target', array($schema['query_first']));
1074 }
1075 else if (!is_array($schema['query_first'][0]))
1076 {
1077 $schema['query_first'] = array(array($schema['query_first'][0], $schema['query_first'][1]));
1078 }
1079
1080 foreach ($schema['query_first'] as $query_first)
1081 {
1082 if ($query_first[0] == 'src')
1083 {
1084 if ($convert->mysql_convert && $same_db)
1085 {
1086 $src_db->sql_query("SET NAMES 'binary'");
1087 }
1088 $src_db->sql_query($query_first[1]);
1089 if ($convert->mysql_convert && $same_db)
1090 {
1091 $src_db->sql_query("SET NAMES 'utf8'");
1092 }
1093 }
1094 else
1095 {
1096 $db->sql_query($query_first[1]);
1097 }
1098 }
1099 }
1100
1101 if (!empty($schema['autoincrement']))
1102 {
1103 switch ($db->dbms_type)
1104 {
1105 case 'postgres':
1106 $db->sql_query("SELECT SETVAL('" . $schema['target'] . "_seq',(select case when max(" . $schema['autoincrement'] . ")>0 then max(" . $schema['autoincrement'] . ")+1 else 1 end from " . $schema['target'] . '));');
1107 break;
1108
1109 case 'oracle':
1110 $result = $db->sql_query('SELECT MAX(' . $schema['autoincrement'] . ') as max_id FROM ' . $schema['target']);
1111 $row = $db->sql_fetchrow($result);
1112 $db->sql_freeresult($result);
1113
1114 $largest_id = (int) $row['max_id'];
1115
1116 if ($largest_id)
1117 {
1118 $db->sql_query('DROP SEQUENCE ' . $schema['target'] . '_seq');
1119 $db->sql_query('CREATE SEQUENCE ' . $schema['target'] . '_seq START WITH ' . ($largest_id + 1));
1120 }
1121 break;
1122 }
1123 }
1124 }
1125
1126 // Process execute_always for this table
1127 // This is for code which needs to be executed on every pass of this table if
1128 // it gets split because of time restrictions
1129 if (!empty($schema['execute_always']))
1130 {
1131 eval($schema['execute_always']);
1132 }
1133
1134 //
1135 // Set up some variables
1136 //
1137 // $waiting_rows holds rows for multirows insertion (MySQL only)
1138 // $src_tables holds unique tables with aliases to select from
1139 // $src_fields will quickly refer source fields (or aliases) corresponding to the current index
1140 // $select_fields holds the names of the fields to retrieve
1141 //
1142
1143 $sql_data = array(
1144 'source_fields' => array(),
1145 'target_fields' => array(),
1146 'source_tables' => array(),
1147 'select_fields' => array(),
1148 );
1149
1150 // This statement is building the keys for later insertion.
1151 $insert_query = $this->build_insert_query($schema, $sql_data, $current_table);
1152
1153 // If no source table is affected, we skip the table
1154 if (empty($sql_data['source_tables']))
1155 {
1156 $skip_rows = 0;
1157 $current_table++;
1158 continue;
1159 }
1160
1161 $distinct = (!empty($schema['distinct'])) ? 'DISTINCT ' : '';
1162
1163 $sql = 'SELECT ' . $distinct . implode(', ', $sql_data['select_fields']) . " \nFROM " . implode(', ', $sql_data['source_tables']);
1164
1165 // Where
1166 $sql .= (!empty($schema['where'])) ? "\nWHERE (" . $schema['where'] . ')' : '';
1167
1168 // Group By
1169 if (!empty($schema['group_by']))
1170 {
1171 $schema['group_by'] = array($schema['group_by']);
1172 foreach ($sql_data['select_fields'] as $select)
1173 {
1174 $alias = strpos(strtolower($select), ' as ');
1175 $select = ($alias) ? substr($select, 0, $alias) : $select;
1176 if (!in_array($select, $schema['group_by']))
1177 {
1178 $schema['group_by'][] = $select;
1179 }
1180 }
1181 }
1182 $sql .= (!empty($schema['group_by'])) ? "\nGROUP BY " . implode(', ', $schema['group_by']) : '';
1183
1184 // Having
1185 $sql .= (!empty($schema['having'])) ? "\nHAVING " . $schema['having'] : '';
1186
1187 // Order By
1188 if (empty($schema['order_by']) && !empty($schema['primary']))
1189 {
1190 $schema['order_by'] = $schema['primary'];
1191 }
1192 $sql .= (!empty($schema['order_by'])) ? "\nORDER BY " . $schema['order_by'] : '';
1193
1194 // Counting basically holds the amount of rows processed.
1195 $counting = -1;
1196 $batch_time = 0;
1197
1198 while ($counting === -1 || ($counting >= $convert->batch_size && still_on_time()))
1199 {
1200 $old_current_table = $current_table;
1201
1202 $rows = '';
1203 $waiting_rows = array();
1204
1205 if (!empty($batch_time))
1206 {
1207 $mtime = explode(' ', microtime());
1208 $mtime = $mtime[0] + $mtime[1];
1209 $rows = ceil($counting/($mtime - $batch_time)) . " rows/s ($counting rows) | ";
1210 }
1211
1212 $template->assign_block_vars('checks', array(
1213 'TITLE' => "skip_rows = $skip_rows",
1214 'RESULT' => $rows . ((defined('DEBUG_EXTRA') && function_exists('memory_get_usage')) ? ceil(memory_get_usage()/1024) . ' ' . $user->lang['KIB'] : ''),
1215 ));
1216
1217 $mtime = explode(' ', microtime());
1218 $batch_time = $mtime[0] + $mtime[1];
1219
1220 if ($convert->mysql_convert && $same_db)
1221 {
1222 $src_db->sql_query("SET NAMES 'binary'");
1223 }
1224
1225 // Take skip rows into account and only fetch batch_size amount of rows
1226 $___result = $src_db->sql_query_limit($sql, $convert->batch_size, $skip_rows);
1227
1228 if ($convert->mysql_convert && $same_db)
1229 {
1230 $src_db->sql_query("SET NAMES 'utf8'");
1231 }
1232
1233 // This loop processes each row
1234 $counting = 0;
1235
1236 $convert->row = $convert_row = array();
1237
1238 if (!empty($schema['autoincrement']))
1239 {
1240 switch ($db->dbms_type)
1241 {
1242 case 'mssql':
1243 $db->sql_query('SET IDENTITY_INSERT ' . $schema['target'] . ' ON');
1244 break;
1245 }
1246 }
1247
1248 // Now handle the rows until time is over or no more rows to process...
1249 while ($counting === 0 || still_on_time())
1250 {
1251 $convert_row = $src_db->sql_fetchrow($___result);
1252
1253 if (!$convert_row)
1254 {
1255 // move to the next batch or table
1256 break;
1257 }
1258
1259 // With this we are able to always save the last state
1260 $convert->row = $convert_row;
1261
1262 // Increment the counting variable, it stores the number of rows we have processed
1263 $counting++;
1264
1265 $insert_values = array();
1266
1267 $sql_flag = $this->process_row($schema, $sql_data, $insert_values);
1268
1269 if ($sql_flag === true)
1270 {
1271 switch ($db->dbms_type)
1272 {
1273 // If MySQL, we'll wait to have num_wait_rows rows to submit at once
1274 case 'mysql':
1275 $waiting_rows[] = '(' . implode(', ', $insert_values) . ')';
1276
1277 if (sizeof($waiting_rows) >= $convert->num_wait_rows)
1278 {
1279 $errored = false;
1280
1281 $db->sql_return_on_error(true);
1282
1283 if (!$db->sql_query($insert_query . implode(', ', $waiting_rows)))
1284 {
1285 $errored = true;
1286 }
1287 $db->sql_return_on_error(false);
1288
1289 if ($errored)
1290 {
1291 $db->sql_return_on_error(true);
1292
1293 // Because it errored out we will try to insert the rows one by one... most of the time this
1294 // is caused by duplicate entries - but we also do not want to miss one...
1295 foreach ($waiting_rows as $waiting_sql)
1296 {
1297 if (!$db->sql_query($insert_query . $waiting_sql))
1298 {
1299 $this->p_master->db_error($user->lang['DB_ERR_INSERT'], htmlspecialchars($insert_query . $waiting_sql) . '<br /><br />' . htmlspecialchars(print_r($db->_sql_error(), true)), __LINE__, __FILE__, true);
1300 }
1301 }
1302
1303 $db->sql_return_on_error(false);
1304 }
1305
1306 $waiting_rows = array();
1307 }
1308
1309 break;
1310
1311 default:
1312 $insert_sql = $insert_query . '(' . implode(', ', $insert_values) . ')';
1313
1314 $db->sql_return_on_error(true);
1315
1316 if (!$db->sql_query($insert_sql))
1317 {
1318 $this->p_master->db_error($user->lang['DB_ERR_INSERT'], htmlspecialchars($insert_sql) . '<br /><br />' . htmlspecialchars(print_r($db->_sql_error(), true)), __LINE__, __FILE__, true);
1319 }
1320 $db->sql_return_on_error(false);
1321
1322 $waiting_rows = array();
1323
1324 break;
1325 }
1326 }
1327
1328 $skip_rows++;
1329 }
1330 $src_db->sql_freeresult($___result);
1331
1332 // We might still have some rows waiting
1333 if (sizeof($waiting_rows))
1334 {
1335 $errored = false;
1336 $db->sql_return_on_error(true);
1337
1338 if (!$db->sql_query($insert_query . implode(', ', $waiting_rows)))
1339 {
1340 $errored = true;
1341 }
1342 $db->sql_return_on_error(false);
1343
1344 if ($errored)
1345 {
1346 $db->sql_return_on_error(true);
1347
1348 // Because it errored out we will try to insert the rows one by one... most of the time this
1349 // is caused by duplicate entries - but we also do not want to miss one...
1350 foreach ($waiting_rows as $waiting_sql)
1351 {
1352 $db->sql_query($insert_query . $waiting_sql);
1353 $this->p_master->db_error($user->lang['DB_ERR_INSERT'], htmlspecialchars($insert_query . $waiting_sql) . '<br /><br />' . htmlspecialchars(print_r($db->_sql_error(), true)), __LINE__, __FILE__, true);
1354 }
1355
1356 $db->sql_return_on_error(false);
1357 }
1358
1359 $waiting_rows = array();
1360 }
1361
1362 if (!empty($schema['autoincrement']))
1363 {
1364 switch ($db->dbms_type)
1365 {
1366 case 'mssql':
1367 $db->sql_query('SET IDENTITY_INSERT ' . $schema['target'] . ' OFF');
1368 break;
1369
1370 case 'postgres':
1371 $db->sql_query("SELECT SETVAL('" . $schema['target'] . "_seq',(select case when max(" . $schema['autoincrement'] . ")>0 then max(" . $schema['autoincrement'] . ")+1 else 1 end from " . $schema['target'] . '));');
1372 break;
1373
1374 case 'oracle':
1375 $result = $db->sql_query('SELECT MAX(' . $schema['autoincrement'] . ') as max_id FROM ' . $schema['target']);
1376 $row = $db->sql_fetchrow($result);
1377 $db->sql_freeresult($result);
1378
1379 $largest_id = (int) $row['max_id'];
1380
1381 if ($largest_id)
1382 {
1383 $db->sql_query('DROP SEQUENCE ' . $schema['target'] . '_seq');
1384 $db->sql_query('CREATE SEQUENCE ' . $schema['target'] . '_seq START WITH ' . ($largest_id + 1));
1385 }
1386 break;
1387 }
1388 }
1389 }
1390
1391 // When we reach this point, either the current table has been processed or we're running out of time.
1392 if (still_on_time() && $counting < $convert->batch_size/* && !defined('DEBUG_EXTRA')*/)
1393 {
1394 $skip_rows = 0;
1395 $current_table++;
1396 }
1397 else
1398 {/*
1399 if (still_on_time() && $counting < $convert->batch_size)
1400 {
1401 $skip_rows = 0;
1402 $current_table++;
1403 }*/
1404
1405 // Looks like we ran out of time.
1406 $url = $this->save_convert_progress('&amp;current_table=' . $current_table . '&amp;skip_rows=' . $skip_rows);
1407
1408 $current_table++;
1409 // $percentage = ($skip_rows == 0) ? 0 : floor(100 / ($total_rows / $skip_rows));
1410
1411 $msg = sprintf($user->lang['STEP_PERCENT_COMPLETED'], $current_table, sizeof($convert->convertor['schema']));
1412
1413 $template->assign_vars(array(
1414 'L_MESSAGE' => $msg,
1415 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
1416 'U_ACTION' => $url,
1417 ));
1418
1419 $this->meta_refresh($url);
1420 return;
1421 }
1422 }
1423
1424 // Process execute_last then we'll be done
1425 $url = $this->save_convert_progress('&amp;jump=1');
1426
1427 $template->assign_vars(array(
1428 'L_SUBMIT' => $user->lang['FINAL_STEP'],
1429 'U_ACTION' => $url,
1430 ));
1431
1432 $this->meta_refresh($url);
1433 return;
1434 }
1435
1436 /**
1437 * Sync function being executed at the middle, some functions need to be executed after a successful sync.
1438 */
1439 function sync_forums($sync_batch)
1440 {
1441 global $template, $user, $db, $config, $cache;
1442 global $convert;
1443
1444 $template->assign_block_vars('checks', array(
1445 'S_LEGEND' => true,
1446 'LEGEND' => $user->lang['SYNC_TOPICS'],
1447 ));
1448
1449 $batch_size = $convert->batch_size;
1450
1451 $sql = 'SELECT MIN(topic_id) as min_value, MAX(topic_id) AS max_value
1452 FROM ' . TOPICS_TABLE;
1453 $result = $db->sql_query($sql);
1454 $row = $db->sql_fetchrow($result);
1455 $db->sql_freeresult($result);
1456
1457 // Set values of minimum/maximum primary value for this table.
1458 $primary_min = $row['min_value'];
1459 $primary_max = $row['max_value'];
1460
1461 if ($sync_batch == 0)
1462 {
1463 $sync_batch = (int) $primary_min;
1464 }
1465
1466 if ($sync_batch == 0)
1467 {
1468 $sync_batch = 1;
1469 }
1470
1471 // Fetch a batch of rows, process and insert them.
1472 while ($sync_batch <= $primary_max && still_on_time())
1473 {
1474 $end = ($sync_batch + $batch_size - 1);
1475
1476 // Sync all topics in batch mode...
1477 sync('topic_approved', 'range', 'topic_id BETWEEN ' . $sync_batch . ' AND ' . $end, true, false);
1478 sync('topic', 'range', 'topic_id BETWEEN ' . $sync_batch . ' AND ' . $end, true, true);
1479
1480 $template->assign_block_vars('checks', array(
1481 'TITLE' => sprintf($user->lang['SYNC_TOPIC_ID'], $sync_batch, ($sync_batch + $batch_size)) . ((defined('DEBUG_EXTRA') && function_exists('memory_get_usage')) ? ' [' . ceil(memory_get_usage()/1024) . ' ' . $user->lang['KIB'] . ']' : ''),
1482 'RESULT' => $user->lang['DONE'],
1483 ));
1484
1485 $sync_batch += $batch_size;
1486 }
1487
1488 if ($sync_batch >= $primary_max)
1489 {
1490 $url = $this->save_convert_progress('&amp;final_jump=1');
1491
1492 $template->assign_vars(array(
1493 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
1494 'U_ACTION' => $url,
1495 ));
1496
1497 $this->meta_refresh($url);
1498 return;
1499 }
1500 else
1501 {
1502 $sync_batch--;
1503 }
1504
1505 $url = $this->save_convert_progress('&amp;sync_batch=' . $sync_batch);
1506
1507 $template->assign_vars(array(
1508 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
1509 'U_ACTION' => $url,
1510 ));
1511
1512 $this->meta_refresh($url);
1513 return;
1514 }
1515
1516 /**
1517 * Save the convertor status
1518 */
1519 function save_convert_progress($step)
1520 {
1521 global $convert, $language;
1522
1523 // Save convertor Status
1524 set_config('convert_progress', serialize(array(
1525 'step' => $step,
1526 'table_prefix' => $convert->src_table_prefix,
1527 'tag' => $convert->convertor_tag,
1528 )), true);
1529
1530 set_config('convert_db_server', serialize(array(
1531 'dbms' => $convert->src_dbms,
1532 'dbhost' => $convert->src_dbhost,
1533 'dbport' => $convert->src_dbport,
1534 'dbname' => $convert->src_dbname,
1535 )), true);
1536
1537 set_config('convert_db_user', serialize(array(
1538 'dbuser' => $convert->src_dbuser,
1539 'dbpasswd' => $convert->src_dbpasswd,
1540 )), true);
1541
1542 return $this->p_master->module_url . "?mode={$this->mode}&amp;sub=in_progress&amp;tag={$convert->convertor_tag}$step&amp;language=$language";
1543 }
1544
1545 /**
1546 * Finish conversion, the last function to be called.
1547 */
1548 function finish_conversion()
1549 {
1550 global $db, $convert, $config, $language, $user, $template;
1551
1552 $db->sql_query('DELETE FROM ' . CONFIG_TABLE . "
1553 WHERE config_name = 'convert_progress'
1554 OR config_name = 'convert_options'
1555 OR config_name = 'convert_db_server'
1556 OR config_name = 'convert_db_user'");
1557 $db->sql_query('DELETE FROM ' . SESSIONS_TABLE);
1558
1559 @unlink(PHPBB_ROOT_PATH . 'cache/data_global.php');
1560 cache_moderators();
1561
1562 // And finally, add a note to the log
1563 add_log('admin', 'LOG_INSTALL_CONVERTED', $convert->convertor_data['forum_name'], $config['version']);
1564
1565 $url = $this->p_master->module_url . "?mode={$this->mode}&amp;sub=final&amp;language=$language";
1566
1567 $template->assign_vars(array(
1568 'L_SUBMIT' => $user->lang['FINAL_STEP'],
1569 'U_ACTION' => $url,
1570 ));
1571
1572 $this->meta_refresh($url);
1573 return;
1574 }
1575
1576 /**
1577 * This function marks the steps after syncing
1578 */
1579 function final_jump($final_jump)
1580 {
1581 global $template, $user, $src_db, $same_db, $db, $config, $cache;
1582 global $convert;
1583
1584 $template->assign_block_vars('checks', array(
1585 'S_LEGEND' => true,
1586 'LEGEND' => $user->lang['PROCESS_LAST'],
1587 ));
1588
1589 if ($final_jump == 1)
1590 {
1591 $db->sql_return_on_error(true);
1592
1593 update_topics_posted();
1594
1595 $template->assign_block_vars('checks', array(
1596 'TITLE' => $user->lang['UPDATE_TOPICS_POSTED'],
1597 'RESULT' => $user->lang['DONE'],
1598 ));
1599
1600 if ($db->sql_error_triggered)
1601 {
1602 $template->assign_vars(array(
1603 'S_ERROR_BOX' => true,
1604 'ERROR_TITLE' => $user->lang['UPDATE_TOPICS_POSTED'],
1605 'ERROR_MSG' => $user->lang['UPDATE_TOPICS_POSTED_ERR'],
1606 ));
1607 }
1608 $db->sql_return_on_error(false);
1609
1610 $this->finish_conversion();
1611 return;
1612 }
1613 }
1614
1615 /**
1616 * This function marks the steps before syncing (jump=1)
1617 */
1618 function jump($jump, $last_statement)
1619 {
1620 global $template, $user, $src_db, $same_db, $db, $config, $cache;
1621 global $convert;
1622
1623 $template->assign_block_vars('checks', array(
1624 'S_LEGEND' => true,
1625 'LEGEND' => $user->lang['PROCESS_LAST'],
1626 ));
1627
1628 if ($jump == 1)
1629 {
1630 // Execute 'last' statements/queries
1631 if (!empty($convert->convertor['execute_last']))
1632 {
1633 if (!is_array($convert->convertor['execute_last']))
1634 {
1635 eval($convert->convertor['execute_last']);
1636 }
1637 else
1638 {
1639 while ($last_statement < sizeof($convert->convertor['execute_last']))
1640 {
1641 eval($convert->convertor['execute_last'][$last_statement]);
1642
1643 $template->assign_block_vars('checks', array(
1644 'TITLE' => $convert->convertor['execute_last'][$last_statement],
1645 'RESULT' => $user->lang['DONE'],
1646 ));
1647
1648 $last_statement++;
1649 $url = $this->save_convert_progress('&amp;jump=1&amp;last=' . $last_statement);
1650
1651 $percentage = ($last_statement == 0) ? 0 : floor(100 / (sizeof($convert->convertor['execute_last']) / $last_statement));
1652 $msg = sprintf($user->lang['STEP_PERCENT_COMPLETED'], $last_statement, sizeof($convert->convertor['execute_last']), $percentage);
1653
1654 $template->assign_vars(array(
1655 'L_SUBMIT' => $user->lang['CONTINUE_LAST'],
1656 'L_MESSAGE' => $msg,
1657 'U_ACTION' => $url,
1658 ));
1659
1660 $this->meta_refresh($url);
1661 return;
1662 }
1663 }
1664 }
1665
1666 if (!empty($convert->convertor['query_last']))
1667 {
1668 if (!is_array($convert->convertor['query_last']))
1669 {
1670 $convert->convertor['query_last'] = array('target', array($convert->convertor['query_last']));
1671 }
1672 else if (!is_array($convert->convertor['query_last'][0]))
1673 {
1674 $convert->convertor['query_last'] = array(array($convert->convertor['query_last'][0], $convert->convertor['query_last'][1]));
1675 }
1676
1677 foreach ($convert->convertor['query_last'] as $query_last)
1678 {
1679 if ($query_last[0] == 'src')
1680 {
1681 if ($convert->mysql_convert && $same_db)
1682 {
1683 $src_db->sql_query("SET NAMES 'binary'");
1684 }
1685
1686 $src_db->sql_query($query_last[1]);
1687
1688 if ($convert->mysql_convert && $same_db)
1689 {
1690 $src_db->sql_query("SET NAMES 'utf8'");
1691 }
1692 }
1693 else
1694 {
1695 $db->sql_query($query_last[1]);
1696 }
1697 }
1698 }
1699
1700 // Sanity check
1701 $db->sql_return_on_error(false);
1702 $src_db->sql_return_on_error(false);
1703
1704 fix_empty_primary_groups();
1705
1706 if (!isset($config['board_startdate']))
1707 {
1708 $sql = 'SELECT MIN(user_regdate) AS board_startdate
1709 FROM ' . USERS_TABLE;
1710 $result = $db->sql_query($sql);
1711 $row = $db->sql_fetchrow($result);
1712 $db->sql_freeresult($result);
1713
1714 if (($row['board_startdate'] < $config['board_startdate'] && $row['board_startdate'] > 0) || !isset($config['board_startdate']))
1715 {
1716 set_config('board_startdate', $row['board_startdate']);
1717 $db->sql_query('UPDATE ' . USERS_TABLE . ' SET user_regdate = ' . $row['board_startdate'] . ' WHERE user_id = ' . ANONYMOUS);
1718 }
1719 }
1720
1721 update_dynamic_config();
1722
1723 $template->assign_block_vars('checks', array(
1724 'TITLE' => $user->lang['CLEAN_VERIFY'],
1725 'RESULT' => $user->lang['DONE'],
1726 ));
1727
1728 $url = $this->save_convert_progress('&amp;jump=2');
1729
1730 $template->assign_vars(array(
1731 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
1732 'U_ACTION' => $url,
1733 ));
1734
1735 $this->meta_refresh($url);
1736 return;
1737 }
1738
1739 if ($jump == 2)
1740 {
1741 $db->sql_query('UPDATE ' . USERS_TABLE . " SET user_permissions = ''");
1742
1743 // TODO: sync() is likely going to bomb out on forums with a considerable amount of topics.
1744 // TODO: the sync function is able to handle FROM-TO values, we should use them here (batch processing)
1745 sync('forum', '', '', false, true);
1746 $cache->destroy('sql', FORUMS_TABLE);
1747
1748 $template->assign_block_vars('checks', array(
1749 'TITLE' => $user->lang['SYNC_FORUMS'],
1750 'RESULT' => $user->lang['DONE'],
1751 ));
1752
1753 // Continue with synchronizing the forums...
1754 $url = $this->save_convert_progress('&amp;sync_batch=0');
1755
1756 $template->assign_vars(array(
1757 'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],
1758 'U_ACTION' => $url,
1759 ));
1760
1761 $this->meta_refresh($url);
1762 return;
1763 }
1764 }
1765
1766 function build_insert_query(&$schema, &$sql_data, $current_table)
1767 {
1768 global $db, $user;
1769 global $convert;
1770
1771 // Can we use IGNORE with this DBMS?
1772 $sql_ignore = ($db->dbms_type === 'mysql' && !defined('DEBUG_EXTRA')) ? 'IGNORE ' : '';
1773 $insert_query = 'INSERT ' . $sql_ignore . 'INTO ' . $schema['target'] . ' (';
1774
1775 $aliases = array();
1776
1777 $sql_data = array(
1778 'source_fields' => array(),
1779 'target_fields' => array(),
1780 'source_tables' => array(),
1781 'select_fields' => array(),
1782 );
1783
1784 foreach ($schema as $key => $val)
1785 {
1786 // Example: array('group_name', 'extension_groups.group_name', 'htmlspecialchars'),
1787 if (is_int($key))
1788 {
1789 if (!empty($val[0]))
1790 {
1791 // Target fields
1792 $sql_data['target_fields'][$val[0]] = $key;
1793 $insert_query .= $val[0] . ', ';
1794 }
1795
1796 if (!is_array($val[1]))
1797 {
1798 $val[1] = array($val[1]);
1799 }
1800
1801 foreach ($val[1] as $valkey => $value_1)
1802 {
1803 // This should cover about any case:
1804 //
1805 // table.field => SELECT table.field FROM table
1806 // table.field AS alias => SELECT table.field AS alias FROM table
1807 // table.field AS table2.alias => SELECT table2.field AS alias FROM table table2
1808 // table.field AS table2.field => SELECT table2.field FROM table table2
1809 //
1810 if (preg_match('/^([a-z0-9_]+)\.([a-z0-9_]+)( +AS +(([a-z0-9_]+?)\.)?([a-z0-9_]+))?$/i', $value_1, $m))
1811 {
1812 // There is 'AS ...' in the field names
1813 if (!empty($m[3]))
1814 {
1815 $value_1 = ($m[2] == $m[6]) ? $m[1] . '.' . $m[2] : $m[1] . '.' . $m[2] . ' AS ' . $m[6];
1816
1817 // Table alias: store it then replace the source table with it
1818 if (!empty($m[5]) && $m[5] != $m[1])
1819 {
1820 $aliases[$m[5]] = $m[1];
1821 $value_1 = str_replace($m[1] . '.' . $m[2], $m[5] . '.' . $m[2], $value_1);
1822 }
1823 }
1824 else
1825 {
1826 // No table alias
1827 $sql_data['source_tables'][$m[1]] = (empty($convert->src_table_prefix)) ? $m[1] : $convert->src_table_prefix . $m[1] . ' ' . $m[1];
1828 }
1829
1830 $sql_data['select_fields'][$value_1] = $value_1;
1831 $sql_data['source_fields'][$key][$valkey] = (!empty($m[6])) ? $m[6] : $m[2];
1832 }
1833 }
1834 }
1835 else if ($key == 'where' || $key == 'group_by' || $key == 'order_by' || $key == 'having')
1836 {
1837 if (@preg_match_all('/([a-z0-9_]+)\.([a-z0-9_]+)/i', $val, $m))
1838 {
1839 foreach ($m[1] as $value)
1840 {
1841 $sql_data['source_tables'][$value] = (empty($convert->src_table_prefix)) ? $value : $convert->src_table_prefix . $value . ' ' . $value;
1842 }
1843 }
1844 }
1845 }
1846
1847 // Add the aliases to the list of tables
1848 foreach ($aliases as $alias => $table)
1849 {
1850 $sql_data['source_tables'][$alias] = $convert->src_table_prefix . $table . ' ' . $alias;
1851 }
1852
1853 // 'left_join' => 'forums LEFT JOIN forum_prune ON forums.forum_id = forum_prune.forum_id',
1854 if (!empty($schema['left_join']))
1855 {
1856 if (!is_array($schema['left_join']))
1857 {
1858 $schema['left_join'] = array($schema['left_join']);
1859 }
1860
1861 foreach ($schema['left_join'] as $left_join)
1862 {
1863 // This won't handle concatened LEFT JOINs
1864 if (!preg_match('/([a-z0-9_]+) LEFT JOIN ([a-z0-9_]+) A?S? ?([a-z0-9_]*?) ?(ON|USING)(.*)/i', $left_join, $m))
1865 {
1866 $this->p_master->error(sprintf($user->lang['NOT_UNDERSTAND'], 'LEFT JOIN', $left_join, $current_table, $schema['target']), __LINE__, __FILE__);
1867 }
1868
1869 if (!empty($aliases[$m[2]]))
1870 {
1871 if (!empty($m[3]))
1872 {
1873 $this->p_master->error(sprintf($user->lang['NAMING_CONFLICT'], $m[2], $m[3], $schema['left_join']), __LINE__, __FILE__);
1874 }
1875
1876 $m[2] = $aliases[$m[2]];
1877 $m[3] = $m[2];
1878 }
1879
1880 $right_table = $convert->src_table_prefix . $m[2];
1881 if (!empty($m[3]))
1882 {
1883 unset($sql_data['source_tables'][$m[3]]);
1884 }
1885 else if ($m[2] != $m[1])
1886 {
1887 unset($sql_data['source_tables'][$m[2]]);
1888 }
1889
1890 if (strpos($sql_data['source_tables'][$m[1]], "\nLEFT JOIN") !== false)
1891 {
1892 $sql_data['source_tables'][$m[1]] = '(' . $sql_data['source_tables'][$m[1]] . ")\nLEFT JOIN $right_table";
1893 }
1894 else
1895 {
1896 $sql_data['source_tables'][$m[1]] .= "\nLEFT JOIN $right_table";
1897 }
1898
1899 if (!empty($m[3]))
1900 {
1901 unset($sql_data['source_tables'][$m[3]]);
1902 $sql_data['source_tables'][$m[1]] .= ' AS ' . $m[3];
1903 }
1904 else if (!empty($convert->src_table_prefix))
1905 {
1906 $sql_data['source_tables'][$m[1]] .= ' AS ' . $m[2];
1907 }
1908 $sql_data['source_tables'][$m[1]] .= ' ' . $m[4] . $m[5];
1909 }
1910 }
1911
1912 // Remove ", " from the end of the insert query
1913 $insert_query = substr($insert_query, 0, -2) . ') VALUES ';
1914
1915 return $insert_query;
1916 }
1917
1918 /**
1919 * Function for processing the currently handled row
1920 */
1921 function process_row(&$schema, &$sql_data, &$insert_values)
1922 {
1923 global $template, $user, $db, $lang, $config, $cache;
1924 global $convert, $convert_row;
1925
1926 $sql_flag = false;
1927
1928 foreach ($schema as $key => $fields)
1929 {
1930 // We are only interested in the lines with:
1931 // array('comment', 'attachments_desc.comment', 'htmlspecialchars'),
1932 if (is_int($key))
1933 {
1934 if (!is_array($fields[1]))
1935 {
1936 $fields[1] = array($fields[1]);
1937 }
1938
1939 $firstkey_set = false;
1940 $firstkey = 0;
1941
1942 foreach ($fields[1] as $inner_key => $inner_value)
1943 {
1944 if (!$firstkey_set)
1945 {
1946 $firstkey = $inner_key;
1947 $firstkey_set = true;
1948 }
1949
1950 $src_field = isset($sql_data['source_fields'][$key][$inner_key]) ? $sql_data['source_fields'][$key][$inner_key] : '';
1951
1952 if (!empty($src_field))
1953 {
1954 $fields[1][$inner_key] = $convert->row[$src_field];
1955 }
1956 }
1957
1958 if (!empty($fields[0]))
1959 {
1960 // We have a target field, if we haven't set $sql_flag yet it will be set to TRUE.
1961 // If a function has already set it to FALSE it won't change it.
1962 if ($sql_flag === false)
1963 {
1964 $sql_flag = true;
1965 }
1966
1967 // No function assigned?
1968 if (empty($fields[2]))
1969 {
1970 $value = $fields[1][$firstkey];
1971 }
1972 else if (is_array($fields[2]))
1973 {
1974 // Execute complex function/eval/typecast
1975 $value = $fields[1];
1976
1977 foreach ($fields[2] as $type => $execution)
1978 {
1979 if (strpos($type, 'typecast') === 0)
1980 {
1981 if (!is_array($value))
1982 {
1983 $value = array($value);
1984 }
1985 $value = $value[0];
1986 settype($value, $execution);
1987 }
1988 else if (strpos($type, 'function') === 0)
1989 {
1990 if (!is_array($value))
1991 {
1992 $value = array($value);
1993 }
1994
1995 $value = call_user_func_array($execution, $value);
1996 }
1997 else if (strpos($type, 'execute') === 0)
1998 {
1999 if (!is_array($value))
2000 {
2001 $value = array($value);
2002 }
2003
2004 $execution = str_replace('{RESULT}', '$value', $execution);
2005 $execution = str_replace('{VALUE}', '$value', $execution);
2006 eval($execution);
2007 }
2008 }
2009 }
2010 else
2011 {
2012 $value = call_user_func_array($fields[2], $fields[1]);
2013 }
2014
2015 if (is_null($value))
2016 {
2017 $value = '';
2018 }
2019
2020 $insert_values[] = $db->_sql_validate_value($value);
2021 }
2022 else if (!empty($fields[2]))
2023 {
2024 if (is_array($fields[2]))
2025 {
2026 // Execute complex function/eval/typecast
2027 $value = '';
2028
2029 foreach ($fields[2] as $type => $execution)
2030 {
2031 if (strpos($type, 'typecast') === 0)
2032 {
2033 $value = settype($value, $execution);
2034 }
2035 else if (strpos($type, 'function') === 0)
2036 {
2037 if (!is_array($value))
2038 {
2039 $value = array($value);
2040 }
2041
2042 $value = call_user_func_array($execution, $value);
2043 }
2044 else if (strpos($type, 'execute') === 0)
2045 {
2046 if (!is_array($value))
2047 {
2048 $value = array($value);
2049 }
2050
2051 $execution = str_replace('{RESULT}', '$value', $execution);
2052 $execution = str_replace('{VALUE}', '$value', $execution);
2053 eval($execution);
2054 }
2055 }
2056 }
2057 else
2058 {
2059 call_user_func_array($fields[2], $fields[1]);
2060 }
2061 }
2062 }
2063 }
2064
2065 return $sql_flag;
2066 }
2067
2068 /**
2069 * Own meta refresh function to be able to change the global time used
2070 */
2071 function meta_refresh($url)
2072 {
2073 global $convert, $template;
2074
2075 if ($convert->options['refresh'])
2076 {
2077 // Because we should not rely on correct settings, we simply use the relative path here directly.
2078 $template->assign_vars(array(
2079 'S_REFRESH' => true,
2080 'META' => '<meta http-equiv="refresh" content="5;url=' . $url . '" />')
2081 );
2082 }
2083 }
2084
2085 /**
2086 * The information below will be used to build the input fields presented to the user
2087 */
2088 var $convert_options = array(
2089 'legend1' => 'SPECIFY_OPTIONS',
2090 'src_dbms' => array('lang' => 'DBMS', 'type' => 'select', 'options' => 'dbms_select(\'{VALUE}\', true)', 'explain' => false),
2091 'src_dbhost' => array('lang' => 'DB_HOST', 'type' => 'text:25:100', 'explain' => true),
2092 'src_dbport' => array('lang' => 'DB_PORT', 'type' => 'text:25:100', 'explain' => true),
2093 'src_dbname' => array('lang' => 'DB_NAME', 'type' => 'text:25:100', 'explain' => false),
2094 'src_dbuser' => array('lang' => 'DB_USERNAME', 'type' => 'text:25:100', 'explain' => false),
2095 'src_dbpasswd' => array('lang' => 'DB_PASSWORD', 'type' => 'password:25:100', 'explain' => false),
2096 'src_table_prefix' => array('lang' => 'TABLE_PREFIX', 'type' => 'text:25:100', 'explain' => false),
2097 //'src_url' => array('lang' => 'FORUM_ADDRESS', 'type' => 'text:50:100', 'explain' => true),
2098 'forum_path' => array('lang' => 'FORUM_PATH', 'type' => 'text:25:100', 'explain' => true),
2099 'refresh' => array('lang' => 'REFRESH_PAGE', 'type' => 'radio:yes_no', 'explain' => true),
2100 );
2101 }
2102
2103 ?>
phpbb is a php-based BBS (buletin board system)