更新的数据库与现在用的库可以不同

app/admin/word_index_weight_refresh.php

@@ -5,6 +5,12 @@
 require_once __DIR__.'/../config.php';
 require_once __DIR__.'/word_index_weight_table.php';
 
+define("_PG_DB_WORD_INDEX_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_WORD_INDEX_", "word_indexs");
+
+define("_PG_DB_PALI_INDEX_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_WORD_", "words");
+
 if (isset($_GET["from"])) {
     $from = (int)$_GET["from"];
     $to = (int)$_GET["to"];
@@ -20,17 +26,17 @@ if (isset($_GET["from"])) {
     }
 }
 
-$dh_word = new PDO( _FILE_DB_WORD_INDEX_, _DB_USERNAME_, _DB_PASSWORD_);
+$dh_word = new PDO( _PG_DB_WORD_INDEX_, _DB_USERNAME_, _DB_PASSWORD_);
 $dh_word->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
-$dh_pali = new PDO( _FILE_DB_PALI_INDEX_, _DB_USERNAME_, _DB_PASSWORD_);
+$dh_pali = new PDO( _PG_DB_PALI_INDEX_, _DB_USERNAME_, _DB_PASSWORD_);
 $dh_pali->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
 echo "from=$from to = $to \n";
 for ($i = $from; $i <= $to; $i++) {
     $time_start = microtime(true);
     echo "正在处理 book= $i ";
-    $query = "SELECT max(paragraph) from "._TABLE_WORD_." where book=?";
+    $query = "SELECT max(paragraph) from "._PG_TABLE_WORD_." where book=?";
 	$stmt = $dh_pali->prepare($query);
     $stmt->execute(array($i));
     $row = $stmt->fetch(PDO::FETCH_NUM);
@@ -39,11 +45,11 @@ for ($i = $from; $i <= $to; $i++) {
         echo "段落数量：$max_para ";
         for ($j = 0; $j <= $max_para; $j++) {
             # code...
-            $query = "SELECT id,book,wordindex,bold from "._TABLE_WORD_." where book={$i} and paragraph={$j} order by id ASC";
+            $query = "SELECT id,book,wordindex,bold from "._PG_TABLE_WORD_." where book={$i} and paragraph={$j} order by id ASC";
             $stmt = $dh_pali->query($query);
             $fetch = $stmt->fetchAll(PDO::FETCH_ASSOC);
 
-            $query = "SELECT wordindex,count(*) as co from "._TABLE_WORD_." where book={$i} and paragraph={$j} group by wordindex";
+            $query = "SELECT wordindex,count(*) as co from "._PG_TABLE_WORD_." where book={$i} and paragraph={$j} group by wordindex";
             $stmt = $dh_pali->query($query);
             $fetch_voc = $stmt->fetchAll(PDO::FETCH_ASSOC);
             $vocabulary = array();
@@ -82,7 +88,7 @@ for ($i = $from; $i <= $to; $i++) {
                     $bold_count = $end - $begin + 1;
                     if ($bold_count == 1) {
 
-                        $query = "SELECT * from "._TABLE_WORD_INDEX_." where id=" . $fetch[$iWord]["wordindex"];
+                        $query = "SELECT * from "._PG_TABLE_WORD_INDEX_." where id=" . $fetch[$iWord]["wordindex"];
                         $stmt_word = $dh_word->query($query);
                         $wordinfo = $stmt_word->fetch(PDO::FETCH_ASSOC);
                         $bookId = (int) $fetch[$iWord]["book"];
@@ -100,7 +106,7 @@ for ($i = $from; $i <= $to; $i++) {
                         for ($iBold = $begin; $iBold <= $end; $iBold++) {
                             # code...
                             $boldid = $fetch[$iBold]["wordindex"];
-                            $query = "SELECT len from "._TABLE_WORD_INDEX_." where id=" . $boldid;
+                            $query = "SELECT len from "._PG_TABLE_WORD_INDEX_." where id=" . $boldid;
                             $stmt_bold = $dh_word->query($query);
                             $wordbold = $stmt_bold->fetch(PDO::FETCH_ASSOC);
                             $len_sum += $wordbold["len"];
@@ -116,7 +122,7 @@ for ($i = $from; $i <= $to; $i++) {
             }
             # 将整段权重写入据库
             $dh_pali->beginTransaction();
-            $query = "UPDATE "._TABLE_WORD_." set weight = ? where id=? ";
+            $query = "UPDATE "._PG_TABLE_WORD_." set weight = ? where id=? ";
             $stmt_weight = $dh_pali->prepare($query);
             foreach ($fetch as $key => $value) {
                 $stmt_weight->execute(array($value["weight"], $value["id"]));

app/install/db_insert_bookword_from_csv_cli.php

@@ -29,8 +29,12 @@ $filelist = array();
 $fileNums = 0;
 $log = "";
 
+//PostgreSQL
+define("_DB_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_", "book_words");
+
 global $dbh_word_index;
-$dns = _FILE_DB_BOOK_WORD_;
+$dns = _DB_;
 $dbh_word_index = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
 $dbh_word_index->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
@@ -62,7 +66,7 @@ for ($from=$_from-1; $from < $_to; $from++) {
         }
     }
     #删除原来的数据
-    $query = "DELETE FROM "._TABLE_BOOK_WORD_." WHERE book = ?";
+    $query = "DELETE FROM "._TABLE_." WHERE book = ?";
     $stmt = $dbh_word_index->prepare($query);
     $stmt->execute(array($book));
     if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
@@ -72,7 +76,7 @@ for ($from=$_from-1; $from < $_to; $from++) {
     }else{
         // 开始一个事务，关闭自动提交
         $dbh_word_index->beginTransaction();
-        $query = "INSERT INTO "._TABLE_BOOK_WORD_." (book , wordindex , count) VALUES ( ? , ? , ?  )";
+        $query = "INSERT INTO "._TABLE_." (book , wordindex , count) VALUES ( ? , ? , ?  )";
         $stmt = $dbh_word_index->prepare($query);
 
         foreach ($bookword as $key => $value) {

app/install/db_insert_palitext_cli.php

@@ -5,6 +5,8 @@
 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;
 
@@ -38,7 +40,7 @@ if ($to == 0 || $to >= $fileNums) {
     $to = $fileNums - 1;
 }
 
-PDO_Connect(_FILE_DB_PALITEXT_,_DB_USERNAME_,_DB_PASSWORD_);
+PDO_Connect(_PG_DB_PALITEXT_,_DB_USERNAME_,_DB_PASSWORD_);
 
 for ($from=$_from-1; $from < $to; $from++) { 
     # code...
@@ -105,13 +107,13 @@ for ($from=$_from-1; $from < $to; $from++) {
     }
     
     #删除 旧数据
-    $query = "DELETE FROM "._TABLE_PALI_TEXT_." WHERE book=?";
+    $query = "DELETE FROM "._PG_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 ( ? , ? , ? , ? , ? , ? , ? , ? )";
+    $query = "INSERT INTO "._PG_TABLE_PALI_TEXT_." ( book , paragraph , level , class , toc , text , html , lenght ) VALUES ( ? , ? , ? , ? , ? , ? , ? , ? )";
     $stmt = $PDO->prepare($query);
     foreach ($arrInserString as $oneParam) {
         if ($oneParam[3] < 100) {

app/install/db_insert_templet_cli.php

@@ -21,7 +21,11 @@ if ($_to > 217) {
 	$_to = 217;
 }
 
-//$myLogFile = fopen(_DIR_LOG_ . "insert_db.log", "a");
+
+#pg
+define("_DB_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_","wbw_templates");
+
 
 $filelist = array();
 
@@ -32,7 +36,7 @@ if (($handle = fopen(__DIR__."/filelist.csv", 'r')) !== false) {
 echo "read file list".PHP_EOL;
 
 
-PDO_Connect(_FILE_DB_PALICANON_TEMPLET_);
+PDO_Connect(_DB_,_DB_USERNAME_,_DB_PASSWORD_);
 echo "db Connectd".PHP_EOL;
 
 
@@ -77,7 +81,7 @@ for ($from=$_from; $from <=$_to ; $from++) {
 	//fwrite($myLogFile, $log);
 
 	#删除目标数据库中数据
-	$query = "DELETE FROM "._TABLE_PALICANON_TEMPLET_." WHERE book = ?";
+	$query = "DELETE FROM "._TABLE_." WHERE book = ?";
 	$stmt = $PDO->prepare($query);
 	if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
 		$error = $PDO->errorInfo();
@@ -91,7 +95,7 @@ for ($from=$_from; $from <=$_to ; $from++) {
 	$row=0;
 	// 开始一个事务，关闭自动提交
 	$PDO->beginTransaction();
-	$query = "INSERT INTO "._TABLE_PALICANON_TEMPLET_." ( book , paragraph, wid , word , real , type , gramma , part , style ) VALUES (?,?,?,?,?,?,?,?,?)";
+	$query = "INSERT INTO "._TABLE_." ( book , paragraph, wid , word , real , type , gramma , part , style ) VALUES (?,?,?,?,?,?,?,?,?)";
 	$stmt = $PDO->prepare($query);
 	if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
 		$error = PDO_ErrorInfo();

app/install/db_insert_word_from_csv_cli.php

@@ -28,9 +28,11 @@ $filelist = array();
 $fileNums = 0;
 $log = "";
 
+define("_DB_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_", "words");
 
 global $dbh_word_index;
-$dns = _FILE_DB_PALI_INDEX_;
+$dns = _DB_;
 $dbh_word_index = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
 $dbh_word_index->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
@@ -46,7 +48,7 @@ if ($_to == 0 || $_to >= $fileNums) {
 for ($from=$_from-1; $from < $_to; $from++) { 
     echo "doing ".($from+1).PHP_EOL;
     #删除
-    $query = "DELETE FROM "._TABLE_WORD_." WHERE book = ?";
+    $query = "DELETE FROM "._TABLE_." WHERE book = ?";
     $stmt = $dbh_word_index->prepare($query);
     $stmt->execute(array($from+1));
 
@@ -54,7 +56,7 @@ for ($from=$_from-1; $from < $_to; $from++) {
     if (($fpoutput = fopen(_DIR_CSV_PALI_CANON_WORD_ . "/{$from}_words.csv", "r")) !== false) {
         // 开始一个事务，关闭自动提交
         $dbh_word_index->beginTransaction();
-        $query = "INSERT INTO "._TABLE_WORD_." ( sn , book , paragraph , wordindex , bold ) VALUES (?,?,?,?,?)";
+        $query = "INSERT INTO "._TABLE_." ( sn , book , paragraph , wordindex , bold ) VALUES (?,?,?,?,?)";
         $stmt = $dbh_word_index->prepare($query);
 
         $count = 0;

app/install/db_insert_wordindex_from_csv_cli.php

@@ -12,12 +12,16 @@ echo "Insert Word Index To DB".PHP_EOL;
 $dirLog = _DIR_LOG_ . "/";
 $log = "";
 
-$dns = _FILE_DB_WORD_INDEX_;
+//PostgreSQL
+define("_DB_WORD_INDEX_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_", "word_indexs");
+
+$dns = _DB_WORD_INDEX_;
 $dbh_word_index = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
 $dbh_word_index->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
 #删除
-$query = "DELETE FROM "._TABLE_WORD_INDEX_." WHERE true";
+$query = "DELETE FROM "._TABLE_." WHERE true";
 $stmt = $dbh_word_index->prepare($query);
 $stmt->execute();
 
@@ -30,7 +34,7 @@ $stmt->execute();
 
                 // 开始一个事务，关闭自动提交
                 $dbh_word_index->beginTransaction();
-                $query = "INSERT INTO "._TABLE_WORD_INDEX_." (id , word , word_en , count , normal , bold , is_base , len ) VALUES (?,?,?,?,?,?,?,?)";
+                $query = "INSERT INTO "._TABLE_." (id , word , word_en , count , normal , bold , is_base , len ) VALUES (?,?,?,?,?,?,?,?)";
         
                 $stmt = $dbh_word_index->prepare($query);
         

app/install/db_update_palitext_cli.php

@@ -5,6 +5,8 @@
 require_once __DIR__."/../config.php";
 require_once __DIR__.'/../public/_pdo.php';
 
+define("_DB_PALITEXT_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_","pali_texts");
 
 echo "Insert Pali Text To DB".PHP_EOL;
 
@@ -37,7 +39,9 @@ if ($to == 0 || $to >= $fileNums) {
     $to = $fileNums - 1;
 }
 
-PDO_Connect(_FILE_DB_PALITEXT_,_DB_USERNAME_,_DB_PASSWORD_);
+
+
+PDO_Connect(_DB_PALITEXT_,_DB_USERNAME_,_DB_PASSWORD_);
 
 for ($from=$_from-1; $from < $to; $from++) { 
     echo "doing $from".PHP_EOL;
@@ -102,7 +106,7 @@ $book = $from + 1;
 
 //计算段落信息，如上一段
 
-$query = "SELECT * from "._TABLE_PALI_TEXT_." where book = '$book'  order by paragraph asc";
+$query = "SELECT * from "._TABLE_." where book = '$book'  order by paragraph asc";
 $title_data = PDO_FetchAll($query);
 echo "Paragraph Count:" . count($title_data) . " arrInserString:".count($arrInserString). PHP_EOL;
 
@@ -110,7 +114,7 @@ $paragraph_count = count($title_data);
 
 // 开始一个事务，关闭自动提交
 $PDO->beginTransaction();
-$query = "UPDATE "._TABLE_PALI_TEXT_." SET level = ? , toc = ? , chapter_len = ? , next_chapter = ?, prev_chapter=? , parent= ?  ,  chapter_strlen = ?  WHERE book=? and paragraph=?";
+$query = "UPDATE "._TABLE_." SET level = ? , toc = ? , chapter_len = ? , next_chapter = ?, prev_chapter=? , parent= ?  ,  chapter_strlen = ?  WHERE book=? and paragraph=?";
 $stmt = $PDO->prepare($query);
 
 $paragraph_info = array();

app/install/db_update_toc_cli.php

@@ -3,6 +3,9 @@ require_once __DIR__."/../config.php";
 require_once __DIR__.'/../public/_pdo.php';
 require_once __DIR__."/../public/function.php";
 
+define("_DB_RES_INDEX_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_TABLE_","res_indexs");
+
 echo "Update toc to res_index".PHP_EOL;
 
 if ($argc != 4) {
@@ -36,7 +39,7 @@ if ($to == 0 || $to >= $fileNums) {
     $to = $fileNums - 1;
 }
 
-PDO_Connect(_FILE_DB_RESRES_INDEX_);
+PDO_Connect(_DB_RES_INDEX_,_DB_USERNAME_,_DB_PASSWORD_);
 
 for ($from=$_from-1; $from < $_to; $from++) { 
     # code...
@@ -88,13 +91,13 @@ for ($from=$_from-1; $from < $_to; $from++) {
     
     //删除已有标题
     
-    $query = "DELETE FROM \""._TABLE_RES_INDEX_."\" WHERE book = ?  AND  language = ?  ";
+    $query = "DELETE FROM \""._TABLE_."\" WHERE book = ?  AND  language = ?  ";
     PDO_Execute($query, array($book,$_lang));
     
     
     // 开始一个事务，关闭自动提交
     $PDO->beginTransaction();
-    $query = "INSERT INTO \""._TABLE_RES_INDEX_."\" (book , paragraph, title, title_en , level, type , language , author , share , create_time , update_time  ) VALUES (  ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? )";
+    $query = "INSERT INTO \""._TABLE_."\" (book , paragraph, title, title_en , level, type , language , author , share , create_time , update_time  ) VALUES (  ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? )";
     $stmt = $PDO->prepare($query);
     if ($_lang == "pali") {
         $type = 1;

deploy/migaration/20211125155600_word_statistics.php

@@ -1,18 +1,21 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_STATISTICS_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_WORD_STATISTICS_", "word_statistics");
+
 #打开源数据库
 $PDO_SRC = new PDO(_SRC_DB_STATISTICS_,_DB_USERNAME_,_DB_PASSWORD_,array(PDO::ATTR_PERSISTENT=>true));
 $PDO_SRC->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 echo "open src".PHP_EOL;
 
 #打开目标数据库
-$PDO_DEST = new PDO(_FILE_DB_STATISTICS_,_DB_USERNAME_,_DB_PASSWORD_,array(PDO::ATTR_PERSISTENT=>true));
+$PDO_DEST = new PDO(_PG_DB_STATISTICS_,_DB_USERNAME_,_DB_PASSWORD_,array(PDO::ATTR_PERSISTENT=>true));
 $PDO_DEST->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 echo "open dest".PHP_EOL;
 
 #删除目标数据库中所有数据
-$query = "DELETE FROM "._TABLE_WORD_STATISTICS_." WHERE true";
+$query = "DELETE FROM "._PG_TABLE_WORD_STATISTICS_." WHERE true";
 $stmt = $PDO_DEST->prepare($query);
 if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
     $error = $PDO_DEST->errorInfo();
@@ -29,7 +32,7 @@ echo "begin Transaction".PHP_EOL;
 
 $PDO_DEST->beginTransaction();
 
-$query = "INSERT INTO "._TABLE_WORD_STATISTICS_." ( bookid , word , count , base , end1 , end2 , type , length ) VALUES ( ? , ? , ? , ? , ? , ? , ? , ? )";
+$query = "INSERT INTO "._PG_TABLE_WORD_STATISTICS_." ( bookid , word , count , base , end1 , end2 , type , length ) VALUES ( ? , ? , ? , ? , ? , ? , ? , ? )";
 $stmtDEST = $PDO_DEST->prepare($query);
 
 #从源数据库中读取

deploy/migaration/20211125155700_pali_sent_org.php

@@ -1,10 +1,14 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_PALI_SENTENCE_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_PALI_SENT_ORG_", "pali_sent_orgs");
+
 $src_db=_SRC_DB_PALI_SENTENCE_;#源数据库
 $src_table=_TABLE_SRC_PALI_SENT_;#源表名
-$dest_db=_FILE_DB_PALI_SENTENCE_;#目标数据库
-$dest_table=_TABLE_PALI_SENT_ORG_;#目标表名
+
+$dest_db=_PG_DB_PALI_SENTENCE_;#目标数据库
+$dest_table=_PG_TABLE_PALI_SENT_ORG_;#目标表名
 
 echo "migarate pali_sent_org".PHP_EOL;
 #打开源数据库

deploy/migaration/20211125165700-pali_sent-upgrade.php

@@ -1,10 +1,14 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_PALI_SENTENCE_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_PALI_SENT_", "pali_sentences");
+
 $src_db=_FILE_DB_PALI_SENTENCE_;#源数据库
 $src_table=_TABLE_PALI_SENT_ORG_;#源表名
-$dest_db=_FILE_DB_PALI_SENTENCE_;#目标数据库
-$dest_table=_TABLE_PALI_SENT_;#目标表名
+
+$dest_db=_PG_DB_PALI_SENTENCE_;#目标数据库
+$dest_table=_PG_TABLE_PALI_SENT_;#目标表名
 
 echo "migarate pali_sent_org".PHP_EOL;
 #打开源数据库

deploy/migaration/20211126220400-pali_sent_index-upgrade.php

@@ -1,9 +1,11 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_PALI_SENTENCE_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_PALI_SENT_", "pali_sentences");
 
-$dest_db=_FILE_DB_PALI_SENTENCE_;#目标数据库
-$dest_table=_TABLE_PALI_SENT_INDEX_;#目标表名
+$dest_db = _PG_DB_PALI_SENTENCE_;#目标数据库
+$dest_table = _TABLE_PALI_SENT_INDEX_;#目标表名
 
 echo "migarate pali_sent_index".PHP_EOL;
 
@@ -25,7 +27,7 @@ $stmt->execute();
 echo "delete dest".PHP_EOL;
 
 #插入数据
-$query = "INSERT INTO ".$dest_table." (book, para, strlen ) SELECT book,paragraph,sum(length) FROM "._TABLE_PALI_SENT_." where true group by book,paragraph;";
+$query = "INSERT INTO ".$dest_table." (book, para, strlen ) SELECT book,paragraph,sum(length) FROM "._PG_TABLE_PALI_SENT_." where true group by book,paragraph;";
 $stmt = $PDO_DEST->prepare($query);
 if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
     $error = $PDO_DEST->errorInfo();

deploy/migaration/20211127214800_sent_sim.php

@@ -1,10 +1,14 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_PALI_SENTENCE_SIM_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_SENT_SIM_", "sent_sims");
+
 $src_db=_SRC_DB_PALI_SENTENCE_SIM_;#源数据库
 $src_table=_TABLE_SRC_SENT_SIM_;#源表名
-$dest_db=_FILE_DB_PALI_SENTENCE_SIM_;#目标数据库
-$dest_table=_TABLE_SENT_SIM_;#目标表名
+
+$dest_db=_PG_DB_PALI_SENTENCE_SIM_;#目标数据库
+$dest_table=_PG_TABLE_SENT_SIM_;#目标表名
 
 echo "migarate sent_sim".PHP_EOL;
 #打开源数据库

deploy/migaration/20211127214900-sent_sim_index.php

@@ -1,9 +1,12 @@
 <?php
 require_once __DIR__."/../../app/config.php";
 
+define("_PG_DB_PALI_SENTENCE_SIM_", _DB_ENGIN_.":host="._DB_HOST_.";port="._DB_PORT_.";dbname="._DB_NAME_.";user="._DB_USERNAME_.";password="._DB_PASSWORD_.";");
+define("_PG_TABLE_SENT_SIM_", "sent_sims");
+define("_PG_TABLE_SENT_SIM_INDEX_", "sent_sim_indexs");
 
-$dest_db=_FILE_DB_PALI_SENTENCE_SIM_;#目标数据库
-$dest_table=_TABLE_SENT_SIM_INDEX_;#目标表名
+$dest_db = _PG_DB_PALI_SENTENCE_SIM_;#目标数据库
+$dest_table = _PG_TABLE_SENT_SIM_INDEX_;#目标表名
 
 echo "migarate sent_sim_index".PHP_EOL;
 
@@ -14,7 +17,7 @@ $PDO_DEST->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 echo "open dest".PHP_EOL;
 
 #删除目标表中所有数据
-$query = "DELETE FROM ".$dest_table." WHERE true";
+$query = "DELETE FROM ".$dest_table;
 $stmt = $PDO_DEST->prepare($query);
 if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
     $error = $PDO_DEST->errorInfo();
@@ -25,7 +28,7 @@ $stmt->execute();
 echo "delete dest".PHP_EOL;
 
 #插入数据
-$query = "INSERT INTO ".$dest_table." (sent_id, count ) SELECT sent1,count(*) FROM "._TABLE_SENT_SIM_." where true group by sent1;";
+$query = "INSERT INTO ".$dest_table." (sent_id, count ) SELECT sent1,count(*) FROM "._PG_TABLE_SENT_SIM_." group by sent1;";
 $stmt = $PDO_DEST->prepare($query);
 if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
     $error = $PDO_DEST->errorInfo();

deploy/migaration/20211202084900_init_pali_serieses.php

@@ -4,10 +4,13 @@
 */
 require_once __DIR__."/../../app/config.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_BOOK_NAME_","books");
+
 $src_file=_DIR_PALI_TITLE_."/pali_serieses.csv";#源数据
 
-$dest_db=_FILE_DB_PALITEXT_;#目标数据库
-$dest_table=_TABLE_PALI_BOOK_NAME_;#目标表名
+$dest_db=_PG_DB_PALITEXT_;#目标数据库
+$dest_table=_PG_TABLE_PALI_BOOK_NAME_;#目标表名
 
 echo "migarate pali_serieses".PHP_EOL;
 #打开源