pgsql dataaccess

src/Utils/DataAccess/AbstractDbDataAccess.php

@@ -0,0 +1,31 @@
+<?php
+
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 6/10/16
+ * Time: 1:12 PM
+ */
+
+namespace Luticate\Utils\DataAccess;
+
+abstract class AbstractDbDataAccess
+{
+    /**
+     * @param $sqlType string
+     * @return string
+     */
+    abstract public function sqlTypeToPhpType($sqlType);
+
+    /**
+     * @param $pdo \PDO
+     * @return array
+     */
+    abstract public function getTablesFull($pdo);
+
+    /**
+     * @param $pdo \PDO
+     * @return array
+     */
+    abstract public function getStoredProceduresFull($pdo);
+}

src/Utils/DataAccess/LuDataAccess.php

@@ -22,6 +22,14 @@ abstract class LuDataAccess {
         return static::getConnection()->transaction($function);
     }
 
+    /**
+     * @return \PDO
+     */
+    public static function getPdo()
+    {
+        return Capsule::connection(static::$_connection)->getPdo();
+    }
+
     /**
      * @return Connection
      */

src/Utils/DataAccess/PgSqlDataAccess.php

@@ -0,0 +1,264 @@
+<?php
+
+namespace Luticate\Utils\DataAccess;
+use Luticate\Utils\Business\LuStringUtils;
+
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 6/10/16
+ * Time: 11:05 AM
+ */
+class PgSqlDataAccess extends AbstractDbDataAccess
+{
+    public static $types = ["SERIAL" => "integer",
+        "BIGSERIAL" => "integer",
+        "abstime" => "datetime",
+        "aclitem" => "",
+        "any" => "",
+        "anyarray" => "",
+        "anyelement" => "",
+        "anyenum" => "",
+        "anynonarray" => "",
+        "anyrange" => "",
+        "bigint" => "integer",
+        "bit" => "",
+        "bit varying" => "",
+        "boolean" => "boolean",
+        "box" => "",
+        "bytea" => "string",
+        "char" => "string",
+        "character" => "string",
+        "character varying" => "string",
+        "cid" => "",
+        "cidr" => "",
+        "circle" => "",
+        "cstring" => "",
+        "date" => "datetime",
+        "daterange" => "",
+        "decimal" => "float",
+        "double precision" => "float",
+        "event_trigger" => "",
+        "fdw_handler" => "",
+        "gtsvector" => "",
+        "inet" => "",
+        "information_schema.cardinal_number" => "",
+        "information_schema.character_data" => "",
+        "information_schema.sql_identifier" => "",
+        "information_schema.time_stamp" => "",
+        "information_schema.yes_or_no" => "",
+        "int2vector" => "",
+        "int4range" => "",
+        "int8range" => "",
+        "integer" => "integer",
+        "internal" => "",
+        "interval" => "",
+        "json" => "",
+        "jsonb" => "",
+        "language_handler" => "",
+        "line" => "",
+        "lseg" => "",
+        "macaddr" => "",
+        "money" => "string",
+        "name" => "",
+        "numeric" => "float",
+        "numrange" => "",
+        "oid" => "",
+        "oidvector" => "",
+        "opaque" => "",
+        "path" => "",
+        "pg_lsn" => "",
+        "pg_node_tree" => "",
+        "point" => "",
+        "polygon" => "",
+        "real" => "float",
+        "record" => "",
+        "refcursor" => "",
+        "regclass" => "",
+        "regconfig" => "",
+        "regdictionary" => "",
+        "regoper" => "",
+        "regoperator" => "",
+        "regproc" => "",
+        "regprocedure" => "",
+        "regtype" => "",
+        "reltime" => "",
+        "smallint" => "integer",
+        "smallserial" => "integer",
+        "smgr" => "",
+        "text" => "string",
+        "tid" => "",
+        "timestamp without time zone" => "datetime",
+        "timestamp with time zone" => "datetime",
+        "time without time zone" => "datetime",
+        "time with time zone" => "datetime",
+        "tinterval" => "",
+        "trigger" => "",
+        "tsquery" => "",
+        "tsrange" => "",
+        "tstzrange" => "",
+        "tsvector" => "",
+        "txid_snapshot" => "",
+        "unknown" => "",
+        "uuid" => "",
+        "void" => "",
+        "xid" => "",
+        "xml" => ""];
+
+    /**
+     * @param string $sqlType
+     * @return string
+     */
+    public function sqlTypeToPhpType($sqlType)
+    {
+        $isArray = false;
+        if (LuStringUtils::endsWith($sqlType, "[]")) {
+            $isArray = true;
+            $sqlType = substr($sqlType, 0, strlen($sqlType) - 2);
+        }
+        if (!isset(static::$types) || static::$types[$sqlType] == "") {
+            return "string";
+        }
+        return static::$types[$sqlType] . ($isArray ? "[]" : "");
+    }
+
+    /**
+     * @param \PDO $pdo
+     * @return array|null
+     */
+    public function getTablesFull($pdo)
+    {
+        $tables_names = $this->getTables($pdo);
+        if (is_null($tables_names)) {
+            return null;
+        }
+
+        $tables = [];
+        foreach ($tables_names as $table_name) {
+            $columns = $this->getColumns($pdo, $table_name);
+            if (is_null($columns)) {
+                return null;
+            }
+            $tables[$table_name] = $columns;
+        }
+
+        return $tables;
+    }
+
+    /**
+     * @param $pdo \PDO
+     * @return string[]|null
+     */
+    public function getTables($pdo)
+    {
+        $tablesQuery = $pdo->prepare("SELECT table_name AS name
+FROM information_schema.tables
+WHERE table_type = 'BASE TABLE' AND table_schema NOT IN ('pg_catalog', 'information_schema')");
+        if ($tablesQuery->execute(array())) {
+            $tables = $tablesQuery->fetchAll();
+            $tables = array_map(function($table)
+            {
+                return $table["name"];
+            }, $tables);
+            return $tables;
+        }
+        else
+            return null;
+    }
+
+    /**
+     * @param $pdo \PDO
+     * @param $table_name string
+     * @return array|null
+     */
+    public function getColumns($pdo, $table_name)
+    {
+        $columnsQuery = $pdo->prepare("SELECT column_name as name, data_type as data_type, is_nullable as nullable FROM information_schema.columns WHERE table_name = :table_name");
+        if ($columnsQuery->execute(array(":table_name" => $table_name)))
+        {
+            $columns = $columnsQuery->fetchAll();
+            return $columns;
+        }
+        else
+            return null;
+    }
+
+    /**
+     * @param \PDO $pdo
+     * @return array|null
+     */
+    public function getStoredProceduresFull($pdo)
+    {
+        $sps = $this->getStoredProcedures($pdo);
+        if (is_null($sps)) {
+            return null;
+        }
+
+        foreach ($sps as $sp_name => $sp) {
+            $args = $this->getStoredProceduresArguments($pdo, $sp_name);
+            if (is_null($args)) {
+                return null;
+            }
+            $sps[$sp_name]["args"] = $args;
+        }
+        return $sps;
+    }
+
+    /**
+     * @param $pdo \PDO
+     * @return array|null
+     */
+    public function getStoredProcedures($pdo)
+    {
+        $spQuery = $pdo->prepare("SELECT r.routine_name AS sp_name, r.data_type AS data_type, proc.proretset AS proretset, proc.prosrc AS prosrc
+FROM information_schema.routines r
+LEFT JOIN pg_catalog.pg_proc proc ON proc.proname = r.routine_name
+WHERE r.specific_schema='public'");
+        if ($spQuery->execute())
+        {
+            $sps = $spQuery->fetchAll();
+            $data = [];
+            foreach ($sps as $sp) {
+                $data[$sp["name"]] = ["sp" => $sp];
+            }
+            return $data;
+        }
+        else
+            return null;
+    }
+
+    /**
+     * @param $pdo \PDO
+     * @param $sp string
+     * @return array|null
+     */
+    public function getStoredProceduresArguments($pdo, $sp)
+    {
+        $sp_name = $sp["sp_name"];
+        $spQuery = $pdo->prepare("SELECT parameters.parameter_name as name, parameters.data_type, parameters.parameter_mode
+FROM information_schema.routines
+JOIN information_schema.parameters ON routines.specific_name=parameters.specific_name
+WHERE routines.specific_schema='public' AND routines.routine_name = :sp_name
+ORDER BY parameters.ordinal_position;");
+        if ($spQuery->execute(array("sp_name" => $sp_name)))
+        {
+            $sp_ = $spQuery->fetchAll();
+            $sps = array("in" => array(), "out" => array());
+            foreach ($sp_ as $p)
+                $sps[strtolower($p["parameter_mode"])][] = $p;
+            $out_count = count($sps['out']);
+            if ($out_count == 0)
+            {
+                $sps['out'][] = array(
+                    "name" => $sp_name,
+                    "data_type" => $sp["data_type"],
+                    "parameter_mode" => "OUT"
+                );
+                $out_count = 1;
+            }
+            return $sps;
+        }
+        else
+            return null;
+    }
+}

src/Utils/Dbo/LuDbo.php

@@ -85,7 +85,7 @@ abstract class LuDbo implements \JsonSerializable {
             $dbo->checkConstraints($constraints);
             return $dbo->getInt();
         }
-        else if ($type == "float") {
+        else if ($type == "float" || $type == "double") {
             $dbo = LuFloatDbo::jsonDeserialize($value);
             $dbo->checkConstraints($constraints);
             return $dbo->getFloat();

tests/DatabaseTest.php

@@ -2,6 +2,7 @@
 use Luticate\Utils\Controller\LuticateApplication;
 use Illuminate\Database\Capsule\Manager as Capsule;
 use Luticate\Utils\DataAccess\LuDataAccess;
+use Luticate\Utils\DataAccess\PgSqlDataAccess;
 use Luticate\Utils\Dbo\LuDbo;
 use Luticate\Utils\Dbo\LuDboDeserializeException;
 
@@ -103,7 +104,7 @@ class TestTableDboArray extends LuDbo
         if (!is_array($json)) {
             throw new LuDboDeserializeException("Invalid array value");
         }
-        $dbo = new self();
+        $dbo = new static();
         $array = [];
         foreach ($json as $data) {
             $array[] = TestTableDbo::jsonDeserialize($data);
@@ -134,18 +135,18 @@ class DatabaseTest extends \PHPUnit_Framework_TestCase
 {
     public function testSetup()
     {
-//        $config = ['databases' => [
-//            [
-//                'name'      => 'mydb',
-//                'driver'    => 'pgsql',
-//                'host'      => '172.17.0.1',
-//                'database'  => 'luticate2',
-//                'username'  => 'dev',
-//                'password'  => 'dev'
-//            ]
-//        ]];
-//        $app = new LuticateApplication($config);
-//        $app->setupDatabases();
+        $config = ['databases' => [
+            [
+                'name'      => 'mydb',
+                'driver'    => 'pgsql',
+                'host'      => '172.17.0.1',
+                'database'  => 'luticate2',
+                'username'  => 'dev',
+                'password'  => 'dev'
+            ]
+        ]];
+        $app = new LuticateApplication($config);
+        $app->setupDatabases();
         
 //        $dbo = new TestTableDbo();
 //        $dbo->setId(11);
@@ -164,5 +165,10 @@ class DatabaseTest extends \PHPUnit_Framework_TestCase
 //        {
 //            return $q->where("some_text", "like", "lol%");
 //        }, ['Id']));
+
+
+        $pdo = TestTableDataAccess::getPdo();
+        $pgsql = new PgSqlDataAccess();
+        var_dump($pgsql->getTablesFull($pdo));
     }
 }