update skipLocked() method for OCI8

codeigniter4 · Sep 20, 2024 · ca8e0b9 · ca8e0b9
1 parent 1952bcb
commit ca8e0b9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Models/QueueJobModel.php b/src/Models/QueueJobModel.php
@@ -101,7 +101,8 @@ private function skipLocked(string $sql): string
         }
 
         if ($this->db->DBDriver === 'OCI8') {
-            $sql = "SELECT * FROM ({$sql}) subquery";
+            $sql = preg_replace('/ OFFSET .*/', '', $sql);
+            $sql = "SELECT * FROM ({$sql}) WHERE ROWNUM = 1";
         }
 
         return $sql .= ' FOR UPDATE SKIP LOCKED';