mint/app/install/db_insert_palitext_cli.php

<?php
/*
生成 巴利原文段落表
 */
require_once __DIR__."/../config.php";
require_once __DIR__.'/../public/_pdo.php';

define("_PG_DB_PALITEXT_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
define("_PG_TABLE_PALI_TEXT_","pali_texts");

echo "Insert Pali Text To DB".PHP_EOL;

if ($argc != 3) {
	echo "help".PHP_EOL;
	echo $argv[0]." from to".PHP_EOL;
	echo "from = 1-217".PHP_EOL;
	echo "to = 1-217".PHP_EOL;
	exit;
}
$_from = (int) $argv[1];
$_to = (int) $argv[2];
if ($_to > 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;
}

$dns = _PG_DB_PALITEXT_;
$dbh = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

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) === "<p") {
                array_push($pali_text_array, $data);
            }
    
        }
        fclose($fpPaliText);
        echo "pali text load：" . $dirPaliTextBase . $xmlfile . PHP_EOL;
    } else {
        echo "can not pali text file. filename=" . $dirPaliTextBase . $xmlfile;
    }
    
    $inputRow = 0;
    if (($fp = fopen($dirXmlBase . $dirXml . $outputFileNameHead . "_pali.csv", "r")) !== false) {
        while (($data = fgetcsv($fp, 0, ',')) !== false) {
            if ($inputRow > 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 "._PG_TABLE_PALI_TEXT_." WHERE book=?";
	$stmt = $dbh->prepare($query);
	try{
		$stmt->execute(array($from+1));
	}catch(PDOException $e){
		fwrite(STDERR,$e->getMessage());
		continue;
	}

    
    // 开始一个事务，关闭自动提交
    $dbh->beginTransaction();
    
    $query = "INSERT INTO "._PG_TABLE_PALI_TEXT_." ( book , paragraph , level , class , toc , text , html , lenght ) VALUES ( ? , ? , ? , ? , ? , ? , ? , ? )";
    $stmt = $dbh->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"));
        try{
			$stmt->execute($newData);
		}catch(PDOException $e){
			fwrite(STDERR,$e->getMessage());
			fwrite(STDERR,implode(",",$newData));
			break;
		}
		
    }
    // 提交更改
    $dbh->commit();
    if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
        $error = $dbh->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;



?>