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

'BODY' => sprintf($lang['BOARD_NOT_INSTALLED_EXPLAIN'], append_sid($phpbb_root_path . 'install/index.' . $phpEx, 'mode=install&language=' . $language)),

118

));

119

120

return;

121

}

122

123

require($phpbb_root_path . 'config.' . $phpEx);

124

require($phpbb_root_path . 'includes/constants.' . $phpEx);

125

require($phpbb_root_path . 'includes/db/' . $dbms . '.' . $phpEx);

126

require($phpbb_root_path . 'includes/functions_convert.' . $phpEx);

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}&sub=intro&new_conv=1&language=$language",

188

'U_CONTINUE_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&sub=in_progress&tag={$options['tag']}{$options['step']}&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.' . $phpEx);

219

require($phpbb_root_path . 'includes/constants.' . $phpEx);

220

require($phpbb_root_path . 'includes/db/' . $dbms . '.' . $phpEx);

221

require($phpbb_root_path . 'includes/functions_convert.' . $phpEx);

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

switch ($db->sql_layer)

242

{

243

case 'sqlite':

244

case 'firebird':

245

$db->sql_query('DELETE FROM ' . SESSIONS_KEYS_TABLE);

246

$db->sql_query('DELETE FROM ' . SESSIONS_TABLE);

247

break;

248

249

default:

250

$db->sql_query('TRUNCATE TABLE ' . SESSIONS_KEYS_TABLE);

251

$db->sql_query('TRUNCATE TABLE ' . SESSIONS_TABLE);

252

break;

253

}

254

255

break;

256

}

257

}

258

259

