Classes\AdaptersDriver\Pgsql

Complexity

Total Complexity

18

Size/Duplication

Total Lines	254
Duplicated Lines	38.98 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
B	getListNameTable()	26	26	3
B	getListColumns()	23	24	2
B	getListConstrant()	30	30	2
B	getSequence()	0	44	4
A	getPDOString()	0	10	1
A	getPDOSocketString()	0	9	1
A	getTotalTables()	20	20	3

<?php

For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 19 and the first side effect is on line 10.

namespace Classes\AdaptersDriver;

use Classes\AdapterConfig\AbstractAdapter;
use Classes\Db\Column;
use Classes\Db\Constrant;
use Classes\Db\DbTable;

require_once 'Classes/AdaptersDriver/AbsractAdapter.php';
require_once 'Classes/Db/Column.php';
require_once 'Classes/Db/Constrant.php';
require_once 'Classes/Db/DbTable.php';

/**
 * @author Pedro Alarcao <phacl151@gmail.com>
 * @link   https://github.com/pedro151/orm-generator
 */
class Pgsql extends AbsractAdapter
{

    /**
     * @var int
     */
    protected $port = 5432;

    /**
     * @type array|\string[]
     */
    protected $schema = array ( 'public' );

    protected $dataTypesToSimple = array (
        /* Numeric Types */
        'smallint'         => 'int',
        'integer'          => 'int',
        'serial'           => 'int',
        'bigint'           => 'float',
        'decimal'          => 'float',
        'numeric'          => 'float',
        'real'             => 'float',
        'double precision' => 'float',
        'bigserial'        => 'float',
        /* Monetary Types */
        'money'            => 'float',
        /* Binary Data Types */
        'bytea'            => 'int',
        /* Character Types */
        'character varyin' => 'string',
        'varchar'          => 'string',
        'character'        => 'string',
        'char'             => 'string',
        'text'             => 'text',
        /* Date/Time Types */
        'datetime'         => 'datetime',
        'timestamp without time zone' => 'timestamp',
        'date'             => 'date',
        /* Boolean Type */
        'boolean'          => 'boolean'
    );

    public function __construct ( AbstractAdapter $adapterConfig )
    {
        parent::__construct ( $adapterConfig );
        if ( $adapterConfig->hasSchemas () ) {
            $this->schema = $adapterConfig->getSchemas ();
        }

    }

    /**
     * Retorna um Array com nome das tabelas
     *
     * @param void $schema

There is no parameter named $schema. Was it maybe removed?

     *
     * @return string[]
     */
    public function getListNameTable ()

This method seems to be duplicated in your project.

    {
        if ( empty( $this->tableList ) ) {

            $sqlTables = !empty($this->tablesName)?"AND table_name IN ( $this->tablesName )":'';

            $strSchema = implode ( "', '", $this->schema );

            $this->tableList = $this->getPDO ()

The property tableList does not exist. Did you maybe forget to declare it?

                                    ->query (
                                        "SELECT table_schema,
              table_name
             FROM information_schema.tables
             WHERE
              table_type = 'BASE TABLE'
              AND table_schema IN ( '$strSchema' ) $sqlTables
              ORDER by
               table_schema,
               table_name
              ASC"
                                    )
                                    ->fetchAll ();
        }

        return $this->tableList;
    }

    /**
     * retorna multiplos arrays com dados da column em array
     *
     * @return array
     */
    public function getListColumns ()

This method seems to be duplicated in your project.

    {
        $sqlTables = !empty($this->tablesName)?"AND c.table_name IN ( $this->tablesName )":'';
        $strSchema = implode ( "', '", $this->schema );

        return $this->getPDO ()
                    ->query (
                        "SELECT distinct
	c.table_schema,
	c.table_name,
	c.column_name ,
	c.data_type,
	c.column_default,
	is_nullable,
	character_maximum_length AS max_length
		FROM
		information_schema.tables AS st
		INNER JOIN  information_schema.columns AS c
		ON st.table_name=c.table_name and st.table_type = 'BASE TABLE'
		 $sqlTables and  c.table_schema IN ('$strSchema')
		order by c.table_name asc"
                    )
                    ->fetchAll ( \PDO::FETCH_ASSOC );
    }

