Pagerfanta\Tests\Adapter\DoctrineDbalTestCase

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	14	2
A	isDoctrineDbalNotAvailable()	0	4	1
A	getConnection()	0	9	1
A	createSchema()	0	22	2
A	insertData()	0	9	3

<?php

namespace Pagerfanta\Tests\Adapter;

use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Query\QueryBuilder;
use Doctrine\DBAL\Schema\Schema;
use PHPUnit\Framework\TestCase;

abstract class DoctrineDbalTestCase extends TestCase
{
    /**
     * @var QueryBuilder
     */
    protected $qb;

    protected function setUp()
    {
        if ($this->isDoctrineDbalNotAvailable()) {
            $this->markTestSkipped('Doctrine DBAL is not available');
        }

        $conn = $this->getConnection();

        $this->createSchema($conn);
        $this->insertData($conn);

        $this->qb = new QueryBuilder($conn);
        $this->qb->select('p.*')->from('posts', 'p');
    }

    private function isDoctrineDbalNotAvailable()
    {
        return !class_exists('Doctrine\DBAL\DriverManager');
    }

    private function getConnection()
    {
        $params = $conn = array(

$conn is not used, you could remove the assignment.

            'driver' => 'pdo_sqlite',
            'memory' => true,
        );

        return DriverManager::getConnection($params);
    }

    private function createSchema($conn)
    {
        $schema = new Schema();
        $posts = $schema->createTable('posts');
        $posts->addColumn('id', 'integer', array('unsigned' => true, 'autoincrement' => true));
        $posts->addColumn('username', 'string', array('length' => 32));
        $posts->addColumn('post_content', 'text');
        $posts->setPrimaryKey(array('id'));

        $comments = $schema->createTable('comments');
        $comments->addColumn('id', 'integer', array('unsigned' => true, 'autoincrement' => true));
        $comments->addColumn('post_id', 'integer', array('unsigned' => true));
        $comments->addColumn('username', 'string', array('length' => 32));
        $comments->addColumn('content', 'text');
        $comments->setPrimaryKey(array('id'));

        $queries = $schema->toSql($conn->getDatabasePlatform()); // get queries to create this schema.

        foreach ($queries as $sql) {
            $conn->executeQuery($sql);
        }
    }

    private function insertData($conn)
    {
        for ($i = 1; $i <= 50; $i++) {
            $conn->insert('posts', array('username' => 'Jon Doe', 'post_content' => 'Post #'.$i));
            for ($j = 1; $j <= 5; $j++) {
                $conn->insert('comments', array('post_id' => $i, 'username' => 'Jon Doe', 'content' => 'Comment #'.$j));
            }
        }
    }
}