AbstractDatabaseManipulator::setDumpQuery() - Code Metrics - Inspection of "Fixed builds" - ntentan/yentu - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( dadab8...9f1627 )

by James Ekow Abaka

created 2017-09-23 16:36 UTC

AbstractDatabaseManipulator::setDumpQuery() A

↳ Parent: AbstractDatabaseManipulator

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	1
dl	0
loc	4
rs	10
c	0
b	0
f	0

<?php

namespace yentu\manipulators;

use ntentan\atiaa\DriverFactory;
use clearice\ConsoleIO;
use yentu\Yentu;
use yentu\DatabaseAssertor;
use yentu\SchemaDescription;
use yentu\Parameters;

abstract class AbstractDatabaseManipulator
{

    const CONVERT_TO_DRIVER = 'driver';
    const CONVERT_TO_YENTU = 'yentu';

    private $schemaDescription;
    private $assertor;
    private $connection;
    private $dumpQuery;
    private $disableQuery;
    protected $defaultSchema;
    private $io;

    public function __construct(Yentu $yentu, DriverFactory $driverFactory, ConsoleIO $io)

    {
        $this->connection = $driverFactory->createDriver();
        $this->connection->connect();
        $this->io = $io;
    }

    public function __get($name)
    {
        if ($name === 'description') {
            return $this->getDescription();
        }
    }

    public function setDumpQuery($dumpQuery)
    {
        $this->dumpQuery = $dumpQuery;
    }

    public function setDisableQuery($disableQuery)
    {
        $this->disableQuery = $disableQuery;
    }

    public function __call($name, $arguments)

    {
        if (preg_match("/^(add|drop|change|executeQuery|reverseQuery)/", $name)) {
            $details = Parameters::wrap($arguments[0]);
            $this->description->$name($details);

            $name = "_$name";
            new \ReflectionMethod($this, $name);
            return $this->$name($details);
        } else {
            throw new \Exception("Failed to execute method '$name'");
        }
    }

    public function query($query, $bind = false)

    {
        try {
            if ($this->dumpQuery) {
                echo "$query\n";
            }

            $this->io->output("\n    > Running Query [$query]", ConsoleIO::OUTPUT_LEVEL_3);

            if ($this->disableQuery !== true) {
                return $this->connection->query($query, $bind);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            }
        } catch (\ntentan\atiaa\exceptions\DatabaseDriverException $e) {
            throw new exceptions\DatabaseManipulatorException($e->getMessage());
        }
    }

    public function disconnect()
    {
        $this->connection->disconnect();
    }

    public function getDefaultSchema()

    {
        return $this->connection->getDefaultSchema();
    }

    public function getAssertor()
    {
        if (!is_object($this->assertor)) {
            $this->assertor = new DatabaseAssertor($this->description);

        }
        return $this->assertor;
    }

    abstract protected function _addSchema($name);


    abstract protected function _dropSchema($name);


    abstract protected function _addTable($details);


    abstract protected function _dropTable($details);


    abstract protected function _changeTableName($details);


    abstract protected function _addColumn($details);


    abstract protected function _changeColumnNulls($details);


    abstract protected function _changeColumnName($details);


    abstract protected function _changeColumnDefault($details);


    abstract protected function _dropColumn($details);


    abstract protected function _addPrimaryKey($details);


    abstract protected function _dropPrimaryKey($details);


    abstract protected function _addUniqueKey($details);


    abstract protected function _dropUniqueKey($details);


    abstract protected function _addAutoPrimaryKey($details);


    abstract protected function _dropAutoPrimaryKey($details);


    abstract protected function _addForeignKey($details);


    abstract protected function _dropForeignKey($details);


    abstract protected function _addIndex($details);


    abstract protected function _dropIndex($details);


    abstract protected function _addView($details);


    abstract protected function _dropView($details);


    abstract protected function _changeViewDefinition($details);


    protected function _changeForeignKeyOnDelete($details)
    {
        $this->_dropForeignKey($details['from']);
        $this->_addForeignKey($details['to']);
    }

    protected function _changeForeignKeyOnUpdate($details)
    {
        $this->_dropForeignKey($details['from']);
        $this->_addForeignKey($details['to']);
    }

    protected function _executeQuery($details)
    {
        $this->query($details['query'], $details['bind'] ?? []);
    }

    protected function _reverseQuery($details)

    {
        
    }

    abstract public function convertTypes($type, $direction, $length);


    /**
     * 
     * @return SchemaDescription
     */
    public function getDescription()
    {
        if (!is_object($this->schemaDescription)) {
            $this->schemaDescription = SchemaDescription::wrap($this->connection->describe(), $this);
        }
        return $this->schemaDescription;
    }

    public function setVersion($version)
    {
        $this->query('INSERT INTO yentu_history(version) values (?)', array($version));
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    public function getVersion()

    {
        $version = $this->query("SELECT MAX(version) as version FROM yentu_history");
        return isset($version[0]) ? $version[0]['version'] : null;
    }

    public function getLastSession()

    {
        $session = $this->query("SELECT session FROM yentu_history ORDER BY id DESC LIMIT 1");
        return isset($session[0]['session']) ? $session[0]['session'] : null;
    }

    public function getSessionVersions($session)
    {
        $sessionVersions = array();
        $versions = $this->query(
            "SELECT DISTINCT version FROM yentu_history WHERE session = ?", array($session)
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        foreach ($versions as $version) {
            $sessionVersions[] = $version['version'];
        }

        return $sessionVersions;
    }

    public function createHistory()
    {
        try {
            $this->connection->describeTable('yentu_history');
        } catch (\ntentan\atiaa\exceptions\TableNotFoundException $e) {
            $this->io->pushOutputLevel(ConsoleIO::OUTPUT_LEVEL_0);
            $this->addTable(array('schema' => '', 'name' => 'yentu_history'));


            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'session', 'type' => 'string'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => false, 'length' => null, 'table' => 'yentu_history', 'name' => 'version', 'type' => 'string'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'method', 'type' => 'string'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'arguments', 'type' => 'text'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'migration', 'type' => 'string'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'default_schema', 'type' => 'string'));

            $this->addColumn(array('default' => null, 'schema' => '', 'nulls' => true, 'length' => null, 'table' => 'yentu_history', 'name' => 'id', 'type' => 'integer'));

            $this->addPrimaryKey(array('schema' => '', 'table' => 'yentu_history', 'name' => 'yentu_history_pk', 'columns' => array('id')));

            $this->addAutoPrimaryKey(array('schema' => '', 'table' => 'yentu_history', 'column' => 'id'));

            $this->io->popOutputLevel();
        }
    }

    public function __clone()
    {
        if (is_object($this->schemaDescription)) {
            $this->schemaDescription = clone $this->schemaDescription;
        }
    }

}


1			<?php
2
3			namespace yentu\manipulators;
4
5			use ntentan\atiaa\DriverFactory;
6			use clearice\ConsoleIO;
7			use yentu\Yentu;
8			use yentu\DatabaseAssertor;
9			use yentu\SchemaDescription;
10			use yentu\Parameters;
11
12			abstract class AbstractDatabaseManipulator
13			{
14
15			const CONVERT_TO_DRIVER = 'driver';
16			const CONVERT_TO_YENTU = 'yentu';
17
18			private $schemaDescription;
19			private $assertor;
20			private $connection;
21			private $dumpQuery;
22			private $disableQuery;
23			protected $defaultSchema;
24			private $io;
25
26			public function __construct(Yentu $yentu, DriverFactory $driverFactory, ConsoleIO $io)
			0 ignored issues – show Unused Code introduced 2017-09-23 16:38 UTC by Report Bug Copy Issue Report The parameter `$yentu` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
27			{
28			$this->connection = $driverFactory->createDriver();
29			$this->connection->connect();
30			$this->io = $io;
31			}
32
33			public function __get($name)
34			{
35			if ($name === 'description') {
36			return $this->getDescription();
37			}
38			}
39

ntentan / yentu

Push — master ( dadab8...9f1627 )

AbstractDatabaseManipulator::setDumpQuery() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like