wip

Author: brendt

packages/database/src/GenericDatabase.php

@@ -82,11 +82,15 @@ public function fetch(BuildsQuery|Query $query): array
 
         $bindings = $this->resolveBindings($query);
 
-        $pdoQuery = $this->connection->prepare($query->toSql());
+        try {
+            $pdoQuery = $this->connection->prepare($query->toSql());
 
-        $pdoQuery->execute($bindings);
+            $pdoQuery->execute($bindings);
 
-        return $pdoQuery->fetchAll(PDO::FETCH_NAMED);
+            return $pdoQuery->fetchAll(PDO::FETCH_NAMED);
+        } catch (PDOException $pdoException) {
+            throw new QueryWasInvalid($query, $bindings, $pdoException);
+        }
     }
 
     public function fetchFirst(BuildsQuery|Query $query): ?array

tests/Integration/Database/GenericDatabaseTest.php

@@ -6,6 +6,7 @@
 
 use Exception;
 use Tempest\Database\Database;
+use Tempest\Database\Exceptions\QueryWasInvalid;
 use Tempest\Database\Migrations\CreateMigrationsTable;
 use Tempest\Database\Query;
 use Tests\Tempest\Fixtures\Migrations\CreateAuthorTable;
@@ -67,4 +68,18 @@ public function test_query_with_semicolons(): void
 
         $this->assertSame(1, query(Publisher::class)->count()->execute());
     }
+
+    public function test_query_was_invalid_exception_is_thrown_on_fetch(): void
+    {
+        $this->assertException(QueryWasInvalid::class, function () {
+            query('books')->select()->orderBy('title DES')->first();
+        });
+    }
+
+    public function test_query_was_invalid_exception_is_thrown_on_execute(): void
+    {
+        $this->assertException(QueryWasInvalid::class, function () {
+            query('books')->update(title: 'Timeline Taxi')->where('title = ?')->execute();
+        });
+    }
 }