Phive\Queue\Tests\Queue\Pdo\PdoQueueTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getUnsupportedItemTypes()	0	4	1
A	testUnsupportedItemType()	0	8	3
A	testThrowExceptionOnMalformedSql()	0	17	3
A	testThrowExceptionOnUnsupportedDriver()	0	10	1

<?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\Queue\Pdo;

use Phive\Queue\NoItemAvailableException;
use Phive\Queue\Tests\Handler\PdoHandler;
use Phive\Queue\Tests\Queue\Concurrency;
use Phive\Queue\Tests\Queue\Performance;
use Phive\Queue\Tests\Queue\QueueTest;
use Phive\Queue\Tests\Queue\Types;
use Phive\Queue\Tests\Queue\Util;

abstract class PdoQueueTest extends QueueTest
{
    use Concurrency;
    use Performance;
    use Util;

    public function getUnsupportedItemTypes()
    {
        return [Types::TYPE_BINARY_STRING, Types::TYPE_ARRAY, Types::TYPE_OBJECT];
    }

    /**
     * @dataProvider provideItemsOfUnsupportedTypes
     * @expectedException PHPUnit_Framework_Exception
     * @expectedExceptionMessageRegExp /expects parameter 1 to be string|Binary strings are not identical/
     */
    public function testUnsupportedItemType($item, $type)
    {
        $this->queue->push($item);

        if (Types::TYPE_BINARY_STRING === $type && $item !== $this->queue->pop()) {
            $this->fail('Binary strings are not identical');
        }
    }

    /**
     * @dataProvider provideQueueInterfaceMethods
     */
    public function testThrowExceptionOnMalformedSql($method)
    {
        $options = self::getHandler()->getOptions();
        $options['table_name'] = uniqid('non_existing_table_name_');

        $handler = new PdoHandler($options);
        $queue = $handler->createQueue();

        try {
            $this->callQueueMethod($queue, $method);
        } catch (NoItemAvailableException $e) {

Consider adding a comment why this CATCH block is empty.

        } catch (\PDOException $e) {
            return;
        }

        $this->fail();
    }

    /**
     * @expectedException InvalidArgumentException
     * @expectedExceptionMessage PDO driver "foobar" is unsupported
     */
    public function testThrowExceptionOnUnsupportedDriver()
    {
        $pdo = new MockPdo();
        $pdo->driverName = 'foobar';

        $handler = self::getHandler();
        $class = $handler->getQueueClass();

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