update 通过提前存储对象在执行完成后再进行获取避免了自己获取PDO对象

Author: kvnZero

app/ApiJson/Method/GetMethod.php

@@ -5,6 +5,7 @@
 use App\ApiJson\Parse\Handle;
 use App\Event\ApiJson\QueryExecuteAfter;
 use App\Event\ApiJson\QueryExecuteBefore;
+use App\Event\ApiJson\QueryResult;
 use Hyperf\Utils\ApplicationContext;
 use Psr\EventDispatcher\EventDispatcherInterface;
 
@@ -31,6 +32,11 @@ protected function process()
 
         if(is_null($event->result)) {
             $result = $this->query->all();
+
+            $queryEvent = new QueryResult($result);
+            ApplicationContext::getContainer()->get(EventDispatcherInterface::class)->dispatch($queryEvent);
+
+            $result = $queryEvent->result;
         } else {
             $result = $event->result;
         }

app/ApiJson/Model/MysqlQuery.php

@@ -4,12 +4,8 @@
 
 use App\ApiJson\Entity\ConditionEntity;
 use App\ApiJson\Interface\QueryInterface;
-use App\Event\ApiJson\MysqlQueryAfter;
 use Hyperf\Database\Query\Builder;
 use Hyperf\DbConnection\Db;
-use Hyperf\Utils\ApplicationContext;
-use PDO;
-use Psr\EventDispatcher\EventDispatcherInterface;
 
 class MysqlQuery implements QueryInterface
 {
@@ -51,17 +47,7 @@ public function getPrimaryKey(): string
     public function all(): array
     {
         $this->buildQuery();
-
-        $pdo = $this->db->getConnection()->getReadPdo(); //为了实现自动解析Json 找不到Hyperf的能提供的能力 则手动拿PDO处理
-
-        $statement = $pdo->prepare($this->toSql());
-        $statement->execute($this->getBindings());
-        $result = $statement->fetchAll(PDO::FETCH_ASSOC);
-
-        $event = new MysqlQueryAfter($result, $statement, $this->toSql(), $this->getBindings()); //这可能并不是很好的写法 待暂无其他思路去实现
-        ApplicationContext::getContainer()->get(EventDispatcherInterface::class)->dispatch($event);
-
-        return $event->result;
+        return $this->db->get()->all();
     }
 
     public function count($columns = '*'): int

app/Constants/ConfigCode.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  [email protected]
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+namespace App\Constants;
+
+use Hyperf\Constants\AbstractConstants;
+use Hyperf\Constants\Annotation\Constants;
+
+/**
+ * @Constants
+ */
+class ConfigCode extends AbstractConstants
+{
+    /**
+     * @Message("查询对象")
+     */
+	public const DB_QUERY_STATEMENT = "ApiJson_DbQueryStatement";
+}

app/Event/ApiJson/MysqlQueryAfter.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Event\ApiJson;
+
+use PDOStatement;
+
+/**
+ * 查询完毕的处理
+ */
+class QueryResult
+{
+    public function __construct(public array $result)
+    {
+    }
+}

app/Event/ApiJson/QueryResult.php

@@ -0,0 +1,30 @@
+<?php
+declare(strict_types=1);
+
+namespace App\Listener;
+
+use App\Constants\ConfigCode;
+use Hyperf\Database\Events\StatementPrepared;
+use Hyperf\Event\Annotation\Listener;
+use Hyperf\Event\Contract\ListenerInterface;
+use Hyperf\Utils\Context;
+
+/**
+ * @Listener
+ */
+class DbPreparedListener implements ListenerInterface
+{
+    public function listen(): array
+    {
+        return [
+            StatementPrepared::class,
+        ];
+    }
+
+    public function process(object $event)
+    {
+        if ($event instanceof StatementPrepared) {
+            Context::set(ConfigCode::DB_QUERY_STATEMENT, $event->statement);
+        }
+    }
+}

app/Listener/DbPreparedListener.php

@@ -3,9 +3,11 @@
 
 namespace App\Listener;
 
-use App\Event\ApiJson\MysqlQueryAfter;
+use App\Constants\ConfigCode;
+use App\Event\ApiJson\QueryResult;
 use Hyperf\Event\Annotation\Listener;
 use Hyperf\Event\Contract\ListenerInterface;
+use Hyperf\Utils\Context;
 
 /**
  * @Listener
@@ -15,17 +17,23 @@ class QueryResultTryToJsonListener implements ListenerInterface
     public function listen(): array
     {
         return [
-            MysqlQueryAfter::class,
+            QueryResult::class,
         ];
     }
 
     public function process(object $event)
     {
-        if (!$event instanceof MysqlQueryAfter) return;
+        if (!$event instanceof QueryResult) return;
+
+        $statement = Context::get(ConfigCode::DB_QUERY_STATEMENT);
+        if (empty($statement)) {
+            return;
+        }
+
         $columnCount = count(array_keys(current($event->result)));
         $columnMeta = [];
         for ($i = 0; $i <= $columnCount; $i++) {
-            $meta = $event->statement->getColumnMeta($i);
+            $meta = $statement->getColumnMeta($i);
             if ($meta) {
                 $columnMeta[$meta['name']] = $meta;
             }