navicat能通了

Author: aogg

README.md

@@ -10,6 +10,7 @@
 - ✅ **连接池**: 自动管理后端 MySQL 连接池，提高性能
 - ✅ **SQL 日志**: 完整的 SQL 执行日志记录
 - ✅ **协议兼容**: 支持基本的 MySQL 协议，包括查询、预处理语句等
+- ✅ **连接稳定性**: 自动连接恢复和超时处理，防止 "Lost connection" 错误
 
 ## 系统要求
 
@@ -157,6 +158,34 @@ MySQL 代理 (端口 3317)
 - **认证失败**: 确认代理账号配置正确
 - **后端连接失败**: 检查后端 MySQL 服务器可访问性
 - **连接池耗尽**: 调整 `pool.size` 配置
+- **"2013 - Lost connection to MySQL server during query" 错误**:
+
+  **可能原因**：
+  - 连接超时时间过短
+  - 查询执行时间过长
+  - 网络连接不稳定
+  - 连接池连接被意外关闭
+  - USE命令响应包格式不正确（缺少状态标志）
+
+  **解决方案**：
+  1. 检查并调整超时配置（已在最新版本中优化）
+  2. 修复USE命令响应包格式，添加SERVER_STATUS_AUTOCOMMIT标志
+  4. 监控连接池状态和系统资源
+  5. 调整MySQL服务器的超时参数
+  6. 重启代理服务以应用修复
+
+## 服务重启
+
+修改配置或代码后，需要重启代理服务：
+
+```bash
+# 如果使用Docker容器方式启动
+docker restart temp-hyperf-sqlLogProxy
+
+# 或者重新启动Hyperf服务
+php bin/hyperf.php stop
+php bin/hyperf.php start
+```
 
 ## 开发说明
 

app/Command/TestDbCommand.php

@@ -0,0 +1,79 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Command;
+
+use Hyperf\Command\Command as HyperfCommand;
+use Hyperf\Command\Annotation\Command;
+use Hyperf\DbConnection\Db;
+use Psr\Container\ContainerInterface;
+
+/**
+ * 测试数据库连接命令
+ */
+#[Command]
+class TestDbCommand extends HyperfCommand
+{
+    public function __construct(protected ContainerInterface $container)
+    {
+        parent::__construct('db:test');
+    }
+
+    public function configure()
+    {
+        parent::configure();
+        $this->setDescription('测试数据库连接');
+    }
+
+    public function handle()
+    {
+        $this->info('开始测试数据库连接...');
+
+        try {
+            // 测试 backend_mysql 连接
+            $this->info('测试 backend_mysql 连接...');
+            $connection = Db::connection('backend_mysql');
+            $this->info('获取连接对象成功');
+
+            // 检查连接对象的类型和可用方法
+            $this->info('连接对象类型: ' . get_class($connection));
+            $this->info('连接对象方法: ' . implode(', ', get_class_methods($connection)));
+
+            // 尝试不同的方法获取 PDO
+            $pdo = null;
+            if (method_exists($connection, 'getConnection')) {
+                $pdo = $connection->getConnection();
+                $this->info('通过 getConnection 获取 PDO');
+            } elseif (method_exists($connection, 'getPdo')) {
+                $pdo = $connection->getPdo();
+                $this->info('通过 getPdo 获取 PDO');
+            } elseif (method_exists($connection, 'getReadPdo')) {
+                $pdo = $connection->getReadPdo();
+                $this->info('通过 getReadPdo 获取 PDO');
+            } elseif (method_exists($connection, 'getWritePdo')) {
+                $pdo = $connection->getWritePdo();
+                $this->info('通过 getWritePdo 获取 PDO');
+            } else {
+                $this->error('无法获取 PDO 对象');
+                return;
+            }
+
+            if ($pdo instanceof \PDO) {
+                $this->info('PDO 对象有效，类型: ' . get_class($pdo));
+            } else {
+                $this->error('PDO 对象无效: ' . gettype($pdo) . ' 类: ' . (is_object($pdo) ? get_class($pdo) : 'N/A'));
+                return;
+            }
+
+            // 执行测试查询
+            $result = $connection->select('SELECT 12 as test_value, NOW() as current_time');
+            $this->info('查询执行成功: ' . json_encode($result));
+
+        } catch (\Throwable $e) {
+            $this->error('数据库连接测试失败: ' . $e->getMessage());
+            $this->error('文件: ' . $e->getFile() . ':' . $e->getLine());
+            $this->error('Trace: ' . $e->getTraceAsString());
+        }
+    }
+}

app/Helpers/PHPSQLParserHelper.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Helpers;
+
+class PHPSQLParserHelper extends \PHPSQLParser\PHPSQLParser
+{
+    public mixed $sql = '';
+    public function __construct($sql = false, $calcPositions = false, array $options = array())
+    {
+        parent::__construct($sql, $calcPositions, $options);
+        $this->sql = $sql;
+    }
+
+    public function isSelect(): bool
+    {
+        return isset($this->parsed['SELECT']) || isset($this->parsed['SHOW']);
+    }
+
+}

app/Helpers/helpers.php

@@ -0,0 +1,40 @@
+<?php
+
+/**
+ * 获取 string.
+ *
+ * @param array $bytes
+ *
+ * @return string
+ */
+function bytes_to_string(array $bytes)
+{
+    return implode(array_map('chr', $bytes));
+}
+
+if (!function_exists('get_exception_hyperf_array')) {
+
+    /**
+     * 转为可存储的数组
+     *
+     * @param \Throwable $exception
+     * @return array
+     */
+    function get_exception_hyperf_array($exception)
+    {
+        $exception_json = [
+            'exception_class_name' => get_class($exception),
+            'getMessage' => $exception->getMessage(),
+            'getFile' => $exception->getFile(),
+            'getCode' => $exception->getCode(),
+            'getTraceAsStringArr' => explode("\n", $exception->getTraceAsString()),
+        ];
+
+
+        if ($exception instanceof \Hyperf\Database\Exception\QueryException) {
+            $exception_json['getSql'] = $exception->getSql();
+        }
+
+        return $exception_json;
+    }
+}

app/Protocol/MySql/Auth.php

@@ -12,6 +12,8 @@ class Auth
     public const CAPABILITIES = 0x00aff7df;
     private const MAX_PACKET_SIZE = 0xffffff;
 
+    public static $OK = [7, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0];
+
     public static function generateAuthData(int $length = 20): string
     {
         $data = '';

app/Protocol/MySql/Packet.php

@@ -10,6 +10,8 @@ class Packet
     private int $sequenceId;
     private string $payload;
 
+    public $toBytes;
+
     public function __construct(int $length, int $sequenceId, string $payload)
     {
         $this->length = $length;
@@ -47,6 +49,10 @@ public static function fromString(string $data): self
 
     public function toBytes(): string
     {
+        if ($this->toBytes) {
+            return $this->toBytes;
+        }
+
         $len = pack('V', $this->length);
         return substr($len, 0, 3) . chr($this->sequenceId) . $this->payload;
     }