Draft: Worker mode: implement reset interface

src/Ting/ConnectionPool.php

@@ -28,7 +28,7 @@
 use CCMBenchmark\Ting\Exceptions\ConnectionException;
 use CCMBenchmark\Ting\Logger\DriverLoggerInterface;
 
-class ConnectionPool implements ConnectionPoolInterface
+class ConnectionPool implements ConnectionPoolInterface, ResetInterface
 {
 
     /**
@@ -226,4 +226,9 @@ public function getDriverClass($name)
 
         return $this->connectionConfig[$name]['namespace'] . '\\Driver';
     }
+
+    public function reset(): void
+    {
+        $this->closeAll();
+    }
 }

src/Ting/Driver/Mysqli/Driver.php

@@ -35,8 +35,6 @@
 use CCMBenchmark\Ting\Logger\DriverLoggerInterface;
 use CCMBenchmark\Ting\Repository\CollectionInterface;
 
-use function is_null;
-
 class Driver implements DriverInterface
 {
 

src/Ting/Repository/Repository.php

@@ -37,14 +37,15 @@
 use CCMBenchmark\Ting\Exceptions\RepositoryException;
 use CCMBenchmark\Ting\MetadataRepository;
 use CCMBenchmark\Ting\Query\QueryFactory;
+use CCMBenchmark\Ting\ResetInterface;
 use CCMBenchmark\Ting\Serializer\SerializerFactoryInterface;
 use CCMBenchmark\Ting\UnitOfWork;
 use Doctrine\Common\Cache\Cache;
 
 /**
  * @template T
  */
-abstract class Repository
+abstract class Repository implements ResetInterface
 {
 
     const QUERY_SELECT = 'select';
@@ -412,4 +413,10 @@ public function getMetadata()
     {
         return $this->metadata;
     }
+
+    public function reset(): void
+    {
+        $this->unitOfWork->reset();
+        $this->connection = $this->metadata->getConnection($this->connectionPool);
+    }
 }

src/Ting/ResetInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace CCMBenchmark\Ting;
+
+interface ResetInterface
+{
+    public function reset(): void;
+}

src/Ting/UnitOfWork.php

@@ -31,7 +31,7 @@
 use CCMBenchmark\Ting\Query\QueryFactoryInterface;
 use CCMBenchmark\Ting\Repository\Metadata;
 
-class UnitOfWork implements PropertyListenerInterface
+class UnitOfWork implements PropertyListenerInterface, ResetInterface
 {
     const STATE_NEW     = 1;
     const STATE_MANAGED = 2;
@@ -229,6 +229,15 @@ public function detachAll()
         $this->entities = [];
     }
 
+    /**
+     * Reset state between requests (worker mode: FrankenPHP, Swoole, RoadRunner, etc.)
+     */
+    public function reset(): void
+    {
+        $this->detachAll();
+        $this->statements = [];
+    }
+
     /**
      * Flag the entity to be deleted on next process
      *