xiuno2flarum.php
· 9.9 KiB · PHP
Brut
<?php
/**
* # XiunoBBS 转 Flarum
* ## 使用说明
* ### 注意：本程序只转移 主题、帖子和版块，不转会员
*
* 1. 将本文件上传到两个网站共同的服务器（只要支持两个站的数据库连接均可）
* 2. 复制 xiunobbs 下的 conf/conf.php 到本目录，或者自己修改以下的引入路径
* 3. 复制 flarum 下的 config.php 到本目录，或者自己修改以下的引入路径
* 4. 执行 composer require s9e/text-formatter 安装转换的扩展
* 5. 再执行 php xiuno2flarum.php 命令行进行转换即可
*
* 注意：由于 Flarum 程序与 Markdown 兼容问题，本程序转换的数据支持不完美。
*
*/
// Get the autoloader
include __DIR__ . '/vendor/autoload.php';
// Use the Forum bundle. It supports BBCodes, emoticons and autolinking
use s9e\TextFormatter\Bundles\Forum as TextFormatter;
define('XIUNO_PATH', '');
define('FLARUM_PATH', '');
$xb_cfg = include 'conf.php';
$fl_cfg = include 'config.php';
$xn_cfg = $xb_cfg['db']['mysql']['master'];
$dsn_xn = sprintf('mysql:dbname=%s;host=%s;charset=%s', $xn_cfg['name'], $xn_cfg['host'], $xn_cfg['charset']);
$dbh_xn = new PDO($dsn_xn, $xn_cfg['user'], $xn_cfg['password']);
$fm_cfg = $fl_cfg['database'];
$dsn_fl = sprintf('mysql:dbname=%s;host=%s;charset=%s', $fm_cfg['database'], $fm_cfg['host'], $fm_cfg['charset']);
$dbh_fl = new PDO($dsn_fl, $fm_cfg['username'], $fm_cfg['password']);
$dbh_fl->exec('set @@foreign_key_checks=OFF');
function date_at(string $time): string
{
return date('Y-m-s h:i:s', $time);
}
function insert_tags()
{
global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;
$sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'forum`');
$sth->execute();
// $result = $sth->fetchAll(PDO::FETCH_ASSOC);
$dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'tags`');
// $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'tags`');
while($row = $sth->fetch(PDO::FETCH_ASSOC))
{
//print_r($row);
$stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'tags` (id,name,slug,description,position) VALUES (?,?,?,?,?)');
try {
$data = [
$row['fid'],
$row['name'],
'tag_' . $row['fid'],
$row['brief'],
$row['fid'],
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
}
print 'Insert table ' . $fm_cfg['prefix'] . "tags\n";
}
function insert_discussions()
{
global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;
$sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'thread`');
$sth->execute();
// $result = $sth->fetchAll(PDO::FETCH_ASSOC);
$dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'discussions`');
// $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussions`');
$dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_tag`');
$dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_user`');
while($row = $sth->fetch(PDO::FETCH_ASSOC))
{
// print_r($row);
$stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'discussions` (id,title,participant_count,created_at,user_id,first_post_id,last_posted_at,last_posted_user_id,last_post_id,slug,is_sticky) VALUES (?,?,1,FROM_UNIXTIME(?),?,?,FROM_UNIXTIME(?),?,?,"",?)');
try {
$data = [
$row['tid'],
$row['subject'],
$row['create_date'],
$row['uid'],
$row['firstpid'],
$row['last_date'],
$row['lastuid'],
$row['lastpid'],
$row['top'] > 0 ? 1 : 0,
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
$tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_tag` (discussion_id,tag_id) VALUES (?,?)';
$stmt = $dbh_fl->prepare($tag_sql);
try {
$data = [
$row['tid'],
$row['fid'],
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
$tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_user` (user_id,discussion_id,last_read_at,last_read_post_number) VALUES (?,?,FROM_UNIXTIME(?),1)';
$stmt = $dbh_fl->prepare($tag_sql);
try {
$data = [
$row['uid'],
$row['tid'],
$row['last_date'],
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
}
print 'Insert table ' . $fm_cfg['prefix'] . "discussions\n";
}
function insert_posts()
{
global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;
$sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'post` ORDER BY `create_date` ASC');
$sth->execute();
// $result = $sth->fetchAll(PDO::FETCH_ASSOC);
$dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'posts`');
// $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'posts`');
$totals = [];
while($row = $sth->fetch(PDO::FETCH_ASSOC))
{
// print_r($row);
$stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'posts` (id,discussion_id,number,created_at,user_id,type,content,ip_address) VALUES (?,?,?,FROM_UNIXTIME(?),?,"comment",?,?)');
try {
if (! isset($totals[$row['tid']])) {
$totals[$row['tid']] = [];
}
$totals[$row['tid']][] = 1;
// if ($row['isfirst'] === 1) {
// $number_id = 1;
// } else {
// $totals[$row['tid']][] = 1;
// }
$number_id = count($totals[$row['tid']]);
// XML representation, that's what you should store in your database
$xml = TextFormatter::parse($row['message']);
// HTML rendering, that's what you display to the user
$html = TextFormatter::render($xml);
$data = [
$row['pid'],
$row['tid'],
$number_id,
$row['create_date'],
$row['uid'],
// '<r>' . $row['message'] . '</r>',
// '<t>' . $row['message_fmt'] . '</t>',
'<t>' . $html . '</t>',
// $html,
long2ip($row['userip']),
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
}
print 'Insert table ' . $fm_cfg['prefix'] . "posts\n";
}
function fix_discussion_count()
{
global $fm_cfg,$dbh_fl;
$sql = 'SELECT count(*) AS counts, `discussion_id` FROM `' . $fm_cfg['prefix'] . 'posts` GROUP BY `discussion_id`';
$sth = $dbh_fl->prepare($sql);
$sth->execute();
while($row = $sth->fetch(PDO::FETCH_ASSOC))
{
// print_r($row);
$stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'discussions` SET `comment_count` = ?, post_number_index = ?, last_post_number = ? WHERE id = ?');
try {
$data = [
$row['counts'],
$row['counts'],
1,
$row['discussion_id'],
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
}
print 'Update table ' . $fm_cfg['prefix'] . "discussions counts\n";
}
function fix_tag_stat()
{
global $fm_cfg,$dbh_fl;
$sql = 'SELECT *, count(*) AS counts FROM `'. $fm_cfg['prefix'] . 'discussions` GROUP BY `slug` DESC;';
$sth = $dbh_fl->prepare($sql);
$sth->execute();
while($row = $sth->fetch(PDO::FETCH_ASSOC))
{
// print_r($row);
$stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'tags` SET `discussion_count` = ?, last_posted_at = ? , last_posted_discussion_id = ?, last_posted_user_id = ? WHERE slug = ?');
$last_uid = $row['last_posted_user_id'];
if ($last_uid == 0)
{
$last_uid = $row['user_id'];
}
try {
$data = [
$row['counts'],
$row['last_posted_at'],
$row['id'],
$last_uid,
$row['slug'],
];
$dbh_fl->beginTransaction();
$stmt->execute($data);
$dbh_fl->commit();
// print $dbh_fl->lastInsertId();
} catch(PDOExecption $e) {
$dbh_fl->rollback();
print "Error!: " . $e->getMessage() . "\n";
exit;
}
}
print 'Update table ' . $fm_cfg['prefix'] . "tags stat\n";
}
insert_tags();
insert_discussions();
insert_posts();
fix_discussion_count();
fix_tag_stat();
| 1 | <?php |
| 2 | |
| 3 | /** |
| 4 | * # XiunoBBS 转 Flarum |
| 5 | * ## 使用说明 |
| 6 | * ### 注意：本程序只转移 主题、帖子和版块，不转会员 |
| 7 | * |
| 8 | * 1. 将本文件上传到两个网站共同的服务器（只要支持两个站的数据库连接均可） |
| 9 | * 2. 复制 xiunobbs 下的 conf/conf.php 到本目录，或者自己修改以下的引入路径 |
| 10 | * 3. 复制 flarum 下的 config.php 到本目录，或者自己修改以下的引入路径 |
| 11 | * 4. 执行 composer require s9e/text-formatter 安装转换的扩展 |
| 12 | * 5. 再执行 php xiuno2flarum.php 命令行进行转换即可 |
| 13 | * |
| 14 | * 注意：由于 Flarum 程序与 Markdown 兼容问题，本程序转换的数据支持不完美。 |
| 15 | * |
| 16 | */ |
| 17 | |
| 18 | // Get the autoloader |
| 19 | include __DIR__ . '/vendor/autoload.php'; |
| 20 | |
| 21 | // Use the Forum bundle. It supports BBCodes, emoticons and autolinking |
| 22 | use s9e\TextFormatter\Bundles\Forum as TextFormatter; |
| 23 | |
| 24 | define('XIUNO_PATH', ''); |
| 25 | define('FLARUM_PATH', ''); |
| 26 | |
| 27 | $xb_cfg = include 'conf.php'; |
| 28 | $fl_cfg = include 'config.php'; |
| 29 | |
| 30 | $xn_cfg = $xb_cfg['db']['mysql']['master']; |
| 31 | $dsn_xn = sprintf('mysql:dbname=%s;host=%s;charset=%s', $xn_cfg['name'], $xn_cfg['host'], $xn_cfg['charset']); |
| 32 | $dbh_xn = new PDO($dsn_xn, $xn_cfg['user'], $xn_cfg['password']); |
| 33 | |
| 34 | $fm_cfg = $fl_cfg['database']; |
| 35 | $dsn_fl = sprintf('mysql:dbname=%s;host=%s;charset=%s', $fm_cfg['database'], $fm_cfg['host'], $fm_cfg['charset']); |
| 36 | $dbh_fl = new PDO($dsn_fl, $fm_cfg['username'], $fm_cfg['password']); |
| 37 | |
| 38 | $dbh_fl->exec('set @@foreign_key_checks=OFF'); |
| 39 | |
| 40 | function date_at(string $time): string |
| 41 | { |
| 42 | return date('Y-m-s h:i:s', $time); |
| 43 | } |
| 44 | |
| 45 | function insert_tags() |
| 46 | { |
| 47 | global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl; |
| 48 | |
| 49 | $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'forum`'); |
| 50 | $sth->execute(); |
| 51 | // $result = $sth->fetchAll(PDO::FETCH_ASSOC); |
| 52 | |
| 53 | $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'tags`'); |
| 54 | // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'tags`'); |
| 55 | |
| 56 | while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
| 57 | { |
| 58 | //print_r($row); |
| 59 | $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'tags` (id,name,slug,description,position) VALUES (?,?,?,?,?)'); |
| 60 | |
| 61 | try { |
| 62 | $data = [ |
| 63 | $row['fid'], |
| 64 | $row['name'], |
| 65 | 'tag_' . $row['fid'], |
| 66 | $row['brief'], |
| 67 | $row['fid'], |
| 68 | ]; |
| 69 | |
| 70 | $dbh_fl->beginTransaction(); |
| 71 | $stmt->execute($data); |
| 72 | $dbh_fl->commit(); |
| 73 | // print $dbh_fl->lastInsertId(); |
| 74 | } catch(PDOExecption $e) { |
| 75 | $dbh_fl->rollback(); |
| 76 | print "Error!: " . $e->getMessage() . "\n"; |
| 77 | exit; |
| 78 | } |
| 79 | } |
| 80 | |
| 81 | print 'Insert table ' . $fm_cfg['prefix'] . "tags\n"; |
| 82 | } |
| 83 | |
| 84 | function insert_discussions() |
| 85 | { |
| 86 | global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl; |
| 87 | |
| 88 | $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'thread`'); |
| 89 | $sth->execute(); |
| 90 | // $result = $sth->fetchAll(PDO::FETCH_ASSOC); |
| 91 | |
| 92 | $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'discussions`'); |
| 93 | // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussions`'); |
| 94 | $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_tag`'); |
| 95 | $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_user`'); |
| 96 | |
| 97 | while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
| 98 | { |
| 99 | // print_r($row); |
| 100 | $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'discussions` (id,title,participant_count,created_at,user_id,first_post_id,last_posted_at,last_posted_user_id,last_post_id,slug,is_sticky) VALUES (?,?,1,FROM_UNIXTIME(?),?,?,FROM_UNIXTIME(?),?,?,"",?)'); |
| 101 | |
| 102 | try { |
| 103 | $data = [ |
| 104 | $row['tid'], |
| 105 | $row['subject'], |
| 106 | $row['create_date'], |
| 107 | $row['uid'], |
| 108 | $row['firstpid'], |
| 109 | $row['last_date'], |
| 110 | $row['lastuid'], |
| 111 | $row['lastpid'], |
| 112 | $row['top'] > 0 ? 1 : 0, |
| 113 | ]; |
| 114 | |
| 115 | $dbh_fl->beginTransaction(); |
| 116 | $stmt->execute($data); |
| 117 | $dbh_fl->commit(); |
| 118 | // print $dbh_fl->lastInsertId(); |
| 119 | } catch(PDOExecption $e) { |
| 120 | $dbh_fl->rollback(); |
| 121 | print "Error!: " . $e->getMessage() . "\n"; |
| 122 | exit; |
| 123 | } |
| 124 | |
| 125 | $tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_tag` (discussion_id,tag_id) VALUES (?,?)'; |
| 126 | $stmt = $dbh_fl->prepare($tag_sql); |
| 127 | try { |
| 128 | $data = [ |
| 129 | $row['tid'], |
| 130 | $row['fid'], |
| 131 | ]; |
| 132 | |
| 133 | $dbh_fl->beginTransaction(); |
| 134 | $stmt->execute($data); |
| 135 | $dbh_fl->commit(); |
| 136 | // print $dbh_fl->lastInsertId(); |
| 137 | } catch(PDOExecption $e) { |
| 138 | $dbh_fl->rollback(); |
| 139 | print "Error!: " . $e->getMessage() . "\n"; |
| 140 | exit; |
| 141 | } |
| 142 | |
| 143 | $tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_user` (user_id,discussion_id,last_read_at,last_read_post_number) VALUES (?,?,FROM_UNIXTIME(?),1)'; |
| 144 | $stmt = $dbh_fl->prepare($tag_sql); |
| 145 | try { |
| 146 | $data = [ |
| 147 | $row['uid'], |
| 148 | $row['tid'], |
| 149 | $row['last_date'], |
| 150 | ]; |
| 151 | |
| 152 | $dbh_fl->beginTransaction(); |
| 153 | |
| 154 | $stmt->execute($data); |
| 155 | $dbh_fl->commit(); |
| 156 | // print $dbh_fl->lastInsertId(); |
| 157 | } catch(PDOExecption $e) { |
| 158 | $dbh_fl->rollback(); |
| 159 | print "Error!: " . $e->getMessage() . "\n"; |
| 160 | exit; |
| 161 | } |
| 162 | } |
| 163 | |
| 164 | print 'Insert table ' . $fm_cfg['prefix'] . "discussions\n"; |
| 165 | } |
| 166 | |
| 167 | function insert_posts() |
| 168 | { |
| 169 | global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl; |
| 170 | |
| 171 | $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'post` ORDER BY `create_date` ASC'); |
| 172 | $sth->execute(); |
| 173 | // $result = $sth->fetchAll(PDO::FETCH_ASSOC); |
| 174 | |
| 175 | $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'posts`'); |
| 176 | // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'posts`'); |
| 177 | |
| 178 | $totals = []; |
| 179 | while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
| 180 | { |
| 181 | // print_r($row); |
| 182 | $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'posts` (id,discussion_id,number,created_at,user_id,type,content,ip_address) VALUES (?,?,?,FROM_UNIXTIME(?),?,"comment",?,?)'); |
| 183 | |
| 184 | try { |
| 185 | if (! isset($totals[$row['tid']])) { |
| 186 | $totals[$row['tid']] = []; |
| 187 | } |
| 188 | $totals[$row['tid']][] = 1; |
| 189 | |
| 190 | // if ($row['isfirst'] === 1) { |
| 191 | // $number_id = 1; |
| 192 | // } else { |
| 193 | // $totals[$row['tid']][] = 1; |
| 194 | // } |
| 195 | $number_id = count($totals[$row['tid']]); |
| 196 | |
| 197 | // XML representation, that's what you should store in your database |
| 198 | $xml = TextFormatter::parse($row['message']); |
| 199 | |
| 200 | // HTML rendering, that's what you display to the user |
| 201 | $html = TextFormatter::render($xml); |
| 202 | |
| 203 | $data = [ |
| 204 | $row['pid'], |
| 205 | $row['tid'], |
| 206 | $number_id, |
| 207 | $row['create_date'], |
| 208 | $row['uid'], |
| 209 | // '<r>' . $row['message'] . '</r>', |
| 210 | // '<t>' . $row['message_fmt'] . '</t>', |
| 211 | '<t>' . $html . '</t>', |
| 212 | // $html, |
| 213 | long2ip($row['userip']), |
| 214 | ]; |
| 215 | |
| 216 | $dbh_fl->beginTransaction(); |
| 217 | $stmt->execute($data); |
| 218 | $dbh_fl->commit(); |
| 219 | // print $dbh_fl->lastInsertId(); |
| 220 | } catch(PDOExecption $e) { |
| 221 | $dbh_fl->rollback(); |
| 222 | print "Error!: " . $e->getMessage() . "\n"; |
| 223 | exit; |
| 224 | } |
| 225 | } |
| 226 | |
| 227 | print 'Insert table ' . $fm_cfg['prefix'] . "posts\n"; |
| 228 | } |
| 229 | |
| 230 | function fix_discussion_count() |
| 231 | { |
| 232 | global $fm_cfg,$dbh_fl; |
| 233 | |
| 234 | $sql = 'SELECT count(*) AS counts, `discussion_id` FROM `' . $fm_cfg['prefix'] . 'posts` GROUP BY `discussion_id`'; |
| 235 | $sth = $dbh_fl->prepare($sql); |
| 236 | $sth->execute(); |
| 237 | |
| 238 | while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
| 239 | { |
| 240 | // print_r($row); |
| 241 | $stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'discussions` SET `comment_count` = ?, post_number_index = ?, last_post_number = ? WHERE id = ?'); |
| 242 | |
| 243 | try { |
| 244 | $data = [ |
| 245 | $row['counts'], |
| 246 | $row['counts'], |
| 247 | 1, |
| 248 | $row['discussion_id'], |
| 249 | ]; |
| 250 | |
| 251 | $dbh_fl->beginTransaction(); |
| 252 | $stmt->execute($data); |
| 253 | $dbh_fl->commit(); |
| 254 | // print $dbh_fl->lastInsertId(); |
| 255 | } catch(PDOExecption $e) { |
| 256 | $dbh_fl->rollback(); |
| 257 | print "Error!: " . $e->getMessage() . "\n"; |
| 258 | exit; |
| 259 | } |
| 260 | } |
| 261 | |
| 262 | print 'Update table ' . $fm_cfg['prefix'] . "discussions counts\n"; |
| 263 | } |
| 264 | |
| 265 | |
| 266 | function fix_tag_stat() |
| 267 | { |
| 268 | global $fm_cfg,$dbh_fl; |
| 269 | |
| 270 | $sql = 'SELECT *, count(*) AS counts FROM `'. $fm_cfg['prefix'] . 'discussions` GROUP BY `slug` DESC;'; |
| 271 | $sth = $dbh_fl->prepare($sql); |
| 272 | $sth->execute(); |
| 273 | |
| 274 | while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
| 275 | { |
| 276 | // print_r($row); |
| 277 | $stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'tags` SET `discussion_count` = ?, last_posted_at = ? , last_posted_discussion_id = ?, last_posted_user_id = ? WHERE slug = ?'); |
| 278 | |
| 279 | $last_uid = $row['last_posted_user_id']; |
| 280 | if ($last_uid == 0) |
| 281 | { |
| 282 | $last_uid = $row['user_id']; |
| 283 | } |
| 284 | |
| 285 | try { |
| 286 | $data = [ |
| 287 | $row['counts'], |
| 288 | $row['last_posted_at'], |
| 289 | $row['id'], |
| 290 | $last_uid, |
| 291 | $row['slug'], |
| 292 | ]; |
| 293 | |
| 294 | $dbh_fl->beginTransaction(); |
| 295 | $stmt->execute($data); |
| 296 | $dbh_fl->commit(); |
| 297 | // print $dbh_fl->lastInsertId(); |
| 298 | } catch(PDOExecption $e) { |
| 299 | $dbh_fl->rollback(); |
| 300 | print "Error!: " . $e->getMessage() . "\n"; |
| 301 | exit; |
| 302 | } |
| 303 | } |
| 304 | |
| 305 | print 'Update table ' . $fm_cfg['prefix'] . "tags stat\n"; |
| 306 | } |
| 307 | |
| 308 | insert_tags(); |
| 309 | insert_discussions(); |
| 310 | insert_posts(); |
| 311 | fix_discussion_count(); |
| 312 | fix_tag_stat(); |
| 313 |