Phive\Queue\Tests\Handler\PdoHandler

Complexity

Total Complexity

10

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getQueueName()	0	4	1
A	getQueueClass()	0	6	2
A	createQueue()	0	6	1
A	reset()	0	13	2
A	clear()	0	4	1
A	configure()	0	12	1
A	configureDriver()	0	8	2

<?php

/*
 * This file is part of the Phive Queue package.
 *
 * (c) Eugene Leonovich <gen.work@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Phive\Queue\Tests\Handler;

use Phive\Queue\Queue;

class PdoHandler extends Handler
{
    /**
     * @var \PDO
     */
    private $pdo;

    /**
     * @var string
     */
    private $driverName;

    public function getQueueName(Queue $queue)
    {
        return parent::getQueueName($queue).'#'.$this->driverName;
    }

    public function getQueueClass()
    {
        $prefix = 'sqlite' === $this->driverName ? 'Sqlite' : 'Generic';

        return '\\Phive\\Queue\\Pdo\\'.$prefix.'PdoQueue';
    }

    public function createQueue()
    {
        $class = $this->getQueueClass();

        return new $class($this->pdo, $this->getOption('table_name'));
    }

    public function reset()
    {
        $sqlDir = realpath(__DIR__.'/../../res/'.$this->driverName);

        foreach (glob($sqlDir.'/*.sql') as $file) {
            $sql = strtr(file_get_contents($file), [
                '{{table_name}}'    => $this->getOption('table_name'),
                '{{routine_name}}'  => $this->getOption('table_name').'_pop',
            ]);

            $this->pdo->exec($sql);
        }
    }

    public function clear()
    {
        $this->pdo->exec('DELETE FROM '.$this->getOption('table_name'));
    }

    protected function configure()
    {
        $this->pdo = new \PDO(
            $this->getOption('dsn'),
            $this->getOption('username'),
            $this->getOption('password')
        );
        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
        $this->driverName = $this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);

        $this->configureDriver();
    }

    protected function configureDriver()
    {
        switch ($this->driverName) {
            case 'sqlite':
                $this->pdo->exec('PRAGMA journal_mode=WAL');
                break;
        }
    }
}