future: support

Author: cclilshy

src/Interface/StatementInterface.php

@@ -19,4 +19,9 @@ interface StatementInterface
      * @return static
      */
     public function execute(array $params = []): static;
+
+    /**
+     * @return void
+     */
+    public function close(): void;
 }

src/MySQL/Client.php

@@ -768,12 +768,12 @@ protected function sendAuthSwitchResponse(): void
      * 一次完整请求流程
      * @param string $command
      * @param string $query 要发送的数据包
-     * @param BufferInterface $heap 数据堆, 用于存储响应结果
-     * @return ResultSet 服务器响应结果
+     * @param ?BufferInterface $heap 数据堆, 用于存储响应结果
+     * @return ?ResultSet 服务器响应结果
      * @throws ConnectionException
      * @throws MySQLException
      */
-    public function request(string $command, string $query, BufferInterface $heap): ResultSet
+    public function request(string $command, string $query, ?BufferInterface $heap = null): ?ResultSet
     {
         try {
             // 获得唯一所
@@ -785,7 +785,7 @@ public function request(string $command, string $query, BufferInterface $heap):
             // 发送数据包
             $this->connection->send("{$command}{$query}");
 
-            while (1) {
+            while ($heap) {
                 try {
                     $payload = $this->connection->waitPayload();
                 } catch (Throwable $e) {
@@ -814,7 +814,7 @@ public function request(string $command, string $query, BufferInterface $heap):
                 }
             }
 
-            return new ResultSet($heap);
+            return $heap ? new ResultSet($heap) : null;
         } finally {
             $this->mutex->unlock();
         }

src/MySQL/Data/Buffer/Statement.php

@@ -36,6 +36,7 @@
 use function is_string;
 use function preg_replace_callback;
 use function is_int;
+use function pack;
 
 class Statement implements BufferInterface, StatementInterface
 {
@@ -251,7 +252,7 @@ public function execute(array $params = []): static
                 }
 
                 $correctType = Type::fromValue($value) ?: $this->params[$key]->type;
-                $header .=  Encode::FixedLengthInteger($correctType->value, 2);
+                $header .= Encode::FixedLengthInteger($correctType->value, 2);
                 $body .= ProtocolBinary::encode($value, $correctType);
             }
 
@@ -267,6 +268,14 @@ public function execute(array $params = []): static
         return $this;
     }
 
+    /**
+     * @return void
+     */
+    public function close(): void
+    {
+        $this->connection->request("\x19", pack('V', $this->statementOk->stmtId));
+    }
+
     /**
      * @param string $content
      * @return void

src/PDOStatement.php

@@ -44,6 +44,7 @@ public function __construct(private readonly StatementInterface $statement, priv
     public function execute(?array $params = []): bool
     {
         $result = $this->statement->execute(array_merge($this->params, $params));
+        $this->statement->close();
         return $result->rowCount() >= 0;
     }