fix limit for update and delete queries, added affected rows to query result

Author: matthi4s

src/Driver/Mysqli/Mysqli.php

@@ -6,9 +6,12 @@
     Driver\Features\CRUDAbleInterface,
     Driver\Features\CRUDQueryableInterface,
     ModelInterface,
+    Query\DeleteQuery,
     Query\Generator\SQL,
     Query\Query,
-    Query\QueryResult};
+    Query\QueryResult,
+    Query\UpdateQuery
+};
 use Exception;
 use mysqli_result;
 
@@ -240,6 +243,11 @@ public function query(Query $query): QueryResult
 
         $result = new QueryResult((bool)$rawQueryResult);
         $result->setQueryString($queryString);
+        if ($query instanceof UpdateQuery || $query instanceof DeleteQuery) {
+            $result->setAffectedRows(mysqli_affected_rows($this->connection));
+            return $result;
+        }
+
         if (is_bool($rawQueryResult)) {
             return $result;
         }

src/Query/Generator/SQL.php

@@ -95,7 +95,11 @@ public function generate(Query $query): string
         }
 
         if ($limit = $query->getLimit()) {
-            $queryString .= " LIMIT " . $limit->start . ", " . $limit->length;
+            if ($query instanceof UpdateQuery || $query instanceof DeleteQuery) {
+                $queryString .= " LIMIT " . $limit->length;
+            } else {
+                $queryString .= " LIMIT " . $limit->start . ", " . $limit->length;
+            }
         }
 
         return $queryString;

src/Query/QueryResult.php

@@ -23,6 +23,13 @@ class QueryResult extends ModelCollectionResult
      */
     protected ?string $queryString = null;
 
+    /**
+     * Number of affected rows in update or delete queries
+     *
+     * @var int|null
+     */
+    protected ?int $affectedRows = null;
+
     /**
      * QueryResult constructor.
      *
@@ -57,4 +64,24 @@ public function setQueryString(?string $queryString): QueryResult
         }
         return $this;
     }
+
+    /**
+     * @return int|null
+     */
+    public function getAffectedRows(): ?int
+    {
+        return $this->affectedRows;
+    }
+
+    /**
+     * @param int|null $affectedRows
+     * @return $this
+     */
+    public function setAffectedRows(?int $affectedRows): static
+    {
+        if ($this->affectedRows === null) {
+            $this->affectedRows = $affectedRows;
+        }
+        return $this;
+    }
 }