support queries containing OFFSET after LIMIT (#178)

Co-authored-by: Markus Staab <[email protected]>

Author: staabm

.phpstan-dba.cache

@@ -4,6 +4,7 @@
 
 namespace staabm\PHPStanDba\QueryReflection;
 
+use PHPStan\ShouldNotHappenException;
 use PHPStan\Type\ArrayType;
 use PHPStan\Type\BooleanType;
 use PHPStan\Type\ConstantScalarType;
@@ -113,6 +114,13 @@ private static function stripTraillingLimit(string $queryString): ?string
     {
         $queryString = rtrim($queryString, ';');
 
+        // strip trailling OFFSET
+        $queryString = preg_replace('/(.*)OFFSET\s+["\']?\d+["\']?\s*$/i', '$1', $queryString);
+
+        if (null === $queryString) {
+            throw new ShouldNotHappenException('Could not strip trailing offset from query');
+        }
+
         // XXX someday we will use a proper SQL parser,
         // which would also allow us to support even more complex expressions like SELECT .. LIMIT X, Y FOR UPDATE
         return preg_replace('/\s*LIMIT\s+["\']?\d+["\']?\s*(,\s*["\']?\d*["\']?)?\s*$/i', '', $queryString);

.phpunit-phpstan-dba.cache

@@ -163,4 +163,11 @@ public function placeholderInData(PDO $pdo)
         $stmt = $pdo->query($query, PDO::FETCH_ASSOC);
         assertType('PDOStatement<array{adaid: int<0, 4294967295>}>', $stmt);
     }
+
+    public function offsetAfterLimit(PDO $pdo, int $limit, int $offset)
+    {
+        $query = 'SELECT adaid FROM ada LIMIT '.$limit.' OFFSET '.$offset;
+        $stmt = $pdo->query($query, PDO::FETCH_ASSOC);
+        assertType('PDOStatement<array{adaid: int<0, 4294967295>}>', $stmt);
+    }
 }

src/QueryReflection/QuerySimulation.php

@@ -208,4 +208,42 @@ public function noErrorInBug94(Connection $connection)
         $orderId = 15315351;
         $connection->preparedQuery($sql, ['orderId' => $orderId, 'productId' => $productId, 'supplierId' => $supplierId]);
     }
+
+    public function noErrorOnBug175(Connection $connection, int $limit, int $offset)
+    {
+        $connection->preparedQuery('
+            SELECT email, adaid
+            FROM ada
+            WHERE gesperrt = ?
+            LIMIT        ?
+            OFFSET '.$offset.'
+        ', [1, $limit]);
+
+        $connection->preparedQuery('
+            SELECT email, adaid
+            FROM ada
+            WHERE gesperrt = ?
+            LIMIT        ?
+            OFFSET '.((int) $offset).'
+        ', [1, $limit]);
+    }
+
+    public function noErrorOnOffsetAfterLimit(Connection $connection, int $limit, int $offset)
+    {
+        $connection->preparedQuery('
+            SELECT email, adaid
+            FROM ada
+            WHERE gesperrt = ?
+            LIMIT        ?
+            OFFSET ?
+        ', [1, $limit, $offset]);
+
+        $connection->preparedQuery('
+            SELECT email, adaid
+            FROM ada
+            WHERE gesperrt = :gesperrt
+            LIMIT        :limit
+            OFFSET :offset
+        ', [':gesperrt' => 1, ':limit' => $limit, ':offset' => $offset]);
+    }
 }