New Entity ORM repair() method

src/Phaseolies/Database/Entity/Builder.php

@@ -21,7 +21,6 @@
 use Phaseolies\Support\Facades\URL;
 use Phaseolies\Support\Contracts\Encryptable;
 use Phaseolies\Support\Collection;
-
 use Phaseolies\Database\Entity\Model;
 
 class Builder
@@ -2964,6 +2963,29 @@ public function search(array $attributes, ?string $searchTerm = null): self
         return $this->where($searchQuery);
     }
 
+    /**
+     * Get records and fix/normalize data
+     *
+     * @param callable $fixer
+     * @param bool $saveChanges
+     * @return Collection
+     */
+    public function repair(callable $fixer, bool $saveChanges = false): Collection
+    {
+        $results = $this->get();
+
+        foreach ($results as $item) {
+            $original = $item->getAttributes();
+            $fixer($item);
+
+            if ($saveChanges && $item->getAttributes() !== $original) {
+                $item->save();
+            }
+        }
+
+        return $results;
+    }
+
     /**
      * Convert camelCase to snake_case for column names
      *

tests/Model/Query/EntityModelQueryTest.php

@@ -15,6 +15,7 @@
 use Phaseolies\DI\Container;
 use PHPUnit\Framework\TestCase;
 use PDO;
+use Tests\Support\Model\MockProduct;
 
 class EntityModelQueryTest extends TestCase
 {
@@ -97,7 +98,20 @@ private function createTestTables(): void
             )
         ");
 
+        $this->pdo->exec("
+            CREATE TABLE product (
+                price INTEGER
+            )
+        ");
+
         // Insert test data
+        $this->pdo->exec("
+            INSERT INTO product (price) VALUES
+            (875),
+            (435),
+            (999)
+        ");
+
         $this->pdo->exec("
             INSERT INTO users (name, email, age, status, created_at) VALUES
             ('John Doe', 'john@example.com', 30, 'active', '2024-01-01 10:00:00'),
@@ -2605,4 +2619,46 @@ public function testPostTagRelateMethod()
         $this->assertEquals([2], array_keys($changes['detached']));
         $this->assertEquals([], $changes['updated']);
     }
+
+    public function testRepairMethodFetchingRecords()
+    {
+        $products = MockProduct::repair(function ($product) {
+            $product->price = preg_replace('/[^0-9]/', '', $product->price);
+        }, false);
+
+        $this->assertEquals(3, count($products));
+    }
+
+    public function testRepairPreviewsPriceCleanupWithoutPersistingChanges()
+    {
+        $products = MockProduct::repair(function ($product) {
+            $product->price = preg_replace('/[^0-5]/', '', $product->price);
+        }, false);
+
+        foreach ($products[0] as $product) {
+            $this->assertTrue(str_contains($product->price, 5));
+        }
+
+        // Cause product 3 id price is = 999
+        foreach ($products[2] as $product) {
+            $this->assertNull($product->price);
+        }
+    }
+
+    public function testRepairMethodSaveChanges()
+    {
+        $products = MockProduct::query()
+            ->repair(function ($product) {
+                $product->price = preg_replace('/[^0-9]/', '', $product->price);
+            }, true);
+
+        foreach ($products[0] as $product) {
+            $this->assertTrue(str_contains($product->price, 5));
+        }
+
+        // Cause product 3 id price is = 999
+        foreach ($products[2] as $product) {
+            $this->assertNull($product->price);
+        }
+    }
 }

tests/Support/Model/MockProduct.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Tests\Support\Model;
+
+use Phaseolies\Database\Entity\Model;
+
+class MockProduct extends Model
+{
+    protected $table = 'product';
+
+    protected $primaryKey = 'id';
+
+    protected $connection = 'default';
+
+    protected $timeStamps = false;
+
+    protected $creatable = ['price'];
+}