Worker mode: implement reset interface

.github/workflows/tests.yml

@@ -12,7 +12,6 @@ jobs:
     strategy:
       matrix:
         php:
-          - 8.0
           - 8.1
           - 8.2
           - 8.3

CHANGELOG

@@ -1,3 +1,7 @@
+Unreleased:
+    * Drop PHP 8.0 support, PHP >= 8.1 is now required
+    * Add ResetInterface on ConnectionPool, UnitOfWork and Repository to reset state between requests (worker mode)
+
 3.12.1 (2025-12-16):
     * Fix Hydrator: disable identity map now prevent storing entities
 

composer.json

@@ -21,7 +21,7 @@
     "type": "library",
     "license": "Apache-2.0",
     "require": {
-        "php": ">=8.0",
+        "php": ">=8.1",
         "aura/sqlquery": "^2.6 || ^3.0",
         "doctrine/cache": "^1.6",
         "symfony/property-access": "^6.0 || ^7.0"

src/Ting/ConnectionPool.php

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

src/Ting/Repository/Repository.php

@@ -38,14 +38,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
 {
     public const QUERY_SELECT = 'select';
     public const QUERY_INSERT = 'insert';
@@ -403,4 +404,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

@@ -33,7 +33,7 @@
 use CCMBenchmark\Ting\Repository\Metadata;
 use WeakMap;
 
-class UnitOfWork implements PropertyListenerInterface
+class UnitOfWork implements PropertyListenerInterface, ResetInterface
 {
     public const STATE_NEW     = 1;
     public const STATE_MANAGED = 2;
@@ -219,6 +219,15 @@ public function detachAll(): void
         $this->entities = new WeakMap();
     }
 
+    /**
+     * 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
      *