beginTransaction();
$query = "INSERT INTO message ('id',
'sender',
'type',
'book',
'paragraph',
'data',
'doc_id',
'time')
VALUES (NULL,'{$username}',?,?,?,?,?,?)";
$stmt = $PDO->prepare($query);
$arrMsgData = json_decode($data);
foreach ($arrMsgData as $oneMsg) {
$newData = array($oneMsg->type, $oneMsg->book, $oneMsg->para, $oneMsg->data, $oneMsg->docid, time());
$stmt->execute($newData);
}
// 提交更改
$PDO->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = PDO_ErrorInfo();
echo "error - $error[2]
";
} else {
}
}
$query = "select id from message where 1 order by id DESC limit 0,1";
$maxId = PDO_FetchOne($query);
//查询相关文档的消息
echo "";
echo "maxid$maxId";
$query = "select * from message where \"doc_id\" = '$doclist' AND \"id\" > {$lastid} limit 0,10000";
$Fetch = PDO_FetchAll($query);
$iFetch = count($Fetch);
if ($iFetch > 0) {
for ($i = 0; $i < $iFetch; $i++) {
echo "";
echo "" . $Fetch[$i]["id"] . "";
echo "" . $Fetch[$i]["sender"] . "";
echo "" . $Fetch[$i]["type"] . "";
echo "" . $Fetch[$i]["data"] . "";
echo "" . $Fetch[$i]["doc_id"] . "";
echo "";
echo "0";
echo "";
}
}
echo "";