    public function getListConstrant ()

This method seems to be duplicated in your project.

    {
        $sqlTables = !empty($this->tablesName)?"AND tc.table_name IN ( $this->tablesName )":'';
        $strSchema = implode ( "', '", $this->schema );

        return $this->getPDO ()
                    ->query (
                        "SELECT distinct
                tc.constraint_type,
                tc.constraint_name,
                tc.table_schema,
                tc.table_name,
                kcu.column_name,
		        ccu.table_schema AS foreign_schema,
                ccu.table_name AS foreign_table,
                ccu.column_name as foreign_column
                  FROM
                information_schema.table_constraints AS tc
                    JOIN information_schema.key_column_usage AS kcu
                      ON tc.constraint_name = kcu.constraint_name
                       AND tc.table_schema IN ('$strSchema')
                       AND tc.constraint_type IN ('FOREIGN KEY','PRIMARY KEY')
                       $sqlTables
                    JOIN information_schema.constraint_column_usage AS ccu
                      ON tc.constraint_name  = ccu.constraint_name
                        AND tc.constraint_schema = ccu.constraint_schema
                    ORDER by tc.table_schema"
                    )
                    ->fetchAll ( \PDO::FETCH_ASSOC );
    }

    /**
     * Retorna o Nome da Sequence da tabela
     *
     * @param $table
     * @param $column
     *
     * @return string
     */
    public function getSequence ( $table, $column, $schema = 0 )
    {
        $tableTemp = $table;
        if ( 0 !== $schema ) {
            $tableTemp = $schema . '.' . $table;
        }

        $pdo     = $this->getPDO ();
        $return1 = $pdo->query ( "SELECT pg_get_serial_sequence('$tableTemp', '$column');" )
                       ->fetchColumn ();

        if ( !is_null ( $return1 ) ) {
            return $return1;
        }

        $stmt = $pdo->prepare (
            "SELECT distinct adsrc FROM pg_attrdef AS att
            INNER JOIN pg_class AS c
              ON adrelid = c.oid AND c.relname = ? --table
            INNER JOIN pg_attribute AS a
              ON att.adnum=a.attnum AND a.attname=? --column
            INNER JOIN pg_catalog.pg_namespace n
              ON n.oid = c.relnamespace and n.nspname=? --schema
              "
        );

        $stmt->bindParam ( 1, $table );
        $stmt->bindParam ( 2, $column );
        $stmt->bindParam ( 3, $schema );
        $stmt->execute ();
        $return2 = $stmt->fetchColumn ();

        if ( $return2 ) {
            return preg_filter (
                array (
                    '/nextval\(\'/',
                    '/\'::regclass\)/'
                ),
                '',
                $return2
            );
        }

    }

    /**
     * @inheritDoc
     * @return string
     */
    public function getPDOString ()
    {
        return sprintf (
            "pgsql:host=%s;port=%s;dbname=%s",
            $this->host,
            $this->port,
            $this->database

        );
    }

    /**
     * @inheritDoc
     * @return string
     */
    public function getPDOSocketString ()
    {
        return sprintf (
            "pgsql:unix_socket=%s;dbname=%s",
            $this->socket,
            $this->database

        );
    }

    /**
     * retorna o numero total de tabelas
     *
     * @return int
     */
    public function getTotalTables ()

This method seems to be duplicated in your project.

    {
        if ( empty( $this->totalTables ) ) {
            $sqlTables = !empty($this->tablesName)?"AND table_name IN ( $this->tablesName )":'';

            $strSchema = implode ( "', '", $this->schema );

            $this->totalTables = $this->getPDO ()
                                      ->query (
                                          "SELECT COUNT(table_name)  AS total
             FROM information_schema.tables
             WHERE
              table_type = 'BASE TABLE'
              AND table_schema IN ( '" . $strSchema . "' ) $sqlTables"
                                      )
                                      ->fetchColumn ();
        }

        return (int) $this->totalTables;
    }
}