FOR UPDATE SKIP LOCKED

Author: Alin Olteanu

composer.json

@@ -30,5 +30,5 @@
             "AlinO\\Db\\": "src"
         }
     },
-    "version": "3.1.0"
+    "version": "3.1.1"
 }

src/MysqliDb.php

@@ -203,6 +203,13 @@ class MysqliDb
      */
     protected $_forUpdate = false;
 
+    /**
+     * FOR UPDATE SKIP LOCKED flag
+     *
+     * @var bool
+     */
+    protected $_forUpdateSkipLocked = false;
+
     /**
      * LOCK IN SHARE MODE flag
      *
@@ -469,6 +476,7 @@ protected function reset()
         $this->returnType = 'array';
         $this->_nestJoin = false;
         $this->_forUpdate = false;
+        $this->_forUpdateSkipLocked = false;
         $this->_lockInShareMode = false;
         $this->_tableName = '';
         $this->_lastInsertId = null;
@@ -720,6 +728,7 @@ public function setQueryOption($options)
             'QUICK',
             'MYSQLI_NESTJOIN',
             'FOR UPDATE',
+            'FOR UPDATE SKIP LOCKED',
             'LOCK IN SHARE MODE'
         );
 
@@ -737,6 +746,8 @@ public function setQueryOption($options)
                 $this->_nestJoin = true;
             } elseif ($option == 'FOR UPDATE') {
                 $this->_forUpdate = true;
+            } elseif ($option == 'FOR UPDATE SKIP LOCKED') {
+                $this->_forUpdateSkipLocked = true;
             } elseif ($option == 'LOCK IN SHARE MODE') {
                 $this->_lockInShareMode = true;
             } else {
@@ -1692,6 +1703,9 @@ protected function _buildQuery($numRows = null, $tableData = null)
         if ($this->_forUpdate) {
             $this->_query .= ' FOR UPDATE';
         }
+        if ($this->_forUpdateSkipLocked) {
+            $this->_query .= ' FOR UPDATE SKIP LOCKED';
+        }
         if ($this->_lockInShareMode) {
             $this->_query .= ' LOCK IN SHARE MODE';
         }