如何禁用Laravel数据库连接丢失后的自动重连？

问题背景 #

我们的分析系统需处理超大规模数据库，部分查询耗时可达数小时。现有逻辑是：若查询60秒未完成则终止该查询，并将其加入队列转为任务执行。

迁移至Laravel后遇到异常：在数据库中终止查询连接后，Laravel会自动创建新连接，仅在第二次终止操作后才会抛出「MySQL server has gone away」异常。

排查Laravel源码后发现逻辑位于vendor/laravel/framework/src/Illuminate/Database/Connection.php：

protected function handleQueryException(QueryException $e, $query, $bindings, Closure $callback)
{
    if ($this->transactions >= 1) {
        throw $e;
    }

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

protected function tryAgainIfCausedByLostConnection(QueryException $e, $query, $bindings, Closure $callback)
{
    if ($this->causedByLostConnection($e->getPrevious())) {
        $this->reconnect();

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

    throw $e;
}

目前无参数可规避该行为，仅在事务中会直接抛出异常，但我们的查询是SELECT语句，使用事务并无意义。

常规操作流程：

• 保存连接ID：

session(['process_id' => DB::selectOne('SELECT CONNECTION_ID() AS id')->id]);
session()->save();

• 终止连接：

DB::statement("KILL $id");

需求：如何让第一次终止操作后就抛出异常？

解决方案 #

方法1：自定义连接类覆盖异常处理逻辑 #

创建自定义的数据库连接类，重写handleQueryException方法，跳过自动重连逻辑：

1. 创建app/Database/CustomMySqlConnection.php：

<?php

namespace App\Database;

use Illuminate\Database\QueryException;
use Illuminate\Database\MySqlConnection;

class CustomMySqlConnection extends MySqlConnection
{
    protected function handleQueryException(QueryException $e, $query, $bindings, \Closure $callback)
    {
        // 直接抛出异常，不执行自动重连
        throw $e;
    }
}

2. 在app/Providers/AppServiceProvider.php的boot方法中替换默认MySQL连接解析：

use App\Database\CustomMySqlConnection;
use Illuminate\Support\Facades\DB;

public function boot()
{
    DB::extend('mysql', function ($config, $name) {
        $connection = new CustomMySqlConnection(
            $this->getPdo($config),
            $config['database'],
            $config['prefix'],
            $config
        );

        return $connection;
    });
}

方法2：用只读事务包装查询（无副作用） #

利用Laravel事务场景直接抛异常的逻辑，用只读事务包装SELECT查询：

// 执行需要监控超时的SELECT查询时
$results = DB::transaction(function () use ($yourQuery) {
    return DB::select($yourQuery);
}, 1); // 尝试次数设为1，避免事务重试

当连接被终止时，因处于事务中，Laravel会直接抛出异常，不会自动重连。只读事务对SELECT查询无副作用，实现简单。

方法3：主动检测连接状态并抛出异常 #

在终止连接后，主动执行简单查询触发异常，直接捕获抛出：

$id = session('process_id');
DB::statement("KILL $id");

// 主动检测连接状态
try {
    DB::select('SELECT 1');
} catch (\Illuminate\Database\QueryException $e) {
    throw new \RuntimeException('查询已被终止', 0, $e);
}

内容的提问来源于stack exchange，提问作者Tapacko