优化 ProxyAuthenticator 和 BackendExecutor 的日志记录，增强调试信息；更新 MySQLHandshake 方法以支持外部 authPluginData 参数；调整 MySQLProxyService 以确保握手包生成的一致性。

Author: aogg

app/Proxy/Auth/ProxyAuthenticator.php

@@ -73,10 +73,10 @@ public function authenticate(
         // 验证密码
         $isValid = $this->verifyPassword($authResponse, $account['password'], $authPluginData);
 
-        $this->logger->info('代理账号验证结果，密码错误', [
+        $this->logger->info('代理账号验证结果', [
             'username' => $username,
             'database' => $database,
-            'is_valid' => $isValid,
+            '是否成功' => $isValid,
         ]);
 
         return $isValid;
@@ -122,6 +122,10 @@ private function verifyPassword(string $clientAuthResponse, string $storedPasswo
         $isValid = hash_equals($expectedResponse, $clientAuthResponse);
 
         $this->logger->debug('密码验证详情', [
+            // 以 hex 形式记录二进制内容，便于对比与调试（生产请谨慎）
+            'auth_plugin_data_hex' => bin2hex($authPluginData),
+            'client_response_hex' => bin2hex($clientAuthResponse),
+            'expected_response_hex' => bin2hex($expectedResponse),
             'client_response_length' => mb_strlen($clientAuthResponse),
             'expected_response_length' => mb_strlen($expectedResponse),
             'responses_match' => $isValid,

app/Proxy/Executor/BackendExecutor.php

@@ -4,7 +4,7 @@
 
 namespace App\Proxy\Executor;
 
-use Hyperf\DB\DB;
+use Hyperf\DbConnection\Db;
 use App\Protocol\MySql\Packet;
 use Hyperf\Logger\LoggerFactory;
 use Psr\Log\LoggerInterface;
@@ -40,11 +40,19 @@ public function execute(string $sql): array
 
         try {
             // 使用 Hyperf 数据库连接执行 SQL
+            /** @var \Hyperf\DbConnection\Connection $connection */
             $connection = DB::connection('backend_mysql');
 
             // 对于 SELECT 查询，使用 select 方法
-            if (stripos(trim($sql), 'select') === 0) {
+            // 支持前置注释（例如 MySQL Connector/J 会在前面带注释），所以使用正则去除注释后判断
+            if (preg_match('/^\s*(?:\/\*[\s\S]*?\*\/\s*)*(select)\b/i', $sql) === 1) {
                 $result = $connection->select($sql);
+                // 某些 PDO 驱动或数据库层返回对象（stdClass），但下游期望关联数组
+                if (!empty($result)) {
+                    $result = array_map(function ($row) {
+                        return is_array($row) ? $row : (array) $row;
+                    }, $result);
+                }
 
                 $elapsedMs = (int) ((microtime(true) - $startTime) * 1000);
 
@@ -58,7 +66,22 @@ public function execute(string $sql): array
             } else {
                 // 对于其他查询（如 INSERT, UPDATE, DELETE），使用 statement 方法
                 $affectedRows = $connection->statement($sql);
-                $lastInsertId = $connection->getPdo()->lastInsertId();
+                // 某些驱动 statement() 返回 bool 而非受影响行数，统一转换为 int
+                if (is_bool($affectedRows)) {
+                    $affectedRows = $affectedRows ? 1 : 0;
+                } else {
+                    $affectedRows = (int) $affectedRows;
+                }
+                // 尝试通过可用方法获取最后插入 ID
+                $lastInsertId = 0;
+                if (method_exists($connection, 'getPdo')) {
+                    $pdo = $connection->getPdo();
+                    if ($pdo instanceof \PDO) {
+                        $lastInsertId = (int) $pdo->lastInsertId();
+                    }
+                } elseif (method_exists($connection, 'lastInsertId')) {
+                    $lastInsertId = (int) $connection->lastInsertId();
+                }
 
                 $elapsedMs = (int) ((microtime(true) - $startTime) * 1000);
 
@@ -236,14 +259,25 @@ public function getPoolStats(): array
     {
         // 使用 Hyperf 的连接池统计
         try {
+            /** @var \Hyperf\DbConnection\Connection $connection */
             $connection = DB::connection('backend_mysql');
-            $pool = $connection->getPool();
+            // 使用动态检测以兼容不同 DB 实现
+            if (method_exists($connection, 'getPool')) {
+                $pool = $connection->getPool();
+                return [
+                    'pool_type' => 'hyperf',
+                    'pool_name' => 'backend_mysql',
+                    'connections_count' => $pool->getConnectionsCount(),
+                    'idle_connections_count' => $pool->getIdleConnectionsCount(),
+                ];
+            }
 
+            // 如果没有 pool 支持，则返回基础信息
             return [
                 'pool_type' => 'hyperf',
                 'pool_name' => 'backend_mysql',
-                'connections_count' => $pool->getConnectionsCount(),
-                'idle_connections_count' => $pool->getIdleConnectionsCount(),
+                'connections_count' => null,
+                'idle_connections_count' => null,
             ];
         } catch (\Throwable $e) {
             return [

app/Proxy/Protocol/MySQLHandshake.php

@@ -30,11 +30,16 @@ public function __construct(LoggerFactory $loggerFactory)
 
     /**
      * 创建服务器握手包
+     *
+     * @param int $threadId 线程/连接 id
+     * @param string|null $authPluginData 如果传入则使用该 auth 插件数据（保证握手与验证使用相同的 salt）
      */
-    public function createServerHandshake(int $threadId): Packet
+    public function createServerHandshake(int $threadId, ?string $authPluginData = null): Packet
     {
-        // 生成随机认证插件数据
-        $authPluginData = $this->generateAuthPluginData(20);
+        // 使用外部传入的 authPluginData（如果有），否则生成新的
+        if ($authPluginData === null) {
+            $authPluginData = $this->generateAuthPluginData(20);
+        }
         $authPluginData1 = substr($authPluginData, 0, 8);
         $authPluginDataLen = strlen($authPluginData);
         $authPluginData2 = substr($authPluginData, 8);
@@ -59,6 +64,8 @@ public function createServerHandshake(int $threadId): Packet
             'capabilities' => sprintf('0x%08x', self::CAPABILITIES),
             'charset' => self::CHARSET,
             'auth_plugin_data_length' => $authPluginDataLen,
+            // 为调试方便以 hex 形式记录 auth 插件数据（注意生产环境隐私）
+            'auth_plugin_data_hex' => bin2hex($authPluginData),
         ]);
 
         return Packet::create(0, $payload);

app/Proxy/Service/MySQLProxyService.php

@@ -48,8 +48,8 @@ public function handleConnect(ConnectionContext $context): Packet
             'remote_port' => $context->getClientPort(),
         ]);
 
-        // 生成并返回服务器握手包
-        return $this->handshake->createServerHandshake($context->getThreadId());
+        // 生成并返回服务器握手包，使用 context 中保存的 authPluginData（确保发送给客户端的 salt 与后续验证一致）
+        return $this->handshake->createServerHandshake($context->getThreadId(), $context->getAuthPluginData());
     }
 
     /**