Adgoal\DBALFaultTolerance\Driver\ServerGoneAwayExceptionsAwareTrait

Complexity

Total Complexity

6

Size/Duplication

Total Lines	58
Duplicated Lines	41.38 %

Coupling/Cohesion

Components	2
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	isGoneAwayException()	12	12	3
A	isGoneAwayInUpdateException()	12	12	3

<?php

namespace Adgoal\DBALFaultTolerance\Driver;

use Throwable;

/**
 * Trait ServerGoneAwayExceptionsAwareTrait.
 */
trait ServerGoneAwayExceptionsAwareTrait
{
    /** @var string[] */
    protected $goneAwayExceptions = [
        'MySQL server has gone away', //code 2006
        'Lost connection to MySQL server during query', //code 2013
        'The MySQL server is running with the --read-only option so it cannot execute this statement',
        'Connection refused',
        'Lost connection to MySQL server during query', //code 2013
        'Deadlock found when trying to get lock', //code 1213
        'Lock wait timeout exceeded', //code 1205
    ];

    /** @var string[] */
    protected $goneAwayInUpdateExceptions = [
        'MySQL server has gone away',
        'The MySQL server is running with the --read-only option so it cannot execute this statement',
        'Connection refused',
        'Deadlock found when trying to get lock', //code 1213
        'Lock wait timeout exceeded', //code 1205
    ];

    /**
     * @param Throwable $exception
     *
     * @return bool
     */
    public function isGoneAwayException(Throwable $exception): bool

This method seems to be duplicated in your project.

    {
        $message = $exception->getMessage();

        foreach ($this->goneAwayExceptions as $goneAwayException) {
            if (stripos($message, $goneAwayException) !== false) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param Throwable $exception
     *
     * @return bool
     */
    public function isGoneAwayInUpdateException(Throwable $exception): bool

This method seems to be duplicated in your project.

    {
        $message = $exception->getMessage();

        foreach ($this->goneAwayInUpdateExceptions as $goneAwayException) {
            if (stripos($message, $goneAwayException) !== false) {
                return true;
            }
        }

        return false;
    }
}