db_insert_templet.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163
  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4. </head>
  5. <body>
  6. <h2>Insert to DB</h2>
  7. <p><a href="index.php">Home</a></p>
  8. <?php
  9. include "./_pdo.php";
  10. if(isset($_GET["from"])==false){
  11. ?>
  12. <form action="db_insert_templet.php" method="get">
  13. From: <input type="text" value="0" name="from"><br>
  14. To: <input type="text" value="216" name="to"><br>
  15. <input type="submit">
  16. </form>
  17. <?php
  18. return;
  19. }
  20. $from=$_GET["from"];
  21. $to=$_GET["to"];
  22. $filelist=array();
  23. $fileNums=0;
  24. $log="";
  25. echo "<h2>$from</h2>";
  26. if(($handle=fopen("filelist.csv",'r'))!==FALSE){
  27. while(($filelist[$fileNums]=fgetcsv($handle,0,','))!==FALSE){
  28. $fileNums++;
  29. }
  30. }
  31. if($to==0 || $to>=$fileNums) $to=$fileNums-1;
  32. $FileName=$filelist[$from][1].".htm";
  33. $fileId=$filelist[$from][0];
  34. $fileId=$filelist[$from][0];
  35. $dirLog="log/";
  36. $dirDb="db/templet/";
  37. $inputFileName=$FileName;
  38. $outputFileNameHead=$filelist[$from][1];
  39. $bookId=$filelist[$from][2];
  40. $vriParNum=0;
  41. $wordOrder=1;
  42. $dirXmlBase="xml/";
  43. $dirXml=$outputFileNameHead."/";
  44. $currChapter="";
  45. $currParNum="";
  46. $arrAllWords[0]=array("id","wid","book","paragraph","word","real","type","gramma","mean","note","part","partmean","bmc","bmt","un","style","vri","sya","si","ka","pi","pa","kam");
  47. $g_wordCounter=0;
  48. $arrUnWords[0]=array("id","word","type","gramma","parent","mean","note","part","partmean","cf","state","delete","tag","len");
  49. $g_unWordCounter=0;
  50. $arrUnPart[0]="word";
  51. $g_unPartCounter=-1;
  52. /*去掉标点符号的统计*/
  53. $arrAllPaliWordsCount=array();
  54. $g_paliWordCounter=0;
  55. $g_wordCounterInSutta=0;
  56. $g_paliWordCountCounter=0;
  57. $xmlfile = $inputFileName;
  58. echo "doing:".$xmlfile."<br>";
  59. $log=$log."$from,$FileName,open\r\n";
  60. $arrInserString=array();
  61. $db_file = $dirDb.$bookId.'_tpl.db3';
  62. PDO_Connect("sqlite:$db_file");
  63. $query="CREATE TABLE 'main' ( 'id' TEXT PRIMARY KEY NOT NULL,
  64. 'book' INTEGER,
  65. 'paragraph' INTEGER,
  66. 'wid' INTEGER,
  67. 'word' TEXT,
  68. 'real' TEXT,
  69. 'type' TEXT,
  70. 'gramma' TEXT,
  71. 'part' TEXT,
  72. 'style' TEXT)";
  73. $stmt = @PDO_Execute($query);
  74. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  75. $error = PDO_ErrorInfo();
  76. print_r($error[2]);
  77. }
  78. $query="CREATE INDEX 'search' ON \"main\" (\"book\", \"paragraph\", \"wid\" ASC)";
  79. $stmt = @PDO_Execute($query);
  80. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  81. $error = PDO_ErrorInfo();
  82. print_r($error[2]);
  83. $log=$log."$from, $FileName, error, $error[2] \r\n";
  84. }
  85. // 打开文件并读取数据
  86. if(($fp=fopen($dirXmlBase.$dirXml.$outputFileNameHead.".csv", "r"))!==FALSE){
  87. while(($data=fgetcsv($fp,0,','))!==FALSE){
  88. //id,wid,book,paragraph,word,real,type,gramma,mean,note,part,partmean,bmc,bmt,un,style,vri,sya,si,ka,pi,pa,kam
  89. $params=array($data[0],
  90. mb_substr($data[2],1),
  91. $data[3],
  92. $data[16],
  93. $data[4],
  94. $data[5],
  95. $data[6],
  96. $data[7],
  97. $data[10],
  98. $data[15]);
  99. $arrInserString[]=$params;
  100. }
  101. fclose($fp);
  102. echo "单词表load:".$dirXmlBase.$dirXml.$outputFileNameHead.".csv<br>";
  103. }
  104. else{
  105. echo "can not open csv file. filename=".$dirXmlBase.$dirXml.$outputFileNameHead.".csv";
  106. }
  107. // 开始一个事务,关闭自动提交
  108. $PDO->beginTransaction();
  109. $query="INSERT INTO main ('id','book','paragraph','wid','word','real','type','gramma','part','style') VALUES (?,?,?,?,?,?,?,?,?,?)";
  110. $stmt = $PDO->prepare($query);
  111. foreach($arrInserString as $oneParam){
  112. $stmt->execute($oneParam);
  113. }
  114. // 提交更改
  115. $PDO->commit();
  116. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  117. $error = PDO_ErrorInfo();
  118. echo "error - $error[2] <br>";
  119. $log=$log."$from, $FileName, error, $error[2] \r\n";
  120. }
  121. else{
  122. $count=count($arrInserString);
  123. echo "updata $count recorders.";
  124. }
  125. $myLogFile = fopen($dirLog."insert_db.log", "a");
  126. fwrite($myLogFile, $log);
  127. fclose($myLogFile);
  128. ?>
  129. <?php
  130. if($from==$to){
  131. echo "<h2>all done!</h2>";
  132. }
  133. else{
  134. echo "<script>";
  135. echo "window.location.assign(\"db_insert_templet.php?from=".($from+1)."&to=".$to."\")";
  136. echo "</script>";
  137. echo "正在载入:".($from+1)."——".$filelist[$from+1][0];
  138. }
  139. ?>
  140. </body>
  141. </html>