Classes\AdaptersDriver\Pgsql::parseForeignKeys()

Complexity

Conditions	11
Paths	25

Size

Total Lines	73
Code Lines	42

Duplication

Lines	41
Ratio	56.16 %

Importance

Changes	9
Bugs	3	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	Pgsql::getSequence()	0	38	4

<?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 $dataTypes = array (
        /* Numeric Types */
        'smallint'         => 'int' ,
        'integer'          => 'int' ,
        'bigint'           => 'float' ,
        'decimal'          => 'float' ,
        'numeric'          => 'float' ,
        'real'             => 'float' ,
        'double precision' => 'float' ,
        'serial'           => 'int' ,
        'bigserial'        => 'float' ,
        /* Monetary Types */
        'money'            => 'float' ,
        /* Character Types */
        'character varyin' => 'string' ,
        'varchar'          => 'string' ,
        'character'        => 'string' ,
        'char'             => 'string' ,
        'text'             => 'string' ,
        /* Binary Data Types */
        'bytea'            => 'string' ,
        /* Date/Time Types */
        'datatime'         => 'date' ,
        '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 ) )
        {
            $strSchema = implode ( "', '" , $this->schema );

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

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

                "SELECT table_schema,
              table_name
             FROM information_schema.tables
             WHERE
              table_type = 'BASE TABLE'
              AND table_schema IN ( '$strSchema' )
              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.

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

        return $this->getPDO ()->query (
            "SELECT distinct
	c.table_schema,
	c.table_name,
	c.column_name ,
	c.data_type,
	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'
		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.

    {
        $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')
                    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 )
    {
        $pdo = $this->getPDO ();
        $return1 = $pdo->query ( "SELECT pg_get_serial_sequence('$table', '$column');" )
                       ->fetchColumn ();

        if ( $return1 )
        {
            return $return1;
        }

        $dtbase = explode ( '.' , $table );;

        $stmt = $pdo->prepare (
            "SELECT adsrc FROM pg_attrdef AS att
            INNER JOIN pg_class AS c
              ON adrelid = c.oid AND att.adnum=1 AND c.relname = ?
            INNER JOIN pg_catalog.pg_namespace n
              ON n.oid = c.relnamespace and n.nspname=?"
        );

        $schema = isset( $dtbase[ 1 ] ) ? $dtbase[ 1 ] : 'public';

        $stmt->bindParam ( 1 , $schema );
        $stmt->bindParam ( 2 , $dtbase[ 0 ] );
        $stmt->execute ();
        $return2 = $stmt->fetchColumn ();
        if ( $return2 )
        {
            return preg_filter (
                array (
                    '/nextval\(\'/' ,
                    '/\'::regclass\)/'
                ) , '' , $return2
            );
        }

    }

    /**
     * @inheritDoc
     */
    public function parseTables ()

This method seems to be duplicated in your project.

    {
        if ( $this->hasTables () )
        {
            return $this->getAllTables ();
        }

        foreach ( $this->getListColumns () as $table )
        {
            $schema = $table[ 'table_schema' ];
            $key = $table [ 'table_name' ];
            if ( ! $this->hasTable ( $key , $schema ) )
            {
                $this->createTable ( $key , $schema );
            }

            $column = Column::getInstance ()
                            ->populate (
                                array (
                                    'name'       => $table [ 'column_name' ] ,
                                    'type'       => $this->convertTypeToPhp ( $table[ 'data_type' ] ) ,
                                    'nullable'   => ( $table[ 'is_nullable' ] == 'YES' ) ,
                                    'max_length' => $table[ 'max_length' ]
                                )
                            );

            $this->getTable ( $key , $schema )
                 ->addColumn ( $column )
                 ->setNamespace (
                     $this->config->createClassNamespace ( $this->getTable ( $key , $schema ) )
                 );
        }
    }

    /**
     * @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 ) )
        {
            $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 . "' )"
            )->fetchColumn ();
        }

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