/**

260

* Generate a list of all available conversion modules

261

262

function list_convertors($sub)

263

{

264

global $lang, $language, $template, $phpbb_root_path, $phpEx;

265

266

$this->page_title = $lang['SUB_INTRO'];

267

268

$template->assign_vars(array(

269

'TITLE' => $lang['CONVERT_INTRO'],

270

'BODY' => $lang['CONVERT_INTRO_BODY'],

271

272

'L_AUTHOR' => $lang['AUTHOR'],

273

'L_AVAILABLE_CONVERTORS' => $lang['AVAILABLE_CONVERTORS'],

274

'L_CONVERT' => $lang['CONVERT'],

275

'L_NO_CONVERTORS' => $lang['NO_CONVERTORS'],

276

'L_OPTIONS' => $lang['CONVERT_OPTIONS'],

277

'L_SOFTWARE' => $lang['SOFTWARE'],

278

'L_VERSION' => $lang['VERSION'],

279

280

'S_LIST' => true,

281

));

282

283

$convertors = $sort = array();

284

$get_info = true;

285

286

$handle = @opendir('./convertors/');

287

288

if (!$handle)

289

{

290

$this->error('Unable to access the convertors directory', __LINE__, __FILE__);

291

}

292

293

while ($entry = readdir($handle))

294

{

295

if (preg_match('/^convert_([a-z0-9_]+).' . $phpEx . '$/i', $entry, $m))

296

{

297

include('./convertors/' . $entry);

298

if (isset($convertor_data))

299

{

300

$sort[strtolower($convertor_data['forum_name'])] = sizeof($convertors);

301

302

$convertors[] = array(

303

'tag' => $m[1],

304

'forum_name' => $convertor_data['forum_name'],

305

'version' => $convertor_data['version'],

306

'dbms' => $convertor_data['dbms'],

307

'dbhost' => $convertor_data['dbhost'],

308

'dbport' => $convertor_data['dbport'],

309

'dbuser' => $convertor_data['dbuser'],

310

'dbpasswd' => $convertor_data['dbpasswd'],

311

'dbname' => $convertor_data['dbname'],

312

'table_prefix' => $convertor_data['table_prefix'],

313

'author' => $convertor_data['author']

314

);

315

}

316

unset($convertor_data);

317

}

318

}

319

closedir($handle);

320

321

@ksort($sort);

322

323

foreach ($sort as $void => $index)

324

{

325

$template->assign_block_vars('convertors', array(

326

'AUTHOR' => $convertors[$index]['author'],

327

'SOFTWARE' => $convertors[$index]['forum_name'],

328

'VERSION' => $convertors[$index]['version'],

329

330

'U_CONVERT' => $this->p_master->module_url . "?mode={$this->mode}&language=$language&sub=settings&tag=" . $convertors[$index]['tag'],

331

));

332

}

333

}

334

335

/**

336

337

function get_convert_settings($sub)

338

{

339

global $lang, $language, $template, $db, $phpbb_root_path, $phpEx, $config, $cache;

340

341

require($phpbb_root_path . 'config.' . $phpEx);

342

require($phpbb_root_path . 'includes/constants.' . $phpEx);

343

require($phpbb_root_path . 'includes/db/' . $dbms . '.' . $phpEx);

344

require($phpbb_root_path . 'includes/functions_convert.' . $phpEx);

345

346

$db = new $sql_db();

347

$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);

348

unset($dbpasswd);

349

350

$this->page_title = $lang['STAGE_SETTINGS'];

351

352

// We need to fill the config to let internal functions correctly work

353

$sql = 'SELECT *

354

FROM ' . CONFIG_TABLE;

355

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

356

357

$config = array();

358

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

359

{

360

$config[$row['config_name']] = $row['config_value'];

361

}

362

$db->sql_freeresult($result);

363

364

$convertor_tag = request_var('tag', '');

365

366

if (empty($convertor_tag))

367

{

368

$this->p_master->error($lang['NO_CONVERT_SPECIFIED'], __LINE__, __FILE__);

369

}

370

$get_info = true;

371

372

// check security implications of direct inclusion

373

$convertor_tag = basename($convertor_tag);

374

if (!file_exists('./convertors/convert_' . $convertor_tag . '.' . $phpEx))

375

{

376

$this->p_master->error($lang['CONVERT_NOT_EXIST'], __LINE__, __FILE__);

377

}

378

379

include('./convertors/convert_' . $convertor_tag . '.' . $phpEx);

380

381

// The test_file is a file that should be present in the location of the old board.

382

if (!isset($test_file))

383

{

384

$this->p_master->error($lang['DEV_NO_TEST_FILE'], __LINE__, __FILE__);

385

}

386

387

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

388

389

$src_dbms = request_var('src_dbms', $convertor_data['dbms']);

390

$src_dbhost = request_var('src_dbhost', $convertor_data['dbhost']);

391

$src_dbport = request_var('src_dbport', $convertor_data['dbport']);

392

$src_dbuser = request_var('src_dbuser', $convertor_data['dbuser']);

393

$src_dbpasswd = request_var('src_dbpasswd', $convertor_data['dbpasswd']);

394

$src_dbname = request_var('src_dbname', $convertor_data['dbname']);

395

$src_table_prefix = request_var('src_table_prefix', $convertor_data['table_prefix']);

396

$forum_path = request_var('forum_path', $convertor_data['forum_path']);

397

$refresh = request_var('refresh', 1);

398

399

// Default URL of the old board

400

// @todo Are we going to use this for attempting to convert URL references in posts, or should we remove it?

401

// -> We should convert old urls to the new relative urls format

402

// $src_url = request_var('src_url', 'Not in use at the moment');

403

404

// strip trailing slash from old forum path

405

$forum_path = (strlen($forum_path) && $forum_path[strlen($forum_path) - 1] == '/') ? substr($forum_path, 0, -1) : $forum_path;

406

407

$error = array();

408

if ($submit)

409

{

410

if (!file_exists('./../' . $forum_path . '/' . $test_file))

411

{

412

$error[] = sprintf($lang['COULD_NOT_FIND_PATH'], $forum_path);

413

}

414

415

$connect_test = false;

416

$available_dbms = get_available_dbms(false, true, true);

417

418

if (!isset($available_dbms[$src_dbms]) || !$available_dbms[$src_dbms]['AVAILABLE'])

419

{

420

$error['db'][] = $lang['INST_ERR_NO_DB'];

421

$connect_test = false;

422

}

423

else

424

{

425

$src_dbpasswd = htmlspecialchars_decode($src_dbpasswd);

426

$connect_test = connect_check_db(true, $error, $available_dbms[$src_dbms], $src_table_prefix, $src_dbhost, $src_dbuser, $src_dbpasswd, $src_dbname, $src_dbport, true, ($src_dbms == $dbms) ? false : true, false);

427

}

428

429

// The forum prefix of the old and the new forum can only be the same if two different databases are used.

430

if ($src_table_prefix == $table_prefix && $src_dbms == $dbms && $src_dbhost == $dbhost && $src_dbport == $dbport && $src_dbname == $dbname)

431

{

432

$error[] = sprintf($lang['TABLE_PREFIX_SAME'], $src_table_prefix);

433

}

434

435

// Check table prefix

436

if (!sizeof($error))

437

{

438

// initiate database connection to old db if old and new db differ

439

global $src_db, $same_db;

440

$src_db = $same_db = false;

441

442

if ($src_dbms != $dbms || $src_dbhost != $dbhost || $src_dbport != $dbport || $src_dbname != $dbname || $src_dbuser != $dbuser)

443

{

444

$sql_db = 'dbal_' . $src_dbms;

445

$src_db = new $sql_db();

446

$src_db->sql_connect($src_dbhost, $src_dbuser, $src_dbpasswd, $src_dbname, $src_dbport, false, true);

447

$same_db = false;

448

}

449

else

450

{

451

$src_db = $db;

452

$same_db = true;

453

}

454

455

$src_db->sql_return_on_error(true);

456

$db->sql_return_on_error(true);

457

458

// Try to select one row from the first table to see if the prefix is OK

459

$result = $src_db->sql_query_limit('SELECT * FROM ' . $src_table_prefix . $tables[0], 1);

460

461

if (!$result)

462

{

463

$prefixes = array();

464

465

$tables_existing = get_tables($src_db);

466

$tables_existing = array_map('strtolower', $tables_existing);

467

foreach ($tables_existing as $table_name)

468

{

469

compare_table($tables, $table_name, $prefixes);

470

}

471

unset($tables_existing);

472

473

foreach ($prefixes as $prefix => $count)

474

{

475

if ($count >= sizeof($tables))

476

{

477

$possible_prefix = $prefix;

478

break;

479

}

480

}

481

482

$msg = '';

483

if (!empty($convertor_data['table_prefix']))

484

{

485

$msg .= sprintf($lang['DEFAULT_PREFIX_IS'], $convertor_data['forum_name'], $convertor_data['table_prefix']);

486

}

487

488

if (!empty($possible_prefix))

489

{

490

$msg .= ' ';

491

$msg .= ($possible_prefix == '*') ? $lang['BLANK_PREFIX_FOUND'] : sprintf($lang['PREFIX_FOUND'], $possible_prefix);

492

$src_table_prefix = ($possible_prefix == '*') ? '' : $possible_prefix;

493

}

494

495

$error[] = $msg;

496

}

497

$src_db->sql_freeresult($result);

498

$src_db->sql_return_on_error(false);

499

}

500

501

if (!sizeof($error))

502

{

503

// Save convertor Status

504

set_config('convert_progress', serialize(array(

505

'step' => '',

506

'table_prefix' => $src_table_prefix,

507

'tag' => $convertor_tag,

508

)), true);

509

set_config('convert_db_server', serialize(array(

510

'dbms' => $src_dbms,

511

'dbhost' => $src_dbhost,

512

'dbport' => $src_dbport,

513

'dbname' => $src_dbname,

514

)), true);

515

set_config('convert_db_user', serialize(array(

516

'dbuser' => $src_dbuser,

517

'dbpasswd' => $src_dbpasswd,

518

)), true);

519

520

// Save options

521

set_config('convert_options', serialize(array('forum_path' => './../' . $forum_path, 'refresh' => $refresh)), true);

522

523

$template->assign_block_vars('checks', array(

524

'TITLE' => $lang['VERIFY_OPTIONS'],

525

'RESULT' => $lang['CONVERT_SETTINGS_VERIFIED'],

526

));

527

528

$template->assign_vars(array(

529

'L_SUBMIT' => $lang['BEGIN_CONVERT'],

530

// 'S_HIDDEN' => $s_hidden_fields,

531

'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&sub=in_progress&tag=$convertor_tag&language=$language",

532

));

533

534

return;

535

}

536

else

537

{

538

$template->assign_block_vars('checks', array(

539

'TITLE' => $lang['VERIFY_OPTIONS'],

540

'RESULT' => '' . implode(' ', $error) . '',

541

));

542

}

543

} // end submit

544

545

foreach ($this->convert_options as $config_key => $vars)

546

{

547

if (!is_array($vars) && strpos($config_key, 'legend') === false)

548

{

549

continue;

550

}

551

552

if (strpos($config_key, 'legend') !== false)

553

{

554

$template->assign_block_vars('options', array(

555

'S_LEGEND' => true,

556

'LEGEND' => $lang[$vars])

557

);

558

559

continue;

560

}

561

562

$options = isset($vars['options']) ? $vars['options'] : '';

563

564

$template->assign_block_vars('options', array(

565

'KEY' => $config_key,

566

'TITLE' => $lang[$vars['lang']],

567

'S_EXPLAIN' => $vars['explain'],

568

'S_LEGEND' => false,

569

'TITLE_EXPLAIN' => ($vars['explain']) ? $lang[$vars['lang'] . '_EXPLAIN'] : '',

570

'CONTENT' => $this->p_master->input_field($config_key, $vars['type'], $$config_key, $options),

571

)

572

);

573

}

574

575

$template->assign_vars(array(

576

'TITLE' => $lang['STAGE_SETTINGS'],

577

'BODY' => $lang['CONV_OPTIONS_BODY'],

578

'L_SUBMIT' => $lang['BEGIN_CONVERT'],

579

'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&sub=settings&tag=$convertor_tag&language=$language",

580

));

581

}

582

583

/**

584

* The function which does the actual work (or dispatches it to the relevant places)

585

586

function convert_data($sub)

587

{

588

global $template, $user, $phpbb_root_path, $phpEx, $db, $lang, $config, $cache;

589

global $convert, $convert_row, $message_parser, $skip_rows;

590

591

require($phpbb_root_path . 'config.' . $phpEx);

592

require($phpbb_root_path . 'includes/constants.' . $phpEx);

593

require($phpbb_root_path . 'includes/db/' . $dbms . '.' . $phpEx);

594

require($phpbb_root_path . 'includes/functions_convert.' . $phpEx);

595

596

$db = new $sql_db();

597

$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);

598

unset($dbpasswd);

599

600

$sql = 'SELECT *

601

FROM ' . CONFIG_TABLE;

602

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

603

604

$config = array();

605

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

606

{

607

$config[$row['config_name']] = $row['config_value'];

608

}

609

$db->sql_freeresult($result);

610

611

// Override a couple of config variables for the duration

612

$config['max_quote_depth'] = 0;

613

614

// @todo Need to confirm that max post length in source is <= max post length in destination or there may be interesting formatting issues

615

$config['max_post_chars'] = 0;

616

617

// Set up a user as well. We _should_ have enough of a database here at this point to do this

618

// and it helps for any core code we call

619

$user->session_begin();

620

$user->page = $user->extract_current_page($phpbb_root_path);

621

622

// This is a little bit of a fudge, but it allows the language entries to be available to the

623

// core code without us loading them again

624

$user->lang = &$lang;

625

626

$this->page_title = $user->lang['STAGE_IN_PROGRESS'];

627

628

$convert->options = array();

629

if (isset($config['convert_progress']))

630

{

631

$convert->options = unserialize($config['convert_progress']);

632

$convert->options = array_merge($convert->options, unserialize($config['convert_db_server']), unserialize($config['convert_db_user']), unserialize($config['convert_options']));

633

}

634

635

// This information should have already been checked once, but do it again for safety

636

if (empty($convert->options) || empty($convert->options['tag']) ||

637

!isset($convert->options['dbms']) ||

638

!isset($convert->options['dbhost']) ||

639

!isset($convert->options['dbport']) ||

640

!isset($convert->options['dbuser']) ||

641

!isset($convert->options['dbpasswd']) ||

642

!isset($convert->options['dbname']) ||

643

!isset($convert->options['table_prefix']))

644

{

645

$this->p_master->error($user->lang['NO_CONVERT_SPECIFIED'], __LINE__, __FILE__);

646

}

647

648

// Make some short variables accessible, for easier referencing

649

$convert->convertor_tag = basename($convert->options['tag']);

650

$convert->src_dbms = $convert->options['dbms'];

651

$convert->src_dbhost = $convert->options['dbhost'];

652

$convert->src_dbport = $convert->options['dbport'];

653

$convert->src_dbuser = $convert->options['dbuser'];

654

$convert->src_dbpasswd = $convert->options['dbpasswd'];

655

$convert->src_dbname = $convert->options['dbname'];

656

$convert->src_table_prefix = $convert->options['table_prefix'];

657

658

// initiate database connection to old db if old and new db differ

659

global $src_db, $same_db;

660

$src_db = $same_db = null;

661

if ($convert->src_dbms != $dbms || $convert->src_dbhost != $dbhost || $convert->src_dbport != $dbport || $convert->src_dbname != $dbname || $convert->src_dbuser != $dbuser)

662

{

663

if ($convert->src_dbms != $dbms)

664

{

665

require($phpbb_root_path . 'includes/db/' . $convert->src_dbms . '.' . $phpEx);

666

}

667

$sql_db = 'dbal_' . $convert->src_dbms;

668

$src_db = new $sql_db();

669

$src_db->sql_connect($convert->src_dbhost, $convert->src_dbuser, $convert->src_dbpasswd, $convert->src_dbname, $convert->src_dbport, false, true);

670

$same_db = false;

671

}

672

else

673

{

674

$src_db = $db;

675

$same_db = true;

676

}

677

678

$convert->mysql_convert = false;

679

switch ($src_db->sql_layer)

680

{

681

case 'sqlite':

682

case 'firebird':

683

$convert->src_truncate_statement = 'DELETE FROM ';

684

break;

685

686

// Thanks MySQL, for silently converting...

687

case 'mysql':

688

case 'mysql4':

689

if (version_compare($src_db->mysql_version, '4.1.3', '>='))

690

{

691

$convert->mysql_convert = true;

692

}

693

$convert->src_truncate_statement = 'TRUNCATE TABLE ';

694

break;

695

696

case 'mysqli':

697

$convert->mysql_convert = true;

698

$convert->src_truncate_statement = 'TRUNCATE TABLE ';

699

break;

700

701

default:

702

$convert->src_truncate_statement = 'TRUNCATE TABLE ';

703

break;

704

}

705

706

if ($convert->mysql_convert && !$same_db)

707

{

708

$src_db->sql_query("SET NAMES 'binary'");

709

}

710

711

switch ($db->sql_layer)

712

{

713

case 'sqlite':

714

case 'firebird':

715

$convert->truncate_statement = 'DELETE FROM ';

716

break;

717

718

default:

719

$convert->truncate_statement = 'TRUNCATE TABLE ';

720

break;

721

}

722

723

$get_info = false;

724

725

// check security implications of direct inclusion

726

if (!file_exists('./convertors/convert_' . $convert->convertor_tag . '.' . $phpEx))

727

{

728

$this->p_master->error($user->lang['CONVERT_NOT_EXIST'], __LINE__, __FILE__);

729

}

730

731

if (file_exists('./convertors/functions_' . $convert->convertor_tag . '.' . $phpEx))

732

{

733

include('./convertors/functions_' . $convert->convertor_tag . '.' . $phpEx);

734

}

735

736

$get_info = true;

737

include('./convertors/convert_' . $convert->convertor_tag . '.' . $phpEx);

738

739

// Map some variables...

740

$convert->convertor_data = $convertor_data;

741

$convert->tables = $tables;

742

$convert->config_schema = $config_schema;

743

744

// Now include the real data

745

$get_info = false;

746

include('./convertors/convert_' . $convert->convertor_tag . '.' . $phpEx);

747

748

$convert->convertor_data = $convertor_data;

749

$convert->tables = $tables;

750

$convert->config_schema = $config_schema;

751

$convert->convertor = $convertor;

752

753

// The test_file is a file that should be present in the location of the old board.

754

if (!file_exists($convert->options['forum_path'] . '/' . $test_file))

755

{

756

$this->p_master->error(sprintf($user->lang['COULD_NOT_FIND_PATH'], $convert->options['forum_path']), __LINE__, __FILE__);

757

}

758

759

$search_type = basename(trim($config['search_type']));

760

761

// For conversions we are a bit less strict and set to a search backend we know exist...

762

if (!file_exists($phpbb_root_path . 'includes/search/' . $search_type . '.' . $phpEx))

763

{

764

$search_type = 'fulltext_native';

765

set_config('search_type', $search_type);

766

}

767

768

if (!file_exists($phpbb_root_path . 'includes/search/' . $search_type . '.' . $phpEx))

769

{

770

trigger_error('NO_SUCH_SEARCH_MODULE');

771

}

772

773

require($phpbb_root_path . 'includes/search/' . $search_type . '.' . $phpEx);

774

775

$error = false;

776

$convert->fulltext_search = new $search_type($error);

777

778

if ($error)

779

{

780

trigger_error($error);

781

}

782

783

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

784

$message_parser = new parse_message();

785

786

$jump = request_var('jump', 0);

787

$final_jump = request_var('final_jump', 0);

788

$sync_batch = request_var('sync_batch', -1);

789

$last_statement = request_var('last', 0);

790

791

// We are running sync...

792

if ($sync_batch >= 0)

793

{

794

$this->sync_forums($sync_batch);

795

return;

796

}

797

798

if ($jump)

799

{

800

$this->jump($jump, $last_statement);

801

return;

802

}

803

804

if ($final_jump)

805

{

806

$this->final_jump($final_jump);

807

return;

808

}

809

810

$current_table = request_var('current_table', 0);

811

$old_current_table = min(-1, $current_table - 1);

812

$skip_rows = request_var('skip_rows', 0);

813

814

if (!$current_table && !$skip_rows)

815

{

816

if (empty($_REQUEST['confirm']))

817

{

818

// If avatars / ranks / smilies folders are specified make sure they are writable

819

$bad_folders = array();

820

821

$local_paths = array(

822

'avatar_path' => path($config['avatar_path']),

823

'avatar_gallery_path' => path($config['avatar_gallery_path']),

824

'icons_path' => path($config['icons_path']),

825

'ranks_path' => path($config['ranks_path']),

826

'smilies_path' => path($config['smilies_path'])

827

);

828

829

foreach ($local_paths as $folder => $local_path)

830

{

831

if (isset($convert->convertor[$folder]))

832

{

833

if (empty($convert->convertor['test_file']))

834

{

835

// test_file is mandantory at the moment so this should never be reached, but just in case...

836

$this->p_master->error($user->lang['DEV_NO_TEST_FILE'], __LINE__, __FILE__);

837

}

838

839

if (!$local_path || !@is_writable($phpbb_root_path . $local_path))

840

{

841

if (!$local_path)

842

{

843

$bad_folders[] = sprintf($user->lang['CONFIG_PHPBB_EMPTY'], $folder);

844

}

845

else

846

{

847

$bad_folders[] = $local_path;

848

}

849

}

850

}

851

}

852

853

if (sizeof($bad_folders))

854

{

855

$msg = (sizeof($bad_folders) == 1) ? $user->lang['MAKE_FOLDER_WRITABLE'] : $user->lang['MAKE_FOLDERS_WRITABLE'];

856

sort($bad_folders);

857

$this->p_master->error(sprintf($msg, implode(' ', $bad_folders)), __LINE__, __FILE__, true);

858

859

$template->assign_vars(array(

860

'L_SUBMIT' => $user->lang['INSTALL_TEST'],

861

'U_ACTION' => $this->p_master->module_url . "?mode={$this->mode}&sub=in_progress&tag={$convert->convertor_tag}&language=$language",

862

));

863

return;

864

}

865

866

// Grab all the tables used in convertor

867

$missing_tables = $tables_list = $aliases = array();

868

869

foreach ($convert->convertor['schema'] as $schema)

870

{

871

// Skip those not used (because of addons/plugins not detected)

872

if (!$schema['target'])

873

{

874

continue;

875

}

876

877

foreach ($schema as $key => $val)

878

{

879

// we're dealing with an array like:

880

// array('forum_status', 'forums.forum_status', 'is_item_locked')

881

if (is_int($key) && !empty($val[1]))

882

{

883

$temp_data = $val[1];

884

if (!is_array($temp_data))

885

{

886

$temp_data = array($temp_data);

887

}

888

889

foreach ($temp_data as $val)

890

{

891

if (preg_match('/([a-z0-9_]+)\.([a-z0-9_]+)\)* ?A?S? ?([a-z0-9_]*?)\.?([a-z0-9_]*)$/i', $val, $m))

892

{

893

$table = $convert->src_table_prefix . $m[1];

894

$tables_list[$table] = $table;

895

896

if (!empty($m[3]))

897

{

898

$aliases[] = $convert->src_table_prefix . $m[3];

899

}

900

}

901

}

902

}

903

// 'left_join' => 'topics LEFT JOIN vote_desc ON topics.topic_id = vote_desc.topic_id AND topics.topic_vote = 1'

904

else if ($key == 'left_join')

905

{

906

// Convert the value if it wasn't an array already.

907

if (!is_array($val))

908

{

909

$val = array($val);

910

}

911

912

for ($j = 0; $j < sizeof($val); ++$j)

913

{

914

if (preg_match('/LEFT JOIN ([a-z0-9_]+) AS ([a-z0-9_]+)/i', $val[$j], $m))

915

{

916

$table = $convert->src_table_prefix . $m[1];

917

$tables_list[$table] = $table;

918

919

if (!empty($m[2]))

920

{

921

$aliases[] = $convert->src_table_prefix . $m[2];

922

}

923

}

924

}

925

}

926

}

927

}

928

929

// Remove aliased tables from $tables_list

930

foreach ($aliases as $alias)

931

{

932

unset($tables_list[$alias]);

933

}

934

935

// Check if the tables that we need exist

936

$src_db->sql_return_on_error(true);

937

foreach ($tables_list as $table => $null)

938

{

939

$sql = 'SELECT 1 FROM ' . $table;

940

$_result = $src_db->sql_query_limit($sql, 1);

941

942

if (!$_result)

943

{

944

$missing_tables[] = $table;

945

}

946

$src_db->sql_freeresult($_result);

947

}

948

$src_db->sql_return_on_error(false);

949

950

// Throw an error if some tables are missing

951

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

952

953

if (sizeof($missing_tables) == sizeof($tables_list))

954

{

955

$this->p_master->error($user->lang['NO_TABLES_FOUND'] . ' ' . $user->lang['CHECK_TABLE_PREFIX'], __LINE__, __FILE__);

956

}

957

else if (sizeof($missing_tables))

958

{

959

$this->p_master->error(sprintf($user->lang['TABLES_MISSING'], implode(', ', $missing_tables)) . ' ' . $user->lang['CHECK_TABLE_PREFIX'], __LINE__, __FILE__);

960

}

961

962

$url = $this->save_convert_progress('&confirm=1');

963

$msg = $user->lang['PRE_CONVERT_COMPLETE'];

964

965

if ($convert->convertor_data['author_notes'])

966

{

967

$msg .= '' . sprintf($user->lang['AUTHOR_NOTES'], $convert->convertor_data['author_notes']);

968

}

969

970

$template->assign_vars(array(

971

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

972

'L_MESSAGE' => $msg,

973

'U_ACTION' => $url,

974

));

975

976

return;

977

} // if (empty($_REQUEST['confirm']))

978

979

$template->assign_block_vars('checks', array(

980

'S_LEGEND' => true,

981

'LEGEND' => $user->lang['STARTING_CONVERT'],

982

));

983

984

// Convert the config table and load the settings of the old board

985

if (!empty($convert->config_schema))

986

{

987

restore_config($convert->config_schema);

988

989

// Override a couple of config variables for the duration

990

$config['max_quote_depth'] = 0;

991

992

// @todo Need to confirm that max post length in source is <= max post length in destination or there may be interesting formatting issues

993

$config['max_post_chars'] = 0;

994

}

995

996

$template->assign_block_vars('checks', array(

997

'TITLE' => $user->lang['CONFIG_CONVERT'],

998

'RESULT' => $user->lang['DONE'],

999

));

1000

1001

// Now process queries and execute functions that have to be executed prior to the conversion

1002

if (!empty($convert->convertor['execute_first']))

1003

{

1004

eval($convert->convertor['execute_first']);

1005

}

1006

1007

if (!empty($convert->convertor['query_first']))

1008

{

1009

if (!is_array($convert->convertor['query_first']))

1010

{

1011

$convert->convertor['query_first'] = array('target', array($convert->convertor['query_first']));

1012

}

1013

else if (!is_array($convert->convertor['query_first'][0]))

1014

{

1015

$convert->convertor['query_first'] = array(array($convert->convertor['query_first'][0], $convert->convertor['query_first'][1]));

1016

}

1017

1018

foreach ($convert->convertor['query_first'] as $query_first)

1019

{

1020

if ($query_first[0] == 'src')

1021

{

1022

if ($convert->mysql_convert && $same_db)

1023

{

1024

$src_db->sql_query("SET NAMES 'binary'");

1025

}

1026

1027

$src_db->sql_query($query_first[1]);

1028

1029

if ($convert->mysql_convert && $same_db)

1030

{

1031

$src_db->sql_query("SET NAMES 'utf8'");

1032

}

1033

}

1034

else

1035

{

1036

$db->sql_query($query_first[1]);

1037

}

1038

}

1039

}

1040

1041

$template->assign_block_vars('checks', array(

1042

'TITLE' => $user->lang['PREPROCESS_STEP'],

1043

'RESULT' => $user->lang['DONE'],

1044

));

1045

} // if (!$current_table && !$skip_rows)

1046

1047

$template->assign_block_vars('checks', array(

1048

'S_LEGEND' => true,

1049

'LEGEND' => $user->lang['FILLING_TABLES'],

1050

));

1051

1052

// This loop takes one target table and processes it

1053

while ($current_table < sizeof($convert->convertor['schema']))

1054

{

1055

$schema = $convert->convertor['schema'][$current_table];

1056

1057

// The target table isn't set, this can be because a module (for example the attachement mod) is taking care of this.

1058

if (empty($schema['target']))

1059

{

1060

$current_table++;

1061

continue;

1062

}

1063

1064

$template->assign_block_vars('checks', array(

1065

'TITLE' => sprintf($user->lang['FILLING_TABLE'], $schema['target']),

1066

));

1067

1068

// This is only the case when we first start working on the tables.

1069

if (!$skip_rows)

1070

{

1071

// process execute_first and query_first for this table...

1072

if (!empty($schema['execute_first']))

1073

{

1074

eval($schema['execute_first']);

1075

}

1076

1077

if (!empty($schema['query_first']))

1078

{

1079

if (!is_array($schema['query_first']))

1080

{

1081

$schema['query_first'] = array('target', array($schema['query_first']));

1082

}

1083

else if (!is_array($schema['query_first'][0]))

1084

{

1085

$schema['query_first'] = array(array($schema['query_first'][0], $schema['query_first'][1]));

1086

}

1087

1088

foreach ($schema['query_first'] as $query_first)

1089

{

1090

if ($query_first[0] == 'src')

1091

{

1092

if ($convert->mysql_convert && $same_db)

1093

{

1094

$src_db->sql_query("SET NAMES 'binary'");

1095

}

1096

$src_db->sql_query($query_first[1]);

1097

if ($convert->mysql_convert && $same_db)

1098

{

1099

$src_db->sql_query("SET NAMES 'utf8'");

1100

}

1101

}

1102

else

1103

{

1104

$db->sql_query($query_first[1]);

1105

}

1106

}

1107

}

1108

1109

if (!empty($schema['autoincrement']))

1110

{

1111

switch ($db->sql_layer)

1112

{

1113

case 'postgres':

1114

$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'] . '));');

1115

break;

1116

1117

case 'oracle':

1118

$result = $db->sql_query('SELECT MAX(' . $schema['autoincrement'] . ') as max_id FROM ' . $schema['target']);

1119

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

1120

$db->sql_freeresult($result);

1121

1122

$largest_id = (int) $row['max_id'];

1123

1124

if ($largest_id)

1125

{

1126

$db->sql_query('DROP SEQUENCE ' . $schema['target'] . '_seq');

1127

$db->sql_query('CREATE SEQUENCE ' . $schema['target'] . '_seq START WITH ' . ($largest_id + 1));

1128

}

1129

break;

1130

}

1131

}

1132

}

1133

1134

// Process execute_always for this table

1135

// This is for code which needs to be executed on every pass of this table if

1136

// it gets split because of time restrictions

1137

if (!empty($schema['execute_always']))

1138

{

1139

eval($schema['execute_always']);

1140

}

1141

1142

1143

// Set up some variables

1144

1145

// $waiting_rows holds rows for multirows insertion (MySQL only)

1146

// $src_tables holds unique tables with aliases to select from

1147

// $src_fields will quickly refer source fields (or aliases) corresponding to the current index

1148

// $select_fields holds the names of the fields to retrieve

1149

1150

1151

$sql_data = array(

1152

'source_fields' => array(),

1153

'target_fields' => array(),

1154

'source_tables' => array(),

1155

'select_fields' => array(),

1156

);

1157

1158

// This statement is building the keys for later insertion.

1159

$insert_query = $this->build_insert_query($schema, $sql_data, $current_table);

1160

1161

// If no source table is affected, we skip the table

1162

if (empty($sql_data['source_tables']))

1163

{

1164

$skip_rows = 0;

1165

$current_table++;

1166

continue;

1167

}

1168

1169

$distinct = (!empty($schema['distinct'])) ? 'DISTINCT ' : '';

1170

1171

$sql = 'SELECT ' . $distinct . implode(', ', $sql_data['select_fields']) . " \nFROM " . implode(', ', $sql_data['source_tables']);

1172

1173

// Where

1174

$sql .= (!empty($schema['where'])) ? "\nWHERE (" . $schema['where'] . ')' : '';

1175

1176

// Group By

1177

if (!empty($schema['group_by']))

1178

{

1179

$schema['group_by'] = array($schema['group_by']);

1180

foreach ($sql_data['select_fields'] as $select)

1181

{

1182

$alias = strpos(strtolower($select), ' as ');

1183

$select = ($alias) ? substr($select, 0, $alias) : $select;

1184

if (!in_array($select, $schema['group_by']))

1185

{

1186

$schema['group_by'][] = $select;

1187

}

1188

}

1189

}

1190

$sql .= (!empty($schema['group_by'])) ? "\nGROUP BY " . implode(', ', $schema['group_by']) : '';

1191

1192

// Having

1193

$sql .= (!empty($schema['having'])) ? "\nHAVING " . $schema['having'] : '';

1194

1195

// Order By

1196

if (empty($schema['order_by']) && !empty($schema['primary']))

1197

{

1198

$schema['order_by'] = $schema['primary'];

1199

}

1200

$sql .= (!empty($schema['order_by'])) ? "\nORDER BY " . $schema['order_by'] : '';

1201

1202

// Counting basically holds the amount of rows processed.

1203

$counting = -1;

1204

$batch_time = 0;

1205

1206

while ($counting === -1 || ($counting >= $convert->batch_size && still_on_time()))

1207

{

1208

$old_current_table = $current_table;

1209

1210

$rows = '';

1211

$waiting_rows = array();

1212

1213

if (!empty($batch_time))

1214

{

1215

$mtime = explode(' ', microtime());

1216

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

1217

$rows = ceil($counting/($mtime - $batch_time)) . " rows/s ($counting rows) | ";

1218

}

1219

1220

$template->assign_block_vars('checks', array(

1221

'TITLE' => "skip_rows = $skip_rows",

1222

'RESULT' => $rows . ((defined('DEBUG_EXTRA') && function_exists('memory_get_usage')) ? ceil(memory_get_usage()/1024) . ' KB' : ''),

1223

));

1224

1225

$mtime = explode(' ', microtime());

1226

$batch_time = $mtime[0] + $mtime[1];

1227

1228

if ($convert->mysql_convert && $same_db)

1229

{

1230

$src_db->sql_query("SET NAMES 'binary'");

1231

}

1232

1233

// Take skip rows into account and only fetch batch_size amount of rows

1234

$___result = $src_db->sql_query_limit($sql, $convert->batch_size, $skip_rows);

1235

1236

if ($convert->mysql_convert && $same_db)

1237

{

1238

$src_db->sql_query("SET NAMES 'utf8'");

1239

}

1240

1241

// This loop processes each row

1242

$counting = 0;

1243

1244

$convert->row = $convert_row = array();

1245

1246

if (!empty($schema['autoincrement']))

1247

{

1248

switch ($db->sql_layer)

1249

{

1250

case 'mssql':

1251

case 'mssql_odbc':

1252

$db->sql_query('SET IDENTITY_INSERT ' . $schema['target'] . ' ON');

1253

break;

1254

}

1255

}

1256

1257

// Now handle the rows until time is over or no more rows to process...

1258

while ($counting === 0 || still_on_time())

1259

{

1260

$convert_row = $src_db->sql_fetchrow($___result);

1261

1262

if (!$convert_row)

1263

{

1264

// move to the next batch or table

1265

break;

1266

}

1267

1268

// With this we are able to always save the last state

1269

$convert->row = $convert_row;

1270

1271

// Increment the counting variable, it stores the number of rows we have processed

1272

$counting++;

1273

1274

$insert_values = array();

1275

1276

$sql_flag = $this->process_row($schema, $sql_data, $insert_values);

1277

1278

if ($sql_flag === true)

1279

{

1280

switch ($db->sql_layer)

1281

{

1282

// If MySQL, we'll wait to have num_wait_rows rows to submit at once

1283

case 'mysql':

1284

case 'mysql4':

1285

case 'mysqli':

1286

$waiting_rows[] = '(' . implode(', ', $insert_values) . ')';

1287

1288

if (sizeof($waiting_rows) >= $convert->num_wait_rows)

1289

{

1290

$errored = false;

1291

1292

$db->sql_return_on_error(true);

1293

1294

if (!$db->sql_query($insert_query . implode(', ', $waiting_rows)))

1295

{

1296

$errored = true;

1297

}

1298

$db->sql_return_on_error(false);

1299

1300

if ($errored)

1301

{

1302

$db->sql_return_on_error(true);

1303

1304

// Because it errored out we will try to insert the rows one by one... most of the time this

1305

// is caused by duplicate entries - but we also do not want to miss one...

1306

foreach ($waiting_rows as $waiting_sql)

1307

{

1308

if (!$db->sql_query($insert_query . $waiting_sql))

1309

{

1310

$this->p_master->db_error($user->lang['DB_ERR_INSERT'], htmlspecialchars($insert_query . $waiting_sql) . ' ' . htmlspecialchars(print_r($db->_sql_error(), true)), __LINE__, __FILE__, true);

1311

}

1312

}

1313

1314

$db->sql_return_on_error(false);

1315

}

1316

1317

$waiting_rows = array();

1318

}

1319

1320

break;

1321

1322

default:

1323

$insert_sql = $insert_query . '(' . implode(', ', $insert_values) . ')';

1324

1325

$db->sql_return_on_error(true);

1326

1327

if (!$db->sql_query($insert_sql))

1328

{

1329

$this->p_master->db_error($user->lang['DB_ERR_INSERT'], htmlspecialchars($insert_sql) . ' ' . htmlspecialchars(print_r($db->_sql_error(), true)), __LINE__, __FILE__, true);

1330

}

1331

$db->sql_return_on_error(false);

1332

1333

$waiting_rows = array();

1334

1335

break;

1336

}

1337

}

1338

1339

$skip_rows++;

1340

}

1341

$src_db->sql_freeresult($___result);

1342

1343

// We might still have some rows waiting

1344

if (sizeof($waiting_rows))

1345

{

1346

$errored = false;

1347

$db->sql_return_on_error(true);

1348

1349

if (!$db->sql_query($insert_query . implode(', ', $waiting_rows)))

1350

{

1351

$errored = true;

1352

}

1353

$db->sql_return_on_error(false);

1354

1355

if ($errored)

1356

{

1357

$db->sql_return_on_error(true);

1358

1359

// Because it errored out we will try to insert the rows one by one... most of the time this

1360

// is caused by duplicate entries - but we also do not want to miss one...

1361

foreach ($waiting_rows as $waiting_sql)

1362

{

1363

$db->sql_query($insert_query . $waiting_sql);

1364

1365

}

1366

1367

$db->sql_return_on_error(false);

1368

}

1369

1370

$waiting_rows = array();

1371

}

1372

1373

if (!empty($schema['autoincrement']))

1374

{

1375

switch ($db->sql_layer)

1376

{

1377

case 'mssql':

1378

case 'mssql_odbc':

1379

$db->sql_query('SET IDENTITY_INSERT ' . $schema['target'] . ' OFF');

1380

break;

1381

1382

case 'postgres':

1383

1384

break;

1385

1386

case 'oracle':

1387

$result = $db->sql_query('SELECT MAX(' . $schema['autoincrement'] . ') as max_id FROM ' . $schema['target']);

1388

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

1389

$db->sql_freeresult($result);

1390

1391

$largest_id = (int) $row['max_id'];

1392

1393

if ($largest_id)

1394

{

1395

$db->sql_query('DROP SEQUENCE ' . $schema['target'] . '_seq');

1396

$db->sql_query('CREATE SEQUENCE ' . $schema['target'] . '_seq START WITH ' . ($largest_id + 1));

1397

}

1398

break;

1399

}

1400

}

1401

}

1402

1403

// When we reach this point, either the current table has been processed or we're running out of time.

1404

if (still_on_time() && $counting < $convert->batch_size/* && !defined('DEBUG_EXTRA')*/)

