217) { $_to = 217; } $to = $_to; $filelist = array(); $fileNums = 0; $log = ""; echo "doing $_from"; if (($handle = fopen(__DIR__."/filelist.csv", 'r')) !== false) { while (($filelist[$fileNums] = fgetcsv($handle, 0, ',')) !== false) { $fileNums++; } } if ($to == 0 || $to >= $fileNums) { $to = $fileNums - 1; } PDO_Connect(_FILE_DB_PALITEXT_,_DB_USERNAME_,_DB_PASSWORD_); for ($from=$_from-1; $from < $to; $from++) { # code... $FileName = $filelist[$from][1] . ".htm"; $fileId = $filelist[$from][0]; $fileId = $filelist[$from][0]; $dirLog = _DIR_LOG_ . "/"; $inputFileName = $FileName; $outputFileNameHead = $filelist[$from][1]; $bookId = $filelist[$from][2]; $vriParNum = 0; $wordOrder = 1; $dirXmlBase = _DIR_PALI_CSV_ . "/"; $dirPaliTextBase = _DIR_PALI_HTML_ . "/"; $dirXml = $outputFileNameHead . "/"; $xmlfile = $inputFileName; echo "doing:" . $xmlfile . PHP_EOL; $log = $log . "$from,$FileName,open\r\n"; $arrInserString = array(); // 打开vri html文件并读取数据 $pali_text_array = array(); if (($fpPaliText = fopen($dirPaliTextBase . $xmlfile, "r")) !== false) { while (($data = fgets($fpPaliText)) !== false) { if (substr($data, 0, 2) === "
0) { if (($inputRow - 1) < count($pali_text_array)) { $data[5] = $pali_text_array[$inputRow - 1]; } $arrInserString[] = $data; } $inputRow++; } fclose($fp); echo "单词表load:" . $dirXmlBase . $dirXml . $outputFileNameHead . ".csv".PHP_EOL; } else { echo "can not open csv file. filename=" . $dirXmlBase . $dirXml . $outputFileNameHead . ".csv"; continue; } if (($inputRow - 1) != count($pali_text_array)) { $log = $log . "$from, $FileName,error,文件行数不匹配 inputRow=$inputRow pali_text_array=" . count($pali_text_array) . " \r\n"; echo "line count error".PHP_EOL; } #删除 旧数据 $query = "DELETE FROM "._TABLE_PALI_TEXT_." WHERE book=?"; PDO_Execute($query,array($from+1)); // 开始一个事务,关闭自动提交 $PDO->beginTransaction(); $query = "INSERT INTO "._TABLE_PALI_TEXT_." ( book , paragraph , level , class , toc , text , html , lenght ) VALUES ( ? , ? , ? , ? , ? , ? , ? , ? )"; $stmt = $PDO->prepare($query); foreach ($arrInserString as $oneParam) { if ($oneParam[3] < 100) { $toc = $oneParam[6]; } else { $toc = ""; } $newData = array($from + 1, $oneParam[2], $oneParam[3], $oneParam[4], $toc, $oneParam[6], $oneParam[5], mb_strlen($oneParam[6], "UTF-8")); $stmt->execute($newData); } // 提交更改 $PDO->commit(); if (!$stmt || ($stmt && $stmt->errorCode() != 0)) { $error = PDO_ErrorInfo(); echo "error - $error[2]".PHP_EOL; $log = $log . "$from, $FileName, error, $error[2] \r\n"; } else { $count = count($arrInserString); echo "updata $count recorders.".PHP_EOL; } /* $myLogFile = fopen($dirLog . "db_insert_palitext.log", "a"); fwrite($myLogFile, $log); fclose($myLogFile); */ } echo "all done!".PHP_EOL; ?>