TonicHealthCheck\Check\DB\BaseTableExist\DBBaseTableExistCheck

Complexity

Total Complexity

13

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
C	performCheck()	0	28	8
A	getTablesExist()	0	4	1
A	setTablesExist()	0	4	1
A	getSqlGetAllTable()	0	4	1
A	setSqlGetAllTable()	0	4	1

<?php

namespace TonicHealthCheck\Check\DB\BaseTableExist;

use PDO;
use PDOException;
use TonicHealthCheck\Check\DB\AbstractDBCheck;
use TonicHealthCheck\Check\DB\DBExpectConnectCheckException;
use TonicHealthCheck\Check\DB\PDOFactory;

/**
 * Class DBBaseTableExistCheck.
 */
class DBBaseTableExistCheck extends AbstractDBCheck
{
    const CHECK = 'db-base-table-exist-check';
    const DEFAULT_SQL_GET_ALL_TABLE = 'SHOW TABLES';

    /**
     * @var array
     */
    protected $tablesExist;

    /**
     * @var string
     */
    protected $sqlGetAllTable;

    /**
     * @param string     $checkNode
     * @param PDOFactory $PDOFactory
     * @param array      $tablesExist
     * @param string     $sqlGetAllTable
     */
    public function __construct(
        $checkNode,
        PDOFactory $PDOFactory,
        $tablesExist,
        $sqlGetAllTable = self::DEFAULT_SQL_GET_ALL_TABLE
    ) {
        parent::__construct($checkNode);
        $this->setPDOFactory($PDOFactory);
        $this->setTablesExist($tablesExist);
        $this->setSqlGetAllTable($sqlGetAllTable);
    }

    /**
     * Check $tablesExist in the database.
     *
     * @param null|array $tablesExist
     *
     * @return void
     *
     * @throws DBBaseTableExistCheckException
     * @throws DBExpectConnectCheckException
     */
    public function performCheck($tablesExist = null)
    {
        if (null === $tablesExist) {
            $tablesExist = $this->getTablesExist();
        }
        try {
            $pdo = $this->getPDOInstance();

            if (null === $pdo || !$this->getPDOInstance() instanceof PDO) {
                throw DBExpectConnectCheckException::expectConnected();
            }
        } catch (PDOException $e) {
            throw new DBExpectConnectCheckException($e->getMessage(), $e->getCode());
        }

        try {
            $sql = $this->getSqlGetAllTable();
            $query = $this->getPDOInstance()->query($sql);
            $tables = $query->fetchAll(PDO::FETCH_COLUMN);
            foreach ($tablesExist as $tableName) {
                if (array_search($tableName, $tables) === false) {
                    throw DBBaseTableExistCheckException::tableDoesNotExist($tableName);
                }
            }
        } catch (\PDOException $e) {
            throw new DBBaseTableExistCheckException($e->getMessage(), $e->getCode(), $e);
        }
    }

    /**
     * @return array
     */
    public function getTablesExist()
    {
        return $this->tablesExist;
    }

    /**
     * @param array $tablesExist
     */
    protected function setTablesExist($tablesExist)
    {
        $this->tablesExist = $tablesExist;
    }

    /**
     * @return string
     */
    public function getSqlGetAllTable()
    {
        return $this->sqlGetAllTable;
    }

    /**
     * @param string $sqlGetAllTable
     */
    public function setSqlGetAllTable($sqlGetAllTable)
    {
        $this->sqlGetAllTable = $sqlGetAllTable;
    }
}