Insert csv to word table
Home
doing : No.{$from} book ";
global $dbh_word_index;
$dns = "sqlite:"._FILE_DB_PALI_INDEX_;
$dbh_word_index = new PDO($dns, "", "",array(PDO::ATTR_PERSISTENT=>true));
$dbh_word_index->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
if(($handle=fopen("filelist.csv",'r'))!==FALSE){
while(($filelist[$fileNums]=fgetcsv($handle,0,','))!==FALSE){
$fileNums++;
}
}
if($to==0 || $to>=$fileNums) $to=$fileNums-1;
if(($fpoutput=fopen(_DIR_CSV_PALI_CANON_WORD_."/{$from}_words.csv", "r"))!==FALSE){
// 开始一个事务，关闭自动提交
$dbh_word_index->beginTransaction();
$query="INSERT INTO word ('id','book','paragraph','wordindex','bold') VALUES (?,?,?,?,?)";
$stmt = $dbh_word_index->prepare($query);
$count=0;
while(($data=fgetcsv($fpoutput,0,','))!==FALSE){
$stmt->execute($data);
$count++;
}
// 提交更改
$dbh_word_index->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = $dbh_word_index->errorInfo();
echo "error - $error[2]
";
$log.="$from, $FileName, error, $error[2] \r\n";
}
else{
echo "updata $count recorders.
";
$log.="updata $count recorders.\r\n";
}
}
$myLogFile = fopen($dirLog."insert_index.log", "a");
fwrite($myLogFile, $log);
fclose($myLogFile);
if($from>=$to){
echo "齐活！功德无量！all done!
";
}
else{
echo "";
echo "正在载入:".($from+1)."——".$filelist[$from+1][0];
}
?>