Catch query exception on bulk update/delete

abnegate · abnegate · commit f944ad350ec8 · 2025-09-19T17:32:34.000+12:00
diff --git a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Delete.php b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Delete.php
@@ -124,6 +124,8 @@ public function action(string $databaseId, string $collectionId, array $queries,
             throw new Exception($this->getConflictException());
         } catch (RestrictedException) {
             throw new Exception($this->getRestrictedException());
+        } catch (QueryException $e) {
+            throw new Exception(Exception::GENERAL_QUERY_INVALID, $e->getMessage());
         }
 
         foreach ($documents as $document) {
diff --git a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Update.php b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Update.php
@@ -150,6 +150,8 @@ public function action(string $databaseId, string $collectionId, string|array $d
             throw new Exception(Exception::RELATIONSHIP_VALUE_INVALID, $e->getMessage());
         } catch (StructureException $e) {
             throw new Exception($this->getStructureException(), $e->getMessage());
+        } catch (QueryException $e) {
+            throw new Exception(Exception::GENERAL_QUERY_INVALID, $e->getMessage());
         }
 
         foreach ($documents as $document) {

Original file line number	Diff line number	Diff line change
`@@ -124,6 +124,8 @@ public function action(string $databaseId, string $collectionId, array $queries,`
`124`	`124`	`throw new Exception($this->getConflictException());`
`125`	`125`	`} catch (RestrictedException) {`
`126`	`126`	`throw new Exception($this->getRestrictedException());`
	`127`	`+ } catch (QueryException $e) {`
	`128`	`+ throw new Exception(Exception::GENERAL_QUERY_INVALID, $e->getMessage());`
`127`	`129`	`}`
`128`	`130`
`129`	`131`	`foreach ($documents as $document) {`
Original file line number	Diff line number	Diff line change
`@@ -150,6 +150,8 @@ public function action(string $databaseId, string $collectionId, string\|array $d`
`150`	`150`	`throw new Exception(Exception::RELATIONSHIP_VALUE_INVALID, $e->getMessage());`
`151`	`151`	`} catch (StructureException $e) {`
`152`	`152`	`throw new Exception($this->getStructureException(), $e->getMessage());`
	`153`	`+ } catch (QueryException $e) {`
	`154`	`+ throw new Exception(Exception::GENERAL_QUERY_INVALID, $e->getMessage());`
`153`	`155`	`}`
`154`	`156`
`155`	`157`	`foreach ($documents as $document) {`