新增 PHP PostgreSQL_PDO 类型数据库操作

source/core/php/index.js

@@ -22,6 +22,7 @@ class PHP extends Base {
       'database/oracle',
       'database/oracle_oci8',
       'database/postgresql',
+      'database/postgresql_pdo',
       'database/informix'
     ].map((_) => {
       this.parseTemplate(`./php/template/${_}`);

source/core/php/template/database/postgresql_pdo.js

+/**
+ * 数据库管理模板::postgresql_pdo
+ * i 数据分隔符号 => \t|\t
+ */
+
+module.exports = (arg1, arg2, arg3, arg4, arg5, arg6) => ({
+  // 显示所有数据库
+  show_databases: {
+    _:
+      `$m=get_magic_quotes_gpc();
+      $hst=$m?stripslashes($_POST["${arg1}"]):$_POST["${arg1}"];
+      $usr=$m?stripslashes($_POST["${arg2}"]):$_POST["${arg2}"];
+      $pwd=$m?stripslashes($_POST["${arg3}"]):$_POST["${arg3}"];
+      $host=split(':',$hst)[0];
+      $port=split(':',$hst)[1];
+      $dbh=new PDO("pgsql:host=$host;port=$port;dbname=postgres;",$usr,$pwd);
+      if(!$dbh){
+        echo("ERROR://CONNECT ERROR");
+      }else{
+        $query="select datname FROM pg_database where datistemplate='f';";
+        $result=$dbh->prepare($query);
+        $result->execute();
+        while($res=$result->fetch(PDO::FETCH_ASSOC)){
+          echo(trim($res['datname']).chr(9));
+        }
+        $dbh=null;
+      }`.replace(/\n\s+/g,''),
+    [arg1]: '#{host}',
+    [arg2]: '#{user}',
+    [arg3]: '#{passwd}'
+  },
+  // 显示数据库所有表
+  show_tables: {
+    _:
+      `$m=get_magic_quotes_gpc();
+      $hst=$m?stripslashes($_POST["${arg1}"]):$_POST["${arg1}"];
+      $usr=$m?stripslashes($_POST["${arg2}"]):$_POST["${arg2}"];
+      $pwd=$m?stripslashes($_POST["${arg3}"]):$_POST["${arg3}"];
+      $dbn=$m?stripslashes($_POST["${arg4}"]):$_POST["${arg4}"];
+      $host=split(':',$hst)[0];
+      $port=split(':',$hst)[1];
+      $dbh=new PDO("pgsql:host=$host;port=$port;dbname=$dbn;",$usr,$pwd);
+      if(!$dbh){
+        echo("ERROR://CONNECT ERROR");
+      }else{
+        $query="SELECT table_name FROM information_schema.tables WHERE table_type='BASE TABLE' AND table_schema NOT IN ('pg_catalog', 'information_schema');";
+        $result=$dbh->prepare($query);
+        $result->execute();
+        while($res=$result->fetch(PDO::FETCH_ASSOC)){
+          echo(trim($res['table_name']).chr(9));
+        }
+        $dbh=null;
+      }`.replace(/\n\s+/g,''),
+    [arg1]: '#{host}',
+    [arg2]: '#{user}',
+    [arg3]: '#{passwd}',
+    [arg4]: '#{db}'
+  },
+  // 显示表字段
+  show_columns: {
+    _:
+      `$m=get_magic_quotes_gpc();
+      $hst=$m?stripslashes($_POST["${arg1}"]):$_POST["${arg1}"];
+      $usr=$m?stripslashes($_POST["${arg2}"]):$_POST["${arg2}"];
+      $pwd=$m?stripslashes($_POST["${arg3}"]):$_POST["${arg3}"];
+      $dbn=$m?stripslashes($_POST["${arg4}"]):$_POST["${arg4}"];
+      $tab=$m?stripslashes($_POST["${arg5}"]):$_POST["${arg5}"];
+      $host=split(':',$hst)[0];
+      $port=split(':',$hst)[1];
+      $dbh=new PDO("pgsql:host=$host;port=$port;dbname=$dbn;",$usr,$pwd);
+      if(!$dbh){
+        echo("ERROR://CONNECT ERROR");
+      }else{
+        $query="SELECT column_name,udt_name,character_maximum_length FROM information_schema.COLUMNS WHERE TABLE_NAME = '{$tab}';";
+        $result=$dbh->prepare($query);
+        $result->execute();
+        while($res=$result->fetch(PDO::FETCH_ASSOC)){
+          $len=$res['character_maximum_length'] ? $res['character_maximum_length']:"0";
+          echo(trim($res['column_name'])." ({$res['udt_name']}({$len}))".chr(9));
+        }
+        $dbh = null;
+      }`.replace(/\n\s+/g,''),
+    [arg1]: '#{host}',
+    [arg2]: '#{user}',
+    [arg3]: '#{passwd}',
+    [arg4]: '#{db}',
+    [arg5]: '#{table}'
+  },
+  // 执行SQL语句
+  query: {
+    _:
+      `$m=get_magic_quotes_gpc();
+      $hst=$m?stripslashes($_POST["${arg1}"]):$_POST["${arg1}"];
+      $usr=$m?stripslashes($_POST["${arg2}"]):$_POST["${arg2}"];
+      $pwd=$m?stripslashes($_POST["${arg3}"]):$_POST["${arg3}"];
+      $dbn=$m?stripslashes($_POST["${arg4}"]):$_POST["${arg4}"];
+      $sql=base64_decode($_POST["${arg5}"]);
+      $encode=$m?stripslashes($_POST["${arg6}"]):$_POST["${arg6}"];
+      $host=split(':',$hst)[0];
+      $port=split(':',$hst)[1];
+      $dbh=new PDO("pgsql:host=$host;port=$port;dbname=$dbn;",$usr,$pwd);
+      if(!$dbh){
+        echo("ERROR://CONNECT ERROR");
+      }else{
+        $result=$dbh->prepare($sql);
+        if(!$result->execute()){
+          echo("Status\t|\t\r\n");
+          echo(base64_encode("ERROR://EXECUTE ERROR")."\t|\t\r\n");
+        }else{
+          $bool=True;
+          while($res=$result->fetch(PDO::FETCH_ASSOC)){
+            if($bool){
+              foreach($res as $key=>$value){
+                echo($key."\t|\t");
+              }
+              echo "\r\n";
+              $bool=False;
+            }
+            foreach($res as $key=>$value){
+              echo(base64_encode($value!==NULL?$value:"NULL")."\t|\t");
+            }
+            echo "\r\n";
+          }
+          if($bool){
+            if($result->rowCount()){
+              echo("Affect Rows\t|\t\r\n".base64_encode($result->rowCount())."\t|\t\r\n");
+            }else{
+              echo("Status\t|\t\r\n");
+            }
+          }
+        }
+        $dbh = null;
+      }`.replace(/\n\s+/g, ''),
+    [arg1]: '#{host}',
+    [arg2]: '#{user}',
+    [arg3]: '#{passwd}',
+    [arg4]: '#{db}',
+    [arg5]: '#{base64::sql}',
+    [arg6]: '#{encode}'
+  }
+})

source/modules/database/php/index.js

@@ -85,6 +85,7 @@ class PHP {
               sql = `SELECT ${column} FROM ${db}.${table} WHERE ROWNUM < 20 ORDER BY 1`;
               break;
             case 'postgresql':
+            case 'postgresql_pdo':
               sql = `SELECT ${column} FROM ${table} ORDER BY 1 DESC LIMIT 20 OFFSET 0;`;
               break;
             default:
@@ -269,6 +270,7 @@ class PHP {
       'oracle': ['UTF8','ZHS16GBK','ZHT16BIG5','ZHS16GBKFIXED','ZHT16BIG5FIXED'],
       'oracle_oci8': ['UTF8','ZHS16GBK','ZHT16BIG5','ZHS16GBKFIXED','ZHT16BIG5FIXED'],
       'postgresql': ['utf8', 'big5', 'dec8', 'cp850', 'hp8', 'koi8r', 'latin1', 'latin2', 'ascii', 'euckr', 'gb2312', 'gbk'],
+      'postgresql_pdo': ['utf8', 'big5', 'dec8', 'cp850', 'hp8', 'koi8r', 'latin1', 'latin2', 'ascii', 'euckr', 'gb2312', 'gbk'],
       'informix': ['utf8', 'big5', 'dec8', 'cp850', 'hp8', 'koi8r', 'latin1', 'latin2', 'ascii', 'euckr', 'gb2312', 'gbk'],
     }
   }
@@ -347,6 +349,7 @@ class PHP {
           { text: 'ORACLE', value: 'oracle' },
           { text: 'ORACLE_OCI8', value: 'oracle_oci8' },
           { text: 'PostgreSQL', value: 'postgresql' },
+          { text: 'PostgreSQL_PDO', value: 'postgresql_pdo' },
           { text: 'INFORMIX', value: 'informix' }
         ] },
         { type: 'combo', label: LANG['form']['encode'], name: 'encode', options: ((c) => {
@@ -410,6 +413,7 @@ class PHP {
           })
           break;
         case 'postgresql':
+        case 'postgresql_pdo':
           form.setFormData({
             host: 'localhost:5432',
             user: 'postgres',
@@ -535,6 +539,7 @@ class PHP {
           { text: 'ORACLE', value: 'oracle', selected: conf['type'] === 'oracle' },
           { text: 'ORACLE_OCI8', value: 'oracle_oci8', selected: conf['type'] === 'oracle_oci8' },
           { text: 'PostgreSQL', value: 'postgresql', selected: conf['type'] === 'postgresql' },
+          { text: 'PostgreSQL_PDO', value: 'postgresql_pdo', selected: conf['type'] === 'postgresql_pdo' },
           { text: 'INFORMIX', value: 'informix', selected: conf['type'] === 'informix' }
         ] },
         { type: 'combo', label: LANG['form']['encode'], name: 'encode', options: ((c) => {
@@ -1491,6 +1496,7 @@ class PHP {
           presql = `SELECT * FROM ${db}.${table} WHERE ROWNUM < 20 ORDER BY 1`;
           break;
         case 'postgresql':
+        case 'postgresql_pdo':
           presql = `SELECT * FROM ${table} ORDER BY 1 DESC LIMIT 20 OFFSET 0;`;
           break;
         default: