RDV\Bundle\MigrationBundle\Event\MigrationEvent

Complexity

Total Complexity

9

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addMigration()	0	8	2
A	getMigrations()	0	4	1
A	getData()	0	6	1
A	isTableExist()	0	13	4

<?php

namespace RDV\Bundle\MigrationBundle\Event;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\DBALException;
use RDV\Bundle\MigrationBundle\Migration\Migration;
use Symfony\Component\EventDispatcher\Event;

class MigrationEvent extends Event
{
    /**
     * @var Migration[]
     */
    protected $migrations = [];

    /**
     * @var Connection
     */
    protected $connection;

    /**
     * @param Connection $connection
     */
    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    /**
     * Adds a migration
     *
     * @param Migration $migration
     * @param bool      $prepend If TRUE a migration is added to the beginning of the list
     */
    public function addMigration(Migration $migration, $prepend = false)
    {
        if ($prepend) {
            array_unshift($this->migrations, $migration);
        } else {
            array_push($this->migrations, $migration);
        }
    }

    /**
     * Gets all migrations
     *
     * @return Migration[]
     */
    public function getMigrations()
    {
        return $this->migrations;
    }

    /**
     * Prepares and executes an SQL query and returns the result as an associative array.
     *
     * @param string $sql    The SQL query.
     * @param array  $params The query parameters.
     * @param array  $types  The query parameter types.
     * @return array
     */
    public function getData($sql, array $params = array(), $types = array())
    {
        $this->connection->connect();

        return $this->connection->fetchAll($sql, $params, $types);
    }

    /**
     * Check if the given table exists in a database
     *
     * @param string $tableName
     * @return bool TRUE if a table exists; otherwise, FALSE
     */
    public function isTableExist($tableName)
    {
        if (!empty($tableName)) {
            try {
                $this->connection->connect();
                return $this->connection->getSchemaManager()->tablesExist($tableName);

$tableName is of type string, but the function expects a array.

            } catch (\PDOException $e) {

Consider adding a comment why this CATCH block is empty.

            } catch (DBALException $e) {

Consider adding a comment why this CATCH block is empty.

            }
        }

        return false;
    }
}