1405

{

1406

$skip_rows = 0;

1407

$current_table++;

1408

}

1409

else

1410

{/*

1411

if (still_on_time() && $counting < $convert->batch_size)

1412

{

1413

$skip_rows = 0;

1414

$current_table++;

1415

}*/

1416

1417

// Looks like we ran out of time.

1418

$url = $this->save_convert_progress('&current_table=' . $current_table . '&skip_rows=' . $skip_rows);

1419

1420

$current_table++;

1421

// $percentage = ($skip_rows == 0) ? 0 : floor(100 / ($total_rows / $skip_rows));

1422

1423

$msg = sprintf($user->lang['STEP_PERCENT_COMPLETED'], $current_table, sizeof($convert->convertor['schema']));

1424

1425

$template->assign_vars(array(

1426

'L_MESSAGE' => $msg,

1427

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

1428

'U_ACTION' => $url,

1429

));

1430

1431

$this->meta_refresh($url);

1432

return;

1433

}

1434

}

1435

1436

// Process execute_last then we'll be done

1437

$url = $this->save_convert_progress('&jump=1');

1438

1439

$template->assign_vars(array(

1440

'L_SUBMIT' => $user->lang['FINAL_STEP'],

1441

'U_ACTION' => $url,

1442

));

1443

1444

