Add AbstractQueryDataReader methods for query result reaching

src/AbstractQueryDataReader.php

@@ -74,6 +74,7 @@
 
             /** @var array|object $row */
             foreach ($iterator as $index => $row) {
+                $this->reachRow($row);
                 yield $index => $this->createItem($row);
             }
         }
@@ -89,16 +90,16 @@
         if ($this->count === null) {
             $q = $this->countParam ?? '*';
 
             if ($q === '*' && is_array($this->data) && !$this->limit && !$this->offset) {
                 $this->count = count($this->data);
             } else {
                 $query = $this->getPreparedQuery();
                 $query->offset(null);
                 $query->limit(null);
                 $query->orderBy('');
 
                 /** @psalm-var non-negative-int */
                 $this->count = (int) $query->count($q);
             }
         }
 
@@ -107,15 +108,15 @@
 
     public function getPreparedQuery(): QueryInterface
     {
         $query = $this->applyFilter(clone $this->query);
         $query = $this->applyHaving($query);
 
         if ($this->limit) {
             $query->limit($this->limit);
         }
 
         if ($this->offset) {
             $query->offset($this->offset);
         }
 
         if ($criteria = $this->sort?->getCriteria()) {
@@ -282,11 +283,15 @@
     {
         if ($this->data === null) {
             $this->data = [];
+
+            $rows = $this->getPreparedQuery()->all();
+            $this->reachRows($rows);
+
             /**
              * @psalm-var TKey $key
              * @psalm-var array $row
              */
-            foreach ($this->getPreparedQuery()->all() as $key => $row) {
+            foreach ($rows as $key => $row) {
                 $this->data[$key] = $this->createItem($row);
             }
         }
@@ -317,6 +322,30 @@
      */
     abstract protected function createItem(array|object $row): array|object;
 
+    /**
+     * This method is called before processing the query results ({@see read()}).
+     *
+     * It allows modifying the array of rows before passing them to the {@see createItem()} method.
+     *
+     * @param array $rows An array of query result rows.
+     *
+     * @psalm-param array<array|object> $rows
+     */
+    protected function reachRows(array &$rows): void
+    {
+    }
+
+    /**
+     * This method is called before processing each individual row of the query result ({@see getIterator()}).
+     *
+     * It allows modifying the row before passing it to the {@see createItem()} method.
+     *
+     * @param array|object $row A single row from the query result.
+     */
+    protected function reachRow(array|object &$row): void
+    {
+    }
+
     public function getFilter(): ?FilterInterface
     {
         return $this->filter;