Da\Mailer\Test\AbstractMySqlDatabaseTestCase

Complexity

Total Complexity

7

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getPdoQueueStoreConnection()	0	10	2
A	getConnection()	0	6	1
A	getDataSet()	0	4	1
A	setUp()	0	18	3

<?php
namespace Da\Mailer\Test;

use Da\Mailer\Queue\Backend\Pdo\PdoQueueStoreConnection;
use Da\Mailer\Test\Fixture\FixtureHelper;
use PHPUnit_Extensions_Database_TestCase;

abstract class AbstractMySqlDatabaseTestCase extends PHPUnit_Extensions_Database_TestCase
{

    protected static function getPdoQueueStoreConnection()
    {
        static $pdoQueue;

        if ($pdoQueue === null) {
            $pdoQueue = new PdoQueueStoreConnection(FixtureHelper::getMySqlConnectionConfiguration());
        }

        return $pdoQueue;
    }

    /**
     * @inheritdoc
     */
    protected function getConnection()
    {
        $pdo = self::getPdoQueueStoreConnection();

        return $this->createDefaultDBConnection($pdo->getInstance());

It seems like $pdo->getInstance() can be null; however, createDefaultDBConnection() does not accept null, maybe add an additional type check?

    }

    /**
     * @inheritdoc
     */
    protected function getDataSet()
    {
        return $this->createFlatXMLDataSet(__DIR__ . '/data/test.xml');
    }

    /**
     * @inheritdoc
     */
    protected function setUp()
    {
        $sql = file_get_contents(__DIR__ . '/migrations/mysql.sql');

        $statements = array_map('trim', array_filter(explode(";", $sql)));

        foreach($statements as $sqlQuery)
        {
            if(empty($sqlQuery)) {
                continue;
            }
            $query = self::getPdoQueueStoreConnection()->getInstance()->prepare($sqlQuery);
            $query->execute();
        }


        parent::setUp();
    }
}