xpath('//word');
//$serverMsg+= "word count:".count($wordsList)."
";
//remove the same word
foreach ($wordsList as $ws) {
$combine = $ws->pali . $ws->guid . $ws->type . $ws->gramma . $ws->parent . $ws->parent_id . $ws->mean . $ws->factors . $ws->fm . $ws->part_id;
$word[$combine] = $ws;
}
$arrInserString = array();
$arrExistWords = array();
foreach ($word as $x => $ws) {
$query = "select id,ref_counter from dict where
\"guid\"=" . $PDO->quote($ws->guid) . " AND
\"pali\"=" . $PDO->quote($ws->pali) . " AND
\"type\"=" . $PDO->quote($ws->type) . " AND
\"gramma\"=" . $PDO->quote($ws->gramma) . " AND
\"mean\"=" . $PDO->quote($ws->mean) . " AND
\"parent\"=" . $PDO->quote($ws->parent) . " AND
\"parent_id\"=" . $PDO->quote($ws->parent_id) . " AND
\"factors\"=" . $PDO->quote($ws->factors) . " AND
\"factormean\"=" . $PDO->quote($ws->fm) . " AND
\"part_id\"=" . $PDO->quote($ws->part_id);
$Fetch = PDO_FetchAll($query);
$FetchNum = count($Fetch);
if ($FetchNum == 0) {
//new recorder
$params = array($ws->guid,
$ws->pali,
$ws->type,
$ws->gramma,
$ws->parent,
$ws->parent_id,
$ws->mean,
$ws->note,
$ws->factors,
$ws->fm,
$ws->part_id,
$ws->status,
$ws->language,
$UID,
time());
array_push($arrInserString, $params);
} else {
// "have a same recorder";
$wordId = $Fetch[0]["id"];
$ref = $Fetch[0]["ref_counter"] + 1;
//更新引用计数
$query = "UPDATE dict SET ref_counter='$ref' where id=" . $PDO->quote($wordId);
$stmt = @PDO_Execute($query);
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = PDO_ErrorInfo();
echo "error" . $error[2] . "
";
}
//去掉已经有的索引
$query = "select count(*) from user_index where word_index={$wordId} and user_id={$UID}";
$num = PDO_FetchOne($query);
if ($num == 0) {
array_push($arrExistWords, $Fetch[0]["id"]);
}
}
}
/* 开始一个事务，关闭自动提交 */
$PDO->beginTransaction();
$query = "INSERT INTO dict ('id',
'guid',
'pali',
'type',
'gramma',
'parent',
'parent_id',
'mean',
'note',
'factors',
'factormean',
'part_id',
'status',
'dict_name',
'language',
'creator',
'time')
VALUES (null,?,?,?,?,?,?,?,?,?,?,?,?,'user',?,?,?)";
$stmt = $PDO->prepare($query);
foreach ($arrInserString as $oneParam) {
$stmt->execute($oneParam);
}
/* 提交更改 */
$PDO->commit();
$lastid = $PDO->lastInsertId();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = PDO_ErrorInfo();
echo "error - $error[2]
";
} else {
$count = count($arrInserString);
echo "updata $count recorders.";
//更新索引表
$iFirst = $lastid - $count + 1;
for ($i = 0; $i < $count; $i++) {
array_push($arrExistWords, $iFirst + $i);
}
if (count($arrExistWords) > 0) {
/* 开始一个事务，关闭自动提交 */
$PDO->beginTransaction();
$query = "INSERT INTO user_index ('id','word_index','user_id','create_time')
VALUES (null,?,{$UID},?)";
$stmt = $PDO->prepare($query);
foreach ($arrExistWords as $oneId) {
$stmt->execute(array($oneId, time()));
}
/* 提交更改 */
$PDO->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = PDO_ErrorInfo();
echo "error - $error[2]
";
} else {
echo "updata index " . count($arrExistWords) . " recorders.";
}
} else {
echo "updata index 0";
}
}