Doctrine\Tests\DBAL\Connection\Connector\HighAvailabilityConnectorTest

Complexity

Total Complexity

9

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testConnectFailMaster()	0	20	3
A	testConnect()	0	7	1
A	testConnectRandomFail()	0	8	2
A	testConnectFailSlave()	0	20	3

<?php

namespace Doctrine\Tests\DBAL\Connection\Connector;

use Doctrine\DBAL\Connections\Connector\HighAvailabilityConnector;
use Throwable;

class HighAvailabilityConnectorTest extends ConnectorTest
{
    public function testConnect() : void
    {
        $params = $this->getParams();

        $connector = new HighAvailabilityConnector($params, $this->failingDriverMock());
        $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('master'));
        $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('slave'));
    }

    public function testConnectFailMaster() : void
    {
        $params = $this->getParams(2, 0, true);

        $connector = new HighAvailabilityConnector($params, $this->failingDriverMock());
        $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('slave'));

        $failed = false;
        try {
            $connector->connectTo('master');
            $failed = true;
        } catch (Throwable $e) {
            $this->assertInstanceOf('Doctrine\DBAL\Exception\ConnectionException', $e);
        }

        if (! $failed) {
            return;
        }

        $this->fail('Connect has not failed');
    }

    public function testConnectFailSlave() : void
    {
        $params = $this->getParams(2, 2);

        $connector = new HighAvailabilityConnector($params, $this->failingDriverMock());
        $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('master'));

        $failed = false;
        try {
            $connector->connectTo('slave');
            $failed = true;
        } catch (Throwable $e) {
            $this->assertInstanceOf('Doctrine\DBAL\Exception\ConnectionException', $e);
        }

        if (! $failed) {
            return;
        }

        $this->fail('Connect has not failed');
    }

    public function testConnectRandomFail() : void
    {
        for ($i = 0; $i < 100; $i++) {
            $params = $this->getParams(2, 1);

            $connector = new HighAvailabilityConnector($params, $this->failingDriverMock());
            $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('master'));
            $this->assertInstanceOf('Doctrine\DBAL\Driver\Connection', $connector->connectTo('slave'));
        }
    }
}