update skipLocked() method for OCI8

michalsn · michalsn · commit 1952bcb52d95 · 2024-09-20T07:28:13.000+02:00
diff --git a/src/Models/QueueJobModel.php b/src/Models/QueueJobModel.php
@@ -100,6 +100,10 @@ private function skipLocked(string $sql): string
             return str_replace('WHERE', $replace, $sql);
         }
 
+        if ($this->db->DBDriver === 'OCI8') {
+            $sql = "SELECT * FROM ({$sql}) subquery";
+        }
+
         return $sql .= ' FOR UPDATE SKIP LOCKED';
     }
 

Original file line number	Diff line number	Diff line change
`@@ -100,6 +100,10 @@ private function skipLocked(string $sql): string`
`100`	`100`	`return str_replace('WHERE', $replace, $sql);`
`101`	`101`	`}`
`102`	`102`
	`103`	`+ if ($this->db->DBDriver === 'OCI8') {`
	`104`	`+ $sql = "SELECT * FROM ({$sql}) subquery";`
	`105`	`+ }`
	`106`	`+`
`103`	`107`	`return $sql .= ' FOR UPDATE SKIP LOCKED';`
`104`	`108`	`}`
`105`	`109`