Hhxsv5\LaravelS\Illuminate\Database\Connectors\CoroutineMySQLConnector

Complexity

Total Complexity

8

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	tryAgainIfCausedByLostConnection()	0	6	2
B	connect()	0	24	4
A	createConnection()	0	14	2

<?php

namespace Hhxsv5\LaravelS\Illuminate\Database\Connectors;

use Exception;
use Illuminate\Support\Arr;
use Illuminate\Database\Connectors\Connector;
use Illuminate\Database\Connectors\ConnectorInterface;
use Hhxsv5\LaravelS\Illuminate\Database\CoroutineMySQL;
use Hhxsv5\LaravelS\Illuminate\Database\StatementException;

class CoroutineMySQLConnector extends Connector implements ConnectorInterface
{
    /**
     * @param string $dsn
     * @param array $config
     * @param array $options
     * @return CoroutineMySQL
     * @throws Exception
     */
    public function createConnection($dsn, array $config, array $options)
    {
        $username = Arr::get($config, 'username');
        $password = Arr::get($config, 'password');

        try {
            $mysql = $this->connect($config);
        } catch (\Exception $e) {
            $mysql = $this->tryAgainIfCausedByLostConnection(
                $e, $dsn, $username, $password, $config
            );
        }

        return $mysql;
    }

    protected function tryAgainIfCausedByLostConnection(Exception $e, $dsn, $username, $password, $options)
    {
        if ($this->causedByLostConnection($e)) {
            return $this->connect($options);
        }
        throw $e;
    }

    /**
     * @param array $config
     * @return CoroutineMySQL
     * @throws StatementException
     */
    public function connect(array $config)
    {
        $connection = new CoroutineMySQL();
        $connection->connect([
            'host'        => Arr::get($config, 'host', '127.0.0.1'),
            'port'        => Arr::get($config, 'port', 3306),
            'user'        => Arr::get($config, 'username', 'hhxsv5'),
            'password'    => Arr::get($config, 'password', '52100'),
            'database'    => Arr::get($config, 'database', 'test'),
            'timeout'     => Arr::get($config, 'timeout', 5),
            'charset'     => Arr::get($config, 'charset', 'utf8mb4'),
            'strict_type' => Arr::get($config, 'strict', false),
        ]);
        if (isset($config['timezone'])) {
            $connection->prepare('set time_zone="' . $config['timezone'] . '"')->execute();
        }
        if (isset($config['strict'])) {
            if ($config['strict']) {
                $connection->prepare("set session sql_mode='STRICT_ALL_TABLES,ANSI_QUOTES'")->execute();
            } else {
                $connection->prepare("set session sql_mode='ANSI_QUOTES'")->execute();
            }
        }
        return $connection;

The expression return $connection returns the type Hhxsv5\LaravelS\Illuminate\Database\CoroutineMySQL which is incompatible with the return type mandated by Illuminate\Database\Connectors\ConnectorInterface::connect() of PDO.

    }
}