Hhxsv5\LaravelS\Illuminate\Database\SwooleMySQLConnection

Complexity

Total Complexity

4

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	tryAgainIfCausedByLostConnection()	0	9	3
A	getDriverName()	0	3	1

<?php

namespace Hhxsv5\LaravelS\Illuminate\Database;

use Illuminate\Support\Str;
use Illuminate\Database\QueryException;
use Illuminate\Database\MySqlConnection;

class SwooleMySQLConnection extends MySqlConnection
{
    /**
     * The active swoole mysql connection.
     *
     * @var SwoolePDO
     */
    protected $pdo;

    /**
     * The active swoole mysql used for reads.
     *
     * @var SwoolePDO
     */
    protected $readPdo;

    public function getDriverName()
    {
        return 'Swoole Coroutine MySQL';
    }

    protected function tryAgainIfCausedByLostConnection(QueryException $e, $query, $bindings, \Closure $callback)
    {
        if ($this->causedByLostConnection($e->getPrevious()) || Str::contains($e->getMessage(), 'is closed')) {
            $this->reconnect();

            return $this->runQueryCallback($query, $bindings, $callback);
        }

        throw $e;
    }
}