$this->meta_refresh($url);

1445

return;

1446

}

1447

1448

/**

1449

* Sync function being executed at the middle, some functions need to be executed after a successful sync.

1450

1451

function sync_forums($sync_batch)

1452

{

1453

global $template, $user, $db, $phpbb_root_path, $phpEx, $config, $cache;

1454

global $convert;

1455

1456

$template->assign_block_vars('checks', array(

1457

'S_LEGEND' => true,

1458

'LEGEND' => $user->lang['SYNC_TOPICS'],

1459

));

1460

1461

$batch_size = $convert->batch_size;

1462

1463

$sql = 'SELECT MIN(topic_id) as min_value, MAX(topic_id) AS max_value

1464

FROM ' . TOPICS_TABLE;

1465

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

1466

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

1467

$db->sql_freeresult($result);

1468

1469

// Set values of minimum/maximum primary value for this table.

1470

$primary_min = $row['min_value'];

1471

$primary_max = $row['max_value'];

1472

1473

if ($sync_batch == 0)

1474

{

1475

$sync_batch = (int) $primary_min;

1476

}

1477

1478

if ($sync_batch == 0)

1479

{

1480

$sync_batch = 1;

1481

}

1482

1483

// Fetch a batch of rows, process and insert them.

1484

while ($sync_batch <= $primary_max && still_on_time())

1485

{

1486

$end = ($sync_batch + $batch_size - 1);

1487

1488

// Sync all topics in batch mode...

1489

sync('topic_approved', 'range', 'topic_id BETWEEN ' . $sync_batch . ' AND ' . $end, true, false);

1490

sync('topic', 'range', 'topic_id BETWEEN ' . $sync_batch . ' AND ' . $end, true, true);

1491

1492

$template->assign_block_vars('checks', array(

1493

'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) . ' KB]' : ''),

1494

'RESULT' => $user->lang['DONE'],

1495

));

1496

1497

$sync_batch += $batch_size;

1498

}

1499

1500

if ($sync_batch >= $primary_max)

1501

{

1502

$url = $this->save_convert_progress('&final_jump=1');

1503

1504

$template->assign_vars(array(

1505

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

1506

'U_ACTION' => $url,

1507

));

1508

1509

$this->meta_refresh($url);

1510

return;

1511

}

1512

else

1513

{

1514

$sync_batch--;

1515

}

1516

1517

$url = $this->save_convert_progress('&sync_batch=' . $sync_batch);

1518

1519

$template->assign_vars(array(

1520

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

1521

'U_ACTION' => $url,

1522

));

1523

1524

$this->meta_refresh($url);

1525

return;

1526

}

1527

1528

/**

1529

* Save the convertor status

1530

1531

function save_convert_progress($step)

1532

{

1533

global $convert, $language;

1534

1535

// Save convertor Status

1536

set_config('convert_progress', serialize(array(

1537

'step' => $step,

1538

'table_prefix' => $convert->src_table_prefix,

1539

'tag' => $convert->convertor_tag,

1540

)), true);

1541

1542

set_config('convert_db_server', serialize(array(

1543

'dbms' => $convert->src_dbms,

1544

'dbhost' => $convert->src_dbhost,

1545

'dbport' => $convert->src_dbport,

1546

'dbname' => $convert->src_dbname,

1547

)), true);

1548

1549

set_config('convert_db_user', serialize(array(

1550

'dbuser' => $convert->src_dbuser,

1551

'dbpasswd' => $convert->src_dbpasswd,

1552

)), true);

1553

1554

return $this->p_master->module_url . "?mode={$this->mode}&sub=in_progress&tag={$convert->convertor_tag}$step&language=$language";

1555

}

1556

1557

/**

1558

* Finish conversion, the last function to be called.

1559

1560

function finish_conversion()

1561

{

1562

global $db, $phpbb_root_path, $convert, $config, $language, $user, $template;

1563

1564

$db->sql_query('DELETE FROM ' . CONFIG_TABLE . "

1565

WHERE config_name = 'convert_progress'

1566

OR config_name = 'convert_options'

1567

OR config_name = 'convert_db_server'

1568

OR config_name = 'convert_db_user'");

1569

$db->sql_query('DELETE FROM ' . SESSIONS_TABLE);

1570

1571

@unlink($phpbb_root_path . 'cache/data_global.php');

1572

cache_moderators();

1573

1574

// And finally, add a note to the log

1575

add_log('admin', 'LOG_INSTALL_CONVERTED', $convert->convertor_data['forum_name'], $config['version']);

1576

1577

$url = $this->p_master->module_url . "?mode={$this->mode}&sub=final&language=$language";

1578

1579

$template->assign_vars(array(

1580

'L_SUBMIT' => $user->lang['FINAL_STEP'],

1581

'U_ACTION' => $url,

1582

));

1583

1584

$this->meta_refresh($url);

1585

return;

1586

}

1587

1588

/**

1589

* This function marks the steps after syncing

1590

1591

function final_jump($final_jump)

1592

{

1593

global $template, $user, $src_db, $same_db, $db, $phpbb_root_path, $phpEx, $config, $cache;

1594

global $convert;

1595

1596

$template->assign_block_vars('checks', array(

1597

'S_LEGEND' => true,

1598

'LEGEND' => $user->lang['PROCESS_LAST'],

1599

));

1600

1601

if ($final_jump == 1)

1602

{

1603

$db->sql_return_on_error(true);

1604

1605

update_topics_posted();

1606

1607

$template->assign_block_vars('checks', array(

1608

'TITLE' => $user->lang['UPDATE_TOPICS_POSTED'],

1609

'RESULT' => $user->lang['DONE'],

1610

));

1611

1612

if ($db->sql_error_triggered)

1613

{

1614

$template->assign_vars(array(

1615

'S_ERROR_BOX' => true,

1616

'ERROR_TITLE' => $user->lang['UPDATE_TOPICS_POSTED'],

1617

'ERROR_MSG' => $user->lang['UPDATE_TOPICS_POSTED_ERR'],

1618

));

1619

}

1620

$db->sql_return_on_error(false);

1621

1622

$this->finish_conversion();

1623

return;

1624

}

1625

}

1626

1627

/**

1628

* This function marks the steps before syncing (jump=1)

1629

1630

function jump($jump, $last_statement)

1631

{

1632

global $template, $user, $src_db, $same_db, $db, $phpbb_root_path, $phpEx, $config, $cache;

1633

global $convert;

1634

1635

$template->assign_block_vars('checks', array(

1636

'S_LEGEND' => true,

1637

'LEGEND' => $user->lang['PROCESS_LAST'],

1638

));

1639

1640

if ($jump == 1)

1641

{

1642

// Execute 'last' statements/queries

1643

if (!empty($convert->convertor['execute_last']))

1644

{

1645

if (!is_array($convert->convertor['execute_last']))

1646

{

1647

eval($convert->convertor['execute_last']);

1648

}

1649

else

1650

{

1651

while ($last_statement < sizeof($convert->convertor['execute_last']))

1652

{

1653

eval($convert->convertor['execute_last'][$last_statement]);

1654

1655

$template->assign_block_vars('checks', array(

1656

'TITLE' => $convert->convertor['execute_last'][$last_statement],

1657

'RESULT' => $user->lang['DONE'],

1658

));

1659

1660

$last_statement++;

1661

$url = $this->save_convert_progress('&jump=1&last=' . $last_statement);

1662

1663

$percentage = ($last_statement == 0) ? 0 : floor(100 / (sizeof($convert->convertor['execute_last']) / $last_statement));

1664

$msg = sprintf($user->lang['STEP_PERCENT_COMPLETED'], $last_statement, sizeof($convert->convertor['execute_last']), $percentage);

1665

1666

$template->assign_vars(array(

1667

'L_SUBMIT' => $user->lang['CONTINUE_LAST'],

1668

'L_MESSAGE' => $msg,

1669

'U_ACTION' => $url,

1670

));

1671

1672

$this->meta_refresh($url);

1673

return;

1674

}

1675

}

1676

}

1677

1678

if (!empty($convert->convertor['query_last']))

1679

{

1680

if (!is_array($convert->convertor['query_last']))

1681

{

1682

$convert->convertor['query_last'] = array('target', array($convert->convertor['query_last']));

1683

}

1684

else if (!is_array($convert->convertor['query_last'][0]))

1685

{

1686

$convert->convertor['query_last'] = array(array($convert->convertor['query_last'][0], $convert->convertor['query_last'][1]));

1687

}

1688

1689

foreach ($convert->convertor['query_last'] as $query_last)

1690

{

1691

if ($query_last[0] == 'src')

1692

{

1693

if ($convert->mysql_convert && $same_db)

1694

{

1695

$src_db->sql_query("SET NAMES 'binary'");

1696

}

1697

1698

$src_db->sql_query($query_last[1]);

1699

1700

if ($convert->mysql_convert && $same_db)

1701

{

1702

$src_db->sql_query("SET NAMES 'utf8'");

1703

}

1704

}

1705

else

1706

{

1707

$db->sql_query($query_last[1]);

1708

}

1709

}

1710

}

1711

1712

// Sanity check

1713

$db->sql_return_on_error(false);

1714

$src_db->sql_return_on_error(false);

1715

1716

fix_empty_primary_groups();

1717

1718

if (!isset($config['board_startdate']))

1719

{

1720

$sql = 'SELECT MIN(user_regdate) AS board_startdate

1721

FROM ' . USERS_TABLE;

1722

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

1723

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

1724

$db->sql_freeresult($result);

1725

1726

if (($row['board_startdate'] < $config['board_startdate'] && $row['board_startdate'] > 0) || !isset($config['board_startdate']))

1727

{

1728

set_config('board_startdate', $row['board_startdate']);

1729

$db->sql_query('UPDATE ' . USERS_TABLE . ' SET user_regdate = ' . $row['board_startdate'] . ' WHERE user_id = ' . ANONYMOUS);

1730

}

1731

}

1732

1733

update_dynamic_config();

1734

1735

$template->assign_block_vars('checks', array(

1736

'TITLE' => $user->lang['CLEAN_VERIFY'],

1737

'RESULT' => $user->lang['DONE'],

1738

));

1739

1740

$url = $this->save_convert_progress('&jump=2');

1741

1742

$template->assign_vars(array(

1743

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

1744

'U_ACTION' => $url,

1745

));

1746

1747

$this->meta_refresh($url);

1748

return;

1749

}

1750

1751

if ($jump == 2)

1752

{

1753

$db->sql_query('UPDATE ' . USERS_TABLE . " SET user_permissions = ''");

1754

1755

// TODO: sync() is likely going to bomb out on forums with a considerable amount of topics.

1756

// TODO: the sync function is able to handle FROM-TO values, we should use them here (batch processing)

1757

sync('forum', '', '', false, true);

1758

$cache->destroy('sql', FORUMS_TABLE);

1759

1760

$template->assign_block_vars('checks', array(

1761

'TITLE' => $user->lang['SYNC_FORUMS'],

1762

'RESULT' => $user->lang['DONE'],

1763

));

1764

1765

// Continue with synchronizing the forums...

1766

$url = $this->save_convert_progress('&sync_batch=0');

1767

1768

$template->assign_vars(array(

1769

'L_SUBMIT' => $user->lang['CONTINUE_CONVERT'],

1770

'U_ACTION' => $url,

1771

));

1772

1773

$this->meta_refresh($url);

1774

return;

1775

}

1776

}

1777

1778

function build_insert_query(&$schema, &$sql_data, $current_table)

1779

{

1780

global $db, $user;

1781

global $convert;

1782

1783

// Can we use IGNORE with this DBMS?

1784

$sql_ignore = (strpos($db->sql_layer, 'mysql') === 0 && !defined('DEBUG_EXTRA')) ? 'IGNORE ' : '';

1785

$insert_query = 'INSERT ' . $sql_ignore . 'INTO ' . $schema['target'] . ' (';

1786

1787

$aliases = array();

1788

1789

$sql_data = array(

1790

'source_fields' => array(),

1791

'target_fields' => array(),

1792

'source_tables' => array(),

1793

'select_fields' => array(),

1794

);

1795

1796

foreach ($schema as $key => $val)

1797

{

1798

// Example: array('group_name', 'extension_groups.group_name', 'htmlspecialchars'),

1799

if (is_int($key))

1800

{

1801

if (!empty($val[0]))

1802

{

1803

// Target fields

1804

$sql_data['target_fields'][$val[0]] = $key;

1805

$insert_query .= $val[0] . ', ';

1806

}

1807

1808

if (!is_array($val[1]))

1809

{

1810

$val[1] = array($val[1]);

1811

}

1812

1813

foreach ($val[1] as $valkey => $value_1)

1814

{

1815

// This should cover about any case:

1816

1817

// table.field => SELECT table.field FROM table

1818

// table.field AS alias => SELECT table.field AS alias FROM table

1819

// table.field AS table2.alias => SELECT table2.field AS alias FROM table table2

1820

// table.field AS table2.field => SELECT table2.field FROM table table2

1821

1822

if (preg_match('/^([a-z0-9_]+)\.([a-z0-9_]+)( +AS +(([a-z0-9_]+?)\.)?([a-z0-9_]+))?$/i', $value_1, $m))

1823

{

1824

// There is 'AS ...' in the field names

1825

if (!empty($m[3]))

1826

{

1827

$value_1 = ($m[2] == $m[6]) ? $m[1] . '.' . $m[2] : $m[1] . '.' . $m[2] . ' AS ' . $m[6];

1828

1829

// Table alias: store it then replace the source table with it

1830

if (!empty($m[5]) && $m[5] != $m[1])

1831

{

1832

$aliases[$m[5]] = $m[1];

1833

$value_1 = str_replace($m[1] . '.' . $m[2], $m[5] . '.' . $m[2], $value_1);

1834

}

1835

}

1836

else

1837

{

1838

// No table alias

1839

$sql_data['source_tables'][$m[1]] = (empty($convert->src_table_prefix)) ? $m[1] : $convert->src_table_prefix . $m[1] . ' ' . $m[1];

1840

}

1841

1842

$sql_data['select_fields'][$value_1] = $value_1;

1843

$sql_data['source_fields'][$key][$valkey] = (!empty($m[6])) ? $m[6] : $m[2];

1844

}

1845

}

1846

}

1847

else if ($key == 'where' || $key == 'group_by' || $key == 'order_by' || $key == 'having')

1848

{

1849

if (@preg_match_all('/([a-z0-9_]+)\.([a-z0-9_]+)/i', $val, $m))

1850

{

1851

foreach ($m[1] as $value)

1852

{

1853

$sql_data['source_tables'][$value] = (empty($convert->src_table_prefix)) ? $value : $convert->src_table_prefix . $value . ' ' . $value;

1854

}

1855

}

1856

}

1857

}

1858

1859

// Add the aliases to the list of tables

1860

foreach ($aliases as $alias => $table)

1861

{

1862

$sql_data['source_tables'][$alias] = $convert->src_table_prefix . $table . ' ' . $alias;

1863

}

1864

1865

// 'left_join' => 'forums LEFT JOIN forum_prune ON forums.forum_id = forum_prune.forum_id',

1866

if (!empty($schema['left_join']))

1867

{

1868

if (!is_array($schema['left_join']))

1869

{

1870

$schema['left_join'] = array($schema['left_join']);

1871

}

1872

1873

foreach ($schema['left_join'] as $left_join)

1874

{

1875

// This won't handle concatened LEFT JOINs

1876

if (!preg_match('/([a-z0-9_]+) LEFT JOIN ([a-z0-9_]+) A?S? ?([a-z0-9_]*?) ?(ON|USING)(.*)/i', $left_join, $m))

1877

{

1878

$this->p_master->error(sprintf($user->lang['NOT_UNDERSTAND'], 'LEFT JOIN', $left_join, $current_table, $schema['target']), __LINE__, __FILE__);

1879

}

1880

1881

if (!empty($aliases[$m[2]]))

1882

{

1883

if (!empty($m[3]))

1884

{

1885

$this->p_master->error(sprintf($user->lang['NAMING_CONFLICT'], $m[2], $m[3], $schema['left_join']), __LINE__, __FILE__);

1886

}

1887

1888

$m[2] = $aliases[$m[2]];

1889

$m[3] = $m[2];

1890

}

1891

1892

$right_table = $convert->src_table_prefix . $m[2];

1893

if (!empty($m[3]))

1894

{

1895

unset($sql_data['source_tables'][$m[3]]);

1896

}

1897

else if ($m[2] != $m[1])

1898

{

1899

unset($sql_data['source_tables'][$m[2]]);

1900

}

1901

1902

if (strpos($sql_data['source_tables'][$m[1]], "\nLEFT JOIN") !== false)

1903

{

1904

$sql_data['source_tables'][$m[1]] = '(' . $sql_data['source_tables'][$m[1]] . ")\nLEFT JOIN $right_table";

1905

}

1906

else

1907

{

1908

$sql_data['source_tables'][$m[1]] .= "\nLEFT JOIN $right_table";

1909

}

1910

1911

if (!empty($m[3]))

1912

{

1913

unset($sql_data['source_tables'][$m[3]]);

1914

$sql_data['source_tables'][$m[1]] .= ' AS ' . $m[3];

1915

}

1916

else if (!empty($convert->src_table_prefix))

1917

{

1918

$sql_data['source_tables'][$m[1]] .= ' AS ' . $m[2];

1919

}

1920

$sql_data['source_tables'][$m[1]] .= ' ' . $m[4] . $m[5];

1921

}

1922

}

1923

1924

// Remove ", " from the end of the insert query

1925

$insert_query = substr($insert_query, 0, -2) . ') VALUES ';

1926

1927

return $insert_query;

1928

}

1929

1930

/**

1931

* Function for processing the currently handled row

1932

1933

function process_row(&$schema, &$sql_data, &$insert_values)

1934

{

1935

global $template, $user, $phpbb_root_path, $phpEx, $db, $lang, $config, $cache;

1936

global $convert, $convert_row;

1937

1938

$sql_flag = false;

1939

1940

foreach ($schema as $key => $fields)

1941

{

1942

// We are only interested in the lines with:

1943

// array('comment', 'attachments_desc.comment', 'htmlspecialchars'),

1944

if (is_int($key))

1945

{

1946

if (!is_array($fields[1]))

1947

{

1948

$fields[1] = array($fields[1]);

1949

}

1950

1951

$firstkey_set = false;

1952

$firstkey = 0;

1953

1954

foreach ($fields[1] as $inner_key => $inner_value)

1955

{

1956

if (!$firstkey_set)

1957

{

1958

$firstkey = $inner_key;

1959

$firstkey_set = true;

1960

}

1961

1962

$src_field = isset($sql_data['source_fields'][$key][$inner_key]) ? $sql_data['source_fields'][$key][$inner_key] : '';

1963

1964

if (!empty($src_field))

1965

{

1966

$fields[1][$inner_key] = $convert->row[$src_field];

1967

}

1968

}

1969

1970

if (!empty($fields[0]))

1971

{

1972

// We have a target field, if we haven't set $sql_flag yet it will be set to TRUE.

1973

// If a function has already set it to FALSE it won't change it.

1974

if ($sql_flag === false)

1975

{

1976

$sql_flag = true;

1977

}

1978

1979

// No function assigned?

1980

if (empty($fields[2]))

1981

{

1982

$value = $fields[1][$firstkey];

1983

}

1984

else if (is_array($fields[2]))

1985

{

1986

// Execute complex function/eval/typecast

1987

$value = $fields[1];

1988

1989

foreach ($fields[2] as $type => $execution)

1990

{

1991

if (strpos($type, 'typecast') === 0)

1992

{

1993

if (!is_array($value))

1994

{

1995

$value = array($value);

1996

}

1997

$value = $value[0];

1998

settype($value, $execution);

1999

}

2000

else if (strpos($type, 'function') === 0)

2001

{

2002

if (!is_array($value))

2003

{

2004

$value = array($value);

2005

}

2006

2007

$value = call_user_func_array($execution, $value);

2008

}

2009

else if (strpos($type, 'execute') === 0)

2010

{

2011

if (!is_array($value))

2012

{

2013

$value = array($value);

2014

}

2015

2016

$execution = str_replace('{RESULT}', '$value', $execution);

2017

$execution = str_replace('{VALUE}', '$value', $execution);

2018

eval($execution);

2019

}

2020

}

2021

}

2022

else

2023

{

2024

$value = call_user_func_array($fields[2], $fields[1]);

2025

}

2026

2027

if (is_null($value))

2028

{

2029

$value = '';

2030

}

2031

2032

$insert_values[] = $db->_sql_validate_value($value);

2033

}

2034

else if (!empty($fields[2]))

2035

{

2036

if (is_array($fields[2]))

2037

{

2038

// Execute complex function/eval/typecast

2039

$value = '';

2040

2041

foreach ($fields[2] as $type => $execution)

2042

{

2043

if (strpos($type, 'typecast') === 0)

2044

{

2045

$value = settype($value, $execution);

2046

}

2047

else if (strpos($type, 'function') === 0)

2048

{

2049

if (!is_array($value))

2050

{

2051

$value = array($value);

2052

}

2053

2054

$value = call_user_func_array($execution, $value);

2055

}

2056

else if (strpos($type, 'execute') === 0)

2057

{

2058

if (!is_array($value))

2059

{

2060

$value = array($value);

2061

}

2062

2063

$execution = str_replace('{RESULT}', '$value', $execution);

2064

$execution = str_replace('{VALUE}', '$value', $execution);

2065

eval($execution);

2066

}

2067

}

2068

}

2069

else

2070

{

2071

call_user_func_array($fields[2], $fields[1]);

2072

}

2073

}

2074

}

2075

}

2076

2077

return $sql_flag;

2078

}

2079

2080

/**

2081

* Own meta refresh function to be able to change the global time used

2082

2083

function meta_refresh($url)

2084

{

2085

global $convert, $template;

2086

2087

if ($convert->options['refresh'])

2088

{

2089

// Because we should not rely on correct settings, we simply use the relative path here directly.

2090

$template->assign_vars(array(

2091

'S_REFRESH' => true,

2092

'META' => '<meta http-equiv="refresh" content="5;url=' . $url . '" />')

2093

);

2094

}

2095

}

2096

2097

/**

2098

* The information below will be used to build the input fields presented to the user

2099

2100

var $convert_options = array(

2101

'legend1' => 'SPECIFY_OPTIONS',

2102

'src_dbms' => array('lang' => 'DBMS', 'type' => 'select', 'options' => 'dbms_select(\'{VALUE}\', true)', 'explain' => false),

2103

'src_dbhost' => array('lang' => 'DB_HOST', 'type' => 'text:25:100', 'explain' => true),

2104

'src_dbport' => array('lang' => 'DB_PORT', 'type' => 'text:25:100', 'explain' => true),

2105

'src_dbname' => array('lang' => 'DB_NAME', 'type' => 'text:25:100', 'explain' => false),

2106

'src_dbuser' => array('lang' => 'DB_USERNAME', 'type' => 'text:25:100', 'explain' => false),

2107

'src_dbpasswd' => array('lang' => 'DB_PASSWORD', 'type' => 'password:25:100', 'explain' => false),

2108

'src_table_prefix' => array('lang' => 'TABLE_PREFIX', 'type' => 'text:25:100', 'explain' => false),

2109

//'src_url' => array('lang' => 'FORUM_ADDRESS', 'type' => 'text:50:100', 'explain' => true),

2110

'forum_path' => array('lang' => 'FORUM_PATH', 'type' => 'text:25:100', 'explain' => true),

2111

'refresh' => array('lang' => 'REFRESH_PAGE', 'type' => 'radio:yes_no', 'explain' => true),

2112

);

2113

}

2114

2115

b'\\ No newline at end of file'

Older »