discuz7.2升级discuz!X2中polloptions.php和pollvoter.php不能正常运行的解决方案
使用转换程序convert把论坛从版本discuz！7.2升级到discuz！X2的过程中，polloptions.php和pollvoter.php报错。我把升级过程分步骤描述如下：
polloptions.php程序的修改：
一、为了减少转换程序的压力，把每次转换数据的数量从1000减小为100.
二、把forum_polloption表的插入操作拿到数据库中完成，运行一下SQL语句：
1 2 3 |
TRUNCATE `ultrax2`.pre_forum_polloption; REPLACE INTO `ultrax2`.pre_forum_polloption (polloptionid,tid,votes,displayorder,polloption,voterids)(SELECT polloptionid,tid,votes,displayorder,polloption,voterids FROM `discuz`.cdb_polloptions); |
三、修改以下程序，见程序中注释。注意：在对$voterids遍历循环操作中（修改后的第46行）添加is_numeric的判断，因为原discuz!7.2中$voterids有很多是IP地址，并不全都是uid，这时要把ip地址的投票者进行过滤。
四、把polloptions.php修改前第38行的调用members表赋值forum_pollvoter表username的操作取消，放到转换程序运行之后再用sql语句完成。
1 |
update pre_forum_pollvoter set pre_forum_pollvoter.username= (SELECT pre_common_member.username from pre_common_member WHERE pre_common_member.uid = pre_forum_pollvoter.uid) |
\convert\source\d7.2_x2.0\table\polloptions.php的修改前是这样的，可以跟修改后的做比较：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 |
<?php /** * DiscuzX Convert * * $Id: polloptions.php 19528 2011-01-05 09:12:03Z liulanbo $ */ $curprg = basename(__FILE__); $table_source = $db_source->tablepre . 'polloptions'; $table_target = $db_target->tablepre . 'forum_polloption'; $table_pollvoter = $db_target->tablepre . 'forum_pollvoter'; $limit = $setting['limit']['polloptions'] ? $setting['limit']['polloptions'] : 1000; $nextid = 0; $start = getgpc('start'); $continue = false; if(!$start) { $db_target->query("TRUNCATE $table_target"); $db_target->query("TRUNCATE $table_pollvoter"); } $query = $db_source->query("SELECT * FROM $table_source WHERE polloptionid>'$start' LIMIT $limit"); while($row = $db_source->fetch_array($query)) { $nextid = $row['polloptionid']; $row = daddslashes($row, 1); $data = implode_field_value($row, ',', db_table_fields($db_target, $table_target)); $db_target->query("INSERT INTO $table_target SET $data"); $voterids = trim($row['voterids']); $voterids = explode("\t", $voterids); foreach($voterids as $voterid) { $count = $db_target->result_first("SELECT COUNT(*) FROM $table_pollvoter WHERE tid='{$row['tid']}' AND uid='$voterid' LIMIT 1"); if(!$count) { $username = daddslashes($db_source->result_first("SELECT username FROM {$db_source->tablepre}members WHERE uid='$voterid'"), 1); $db_target->query("INSERT INTO $table_pollvoter SET tid='{$row['tid']}', uid='$voterid', username='$username', options='', dateline='0'"); } } } if($nextid) { showmessage("继续转换数据表 ".$table_source." polloptionid > $nextid", "index.php?a=$action&source=$source&prg=$curprg&start=$nextid"); } ?> |
\convert\source\d7.2_x2.0\table\polloptions.php的修改后：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
<?php /** * DiscuzX Convert * * $Id: polloptions.php 19528 2011-01-05 09:12:03Z liulanbo $ */ $curprg = basename(__FILE__); $table_source = $db_source->tablepre . 'polloptions'; $table_target = $db_target->tablepre . 'forum_polloption'; $table_pollvoter = $db_target->tablepre . 'forum_pollvoter'; $limit = $setting['limit']['polloptions'] ? $setting['limit']['polloptions'] : 1000; $limit = 100;//修改处一：这个数值改小一点比较好，以免数据量过大而导致程序运行超时。 $nextid = 0; $start = getgpc('start'); $continue = false; if(!$start) { //$db_target->query("TRUNCATE $table_target");//这里要注释掉，在这里不进行forum_polloption表的操作 $db_target->query("TRUNCATE $table_pollvoter"); } $query = $db_source->query("SELECT * FROM $table_source WHERE polloptionid>'$start' LIMIT $limit"); while($row = $db_source->fetch_array($query)) { $nextid = $row['polloptionid']; $row = daddslashes($row, 1); /*修改处二： //对于forum_polloption表的插入操作，在这里不执行，直接用mysql语句来完成。 TRUNCATE `ultrax2`.pre_forum_polloption; REPLACE INTO `ultrax2`.pre_forum_polloption (polloptionid,tid,votes,displayorder,polloption,voterids)(SELECT polloptionid,tid,votes,displayorder,polloption,voterids FROM `discuz`.cdb_polloptions); 以上SQL语句可以在执行本程序之前来执行也可以在本程序完毕后再执行，但要在执行pollvoter之前。 */ //$data = implode_field_value($row, ',', db_table_fields($db_target, $table_target)); //$db_target->query("INSERT INTO $table_target SET $data"); $voterids = trim($row['voterids']); $voterids = explode("\t", $voterids); foreach($voterids as $voterid) { if(is_numeric($voterid))//需要判断一下，因为有的voterid值是ip地址 { $count = $db_target->result_first("SELECT COUNT(*) FROM $table_pollvoter WHERE tid='{$row['tid']}' AND uid='$voterid' LIMIT 1"); if(!$count) { /*修改处三： //这一步操作也放到后边直接在mysql中执行下面的sql语句，减少转换程序的压力。 update pre_forum_pollvoter set pre_forum_pollvoter.username= (SELECT pre_common_member.username from pre_common_member WHERE pre_common_member.uid = pre_forum_pollvoter.uid) 以上SQL语句放在执行本程序完毕后再执行，但要在执行pollvoter之前。 */ //$username = daddslashes($db_source->result_first("SELECT username FROM {$db_source->tablepre}members WHERE uid='$voterid'"), 1); $username='';//把$username设置为空 $db_target->query("INSERT INTO $table_pollvoter SET tid='{$row['tid']}', uid='$voterid', username='$username', options='', dateline='0'"); } } } } if($nextid) { showmessage("继续转换数据表 ".$table_source." polloptionid > $nextid", "index.php?a=$action&source=$source&prg=$curprg&start=$nextid"); } ?> |
对pollvoter.php程序的修改：
文件路径：\convert\source\d7.2_x2.0\pollvoter.php
操作步骤：
1.同样是把$limit值改为100.
2.在程序第30行处对$voterid进行数字判断“if(is_numeric($voterid))”。
3.该程序有一处错误。程序源码的第33行：把$options[] = $row[‘polloptionid’];修改为$options[] .= $row[‘polloptionid’];//这个地方少了一个点，应该是.=。
4.把第35、36行拿到第32行的if语句之内，因为当polloptionid值在数据中已经存在时就没必要再重复一遍了。
pollvoter.php程序修改前后的代码如下：
修改前：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 |
<?php /** * DiscuzX Convert * * $Id: pollvoter.php 19528 2011-01-05 09:12:03Z liulanbo $ */ $curprg = basename(__FILE__); $table_source = $db_source->tablepre . 'polloptions'; $table_target = $db_target->tablepre . 'forum_pollvoter'; $limit = 1000; $pstep = getgpc('pstep'); $pstep = intval($pstep); $total = getgpc('total'); $total = intval($total); $offset = $pstep * $limit; $continue = false; $query = $db_source->query("SELECT * FROM $table_source ORDER BY polloptionid LIMIT $offset, $limit"); while($row = $db_source->fetch_array($query)) { $voterids = trim($row['voterids']); $voterids = explode("\t", $voterids); foreach($voterids as $voterid) { $options = $db_target->result_first("SELECT options FROM $table_target WHERE tid='{$row['tid']}' AND uid='$voterid'"); $options = explode("\t", $options); if(!in_array($row['polloptionid'], $options)) { $options[] = $row['polloptionid']; } $options_str = trim(implode("\t", $options)); $db_target->query("UPDATE $table_target SET options='$options_str' WHERE tid='{$row['tid']}' AND uid='$voterid'"); } $continue = true; $total ++; } $nextpstep = $pstep + 1; if($continue) { showmessage("继续转换数据表 ".$table_source."，已转换 $total 条记录。", "index.php?a=$action&source=$source&prg=$curprg&pstep=$nextpstep&total=$total"); } ?> |
修改后：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 |
<?php /** * DiscuzX Convert * * $Id: pollvoter.php 19528 2011-01-05 09:12:03Z liulanbo $ */ $curprg = basename(__FILE__); $table_source = $db_source->tablepre . 'polloptions'; $table_target = $db_target->tablepre . 'forum_pollvoter'; $limit = 100;//这个数值改小一点比较好，以免数据量过大而导致程序运行超时。 $pstep = getgpc('pstep'); $pstep = intval($pstep); if(!$pstep) { $db_target->query("update $table_target set options=''"); } $total = getgpc('total'); $total = intval($total); $offset = $pstep * $limit; $continue = false; $query = $db_source->query("SELECT * FROM $table_source ORDER BY polloptionid LIMIT $offset, $limit"); while($row = $db_source->fetch_array($query)) { $voterids = trim($row['voterids']); $voterids = explode("\t", $voterids); foreach($voterids as $voterid) { if(is_numeric($voterid))//需要判断一下，因为有的voterid值是ip地址 { $options = $db_target->result_first("SELECT options FROM $table_target WHERE tid='{$row['tid']}' AND uid='$voterid'"); $options = explode("\t", $options); if(!in_array($row['polloptionid'], $options)) { $options[] .= $row['polloptionid'];//这个地方少了一个点，应该是.= $options_str = trim(implode("\t", $options));//这一行和下面的这一行一起拿到if语句之内来，因为如果polloptionid已经存在了就不要再执行一遍update了 $db_target->query("UPDATE $table_target SET options='$options_str' WHERE tid='{$row['tid']}' AND uid='$voterid'"); } } } $continue = true; $total ++; } $nextpstep = $pstep + 1; if($continue) { showmessage("继续转换数据表 ".$table_source."，已转换 $total 条记录。", "index.php?a=$action&source=$source&prg=$curprg&pstep=$nextpstep&total=$total"); } ?> |
