Classes\AdaptersDriver\Mssql

Complexity

Total Complexity

23

Size/Duplication

Total Lines	235
Duplicated Lines	21.28 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
B	convertTypeToSimple()	0	18	5
A	getHost()	0	13	3
A	getPDOString()	0	8	1
A	getPDOSocketString()	0	5	1
B	getListNameTable()	28	28	3
B	getListColumns()	0	25	2
A	getTotalTables()	22	22	3
A	getSequence()	0	15	2
A	getListConstrant()	0	4	1

<?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 Mssql extends AbsractAdapter
{

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

    protected $schema = array ( 'public' );

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

    }

    /**
     * @inheritDoc
     */
    protected function convertTypeToSimple ( $str )
    {
        if ( preg_match ( '/(tinyint|bit)/' , $str ) )
        {
            $res = 'boolean';
        } elseif ( preg_match ( '/(date|time|text|binary|char|xml|uniqueidentifier)/' , $str ) )
        {
            $res = 'string';
        } elseif ( preg_match ( '/(decimal|numeric|real|float|money)/' , $str ) )
        {
            $res = 'float';
        } elseif ( preg_match ( '#^(?:tiny|small|medium|long|big|var)?(\w+)(?:\(\d+\))?(?:\s\w+)*$#' , $str , $matches ) )
        {
            $res = $matches[ 1 ];
        }

        return $res;

The variable $res does not seem to be defined for all execution paths leading up to this point.

    }

    protected function getHost(){
        $host = $this->host;
        if (!empty($this->port)) {
            $seperator = ':';
            if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
                $seperator = ',';
            }
            $host .=  $seperator . $this->port;
            unset($this->port);
        }

        return $host;
    }

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

    /**
     * @inheritDoc
     * @return string
     */
    public function getPDOSocketString ()
    {
        // TODO: implement here
        return "";
    }

    /**
     * @inheritDoc
     * @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 {$this->database}.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[]
     */

    /**
     * retorna multiplos arrays com dados da column em array
     *
     * @return array
     */
    public function getListColumns ()
    {
        $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
		{$this->database}.information_schema.tables AS st
		INNER JOIN  {$this->database}.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 );
    }

    /**
     * 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 {$this->database}.information_schema.tables
             WHERE
              table_type = 'BASE TABLE'
              AND table_schema IN ( '" . $strSchema . "' ) $sqlTables"
                                      )
                                      ->fetchColumn ();
        }

        return (int) $this->totalTables;
    }

    public function getSequence ( $table , $column , $schema = 0 )
    {
        $return = $this->getPDO ()
                       ->query (
                           "SELECT is_identity FROM sys.columns WHERE object_id = object_id('{$schema}.{$table}')  AND name = '{$column}';"
                       )
                       ->fetchColumn();

        if ( ! $return )
        {
            return;
        }

        return "{$table}_{$column}_seq";
    }

    /**
     * @return array
     */
    public function getListConstrant ()
    {
        return array();
    }

    /*

56% of this comment could be valid code. Did you maybe forget this after debugging?

    public function getListConstrant ()
    {
        $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
                {$this->database}.INFORMATION_SCHEMA.TABLE_CONSTRAINTS tc
            INNER JOIN {$this->database}.INFORMATION_SCHEMA.KEY_COLUMN_USAGE kcu
                      ON tc.constraint_name = kcu.constraint_name
                       AND tc.table_schema IN ('$strSchema')
                       AND tc.constraint_type IN ('FOREIGN KEY','PRIMARY KEY')
                       $sqlTables
            INNER JOIN {$this->database}.information_schema.constraint_column_usage AS ccu
                      ON tc.constraint_name  = ccu.constraint_name
                      ORDER by tc.table_schema;"
                    )
                    ->fetchAll ( \PDO::FETCH_ASSOC );
    }
    */

}