MySqlConnection::tryAgainIfCausedByLostConnection() - Code Metrics - swooletw/laravel-swoole - Measure and Improve Code Quality continuously with Scrutinizer

tryAgainIfCausedByLostConnection() A
last analyzed 2022-04-06 07:13 UTC

↳ Parent: MySqlConnection

Complexity

Conditions	3
Paths	2

Size

Total Lines	13
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	3
eloc	6
c	1
b	0
f	0
nc	2
nop	4
dl	0
loc	13
rs	10

<?php

namespace SwooleTW\Http\Coroutine;

use Closure;
use Illuminate\Database\MySqlConnection as BaseConnection;
use Illuminate\Database\QueryException;
use Illuminate\Support\Str;

class MySqlConnection extends BaseConnection
{
    /**
     * Handle a query exception that occurred during query execution.
     *
     * @param  \Illuminate\Database\QueryException $e
     * @param  string $query
     * @param  array $bindings
     * @param  \Closure $callback
     *
     * @return mixed
     *
     * @throws \Illuminate\Database\QueryException
     */
    protected function tryAgainIfCausedByLostConnection(QueryException $e, $query, $bindings, Closure $callback)
    {
        // https://github.com/swoole/swoole-src/blob/a414e5e8fec580abb3dbd772d483e12976da708f/swoole_mysql_coro.c#L1140
        if ($this->causedByLostConnection($e->getPrevious()) || Str::contains(
                $e->getMessage(),
                ['is closed', 'is not established']
            )) {
            $this->reconnect();

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

        throw $e;
    }
}


1			<?php
2
3			namespace SwooleTW\Http\Coroutine;
4
5			use Closure;
6			use Illuminate\Database\MySqlConnection as BaseConnection;
7			use Illuminate\Database\QueryException;
8			use Illuminate\Support\Str;
9
10			class MySqlConnection extends BaseConnection
11			{
12			/**
13			* Handle a query exception that occurred during query execution.
14			*
15			* @param \Illuminate\Database\QueryException $e
16			* @param string $query
17			* @param array $bindings
18			* @param \Closure $callback
19			*
20			* @return mixed
21			*
22			* @throws \Illuminate\Database\QueryException
23			*/
24			protected function tryAgainIfCausedByLostConnection(QueryException $e, $query, $bindings, Closure $callback)
25			{
26			// https://github.com/swoole/swoole-src/blob/a414e5e8fec580abb3dbd772d483e12976da708f/swoole_mysql_coro.c#L1140
27			if ($this->causedByLostConnection($e->getPrevious()) \|\| Str::contains(
28			$e->getMessage(),
29			['is closed', 'is not established']
30			)) {
31			$this->reconnect();
32
33			return $this->runQueryCallback($query, $bindings, $callback);
34			}
35
36			throw $e;
37			}
38			}
39

swooletw / laravel-swoole

tryAgainIfCausedByLostConnection() A last analyzed 2022-04-06 07:13 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

tryAgainIfCausedByLostConnection() A
last analyzed 2022-04-06 07:13 UTC