Override findOneByColumn, findAllByColumn and sum to use deletiontimestamp.

src/Mapping.php

@@ -2,6 +2,7 @@
 
 namespace PicoMapper;
 
+use Override;
 use PicoDb\Database;
 use PicoDb\Table;
 
@@ -96,6 +97,54 @@
         return parent::count($column);
     }
 
+    /**
+     * Fetches all values for a single column.
+     *
+     * @param string $column
+     * @return mixed
+     */
+    #[Override]
+    public function findAllByColumn($column)
+    {
+        if ($this->definition->getDeletionTimestamp()) {
+            $this->isNull($this->prefixTableNameTo($this->definition->getDeletionTimestamp()));
+        }
+
+        return parent::findAllByColumn($column);
+    }
+
+    /**
+     * Fetches a single column value from the first matching row.
+     *
+     * @param string $column
+     * @return string|bool
+     */
+    #[Override]
+    public function findOneColumn($column)
+    {
+        if ($this->definition->getDeletionTimestamp()) {
+            $this->isNull($this->prefixTableNameTo($this->definition->getDeletionTimestamp()));
+        }
+
+        return parent::findOneColumn($column);
+    }
+
+    /**
+     * Sums a column across all matching rows.
+     *
+     * @param string $column
+     * @return float
+     */
+    #[Override]
+    public function sum(string $column)
+    {
+        if ($this->definition->getDeletionTimestamp()) {
+            $this->isNull($this->prefixTableNameTo($this->definition->getDeletionTimestamp()));
+        }
+
+        return parent::sum($column);
+    }
+
     /**
      * Maps the provided array into the database.
      *

tests/MappingTest.php

@@ -192,6 +192,42 @@ public function testRemove()
         );
     }
 
+    public function testFindAllByColumnExcludesSoftDeletedRecords()
+    {
+        $this->getMapping()->eq('id', 1)->remove();
+
+        $names = $this->getMapping()->findAllByColumn('name');
+
+        $this->assertCount(1, $names);
+        $this->assertNotContains('John Doe', $names);
+        $this->assertContains('Jane Doe', $names);
+    }
+
+    public function testFindOneColumnExcludesSoftDeletedRecords()
+    {
+        $this->getMapping()->eq('id', 1)->remove();
+
+        $name = $this->getMapping()->eq('id', 1)->findOneColumn('name');
+
+        $this->assertFalse($name);
+    }
+
+    public function testSumExcludesSoftDeletedRecords()
+    {
+        $this->db->execute('CREATE TABLE scores (id INTEGER PRIMARY KEY, customer_id INTEGER, points INTEGER, date_deleted TEXT)');
+        $this->db->execute('INSERT INTO scores (id, customer_id, points) VALUES (1, 1, 100), (2, 2, 200)');
+
+        $score = (new Definition('scores'))
+            ->withColumns('id', 'customer_id', 'points')
+            ->withDeletionTimestamp('date_deleted');
+
+        $this->assertSame(300.0, (new Mapping($this->db, $score))->sum('points'));
+
+        (new Mapping($this->db, $score))->eq('id', 1)->remove();
+
+        $this->assertSame(200.0, (new Mapping($this->db, $score))->sum('points'));
+    }
+
     public function testReadOnlyInsert()
     {
         $customer = [