JSON_EXTRACT to extended MySQL dialect

phalcon · Nov 6, 2018 · ce8e8ec · ce8e8ec
1 parent 995d5b5
commit ce8e8ec
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/Library/Phalcon/Db/Dialect/MysqlExtended.php b/Library/Phalcon/Db/Dialect/MysqlExtended.php
@@ -128,6 +128,22 @@ public function getSqlExpression(array $expression, $escapeChar = null, $bindCou
                     return $this->getSqlExpression($expression['arguments'][0]) .
                     ' REGEXP (' . $this->getSqlExpression($expression['arguments'][1]) . ')';
                     break;
+
+                case 'JSON_EXTRACT':
+                    if (count($expression["arguments"]) < 2) {
+                        throw new Exception('JSON_EXTRACT requires 2 parameters');
+                    }
+
+                    $arguments = [];
+                    $length = count($expression["arguments"]);
+                    for ($i = 0; $i < $length; $i++) {
+                        $arguments[] = $i === 0 ?
+                            $this->getSqlExpression($expression["arguments"][$i]) :
+                            $expression["arguments"][$i]['value'];
+                    }
+
+                    return 'JSON_EXTRACT(' . join(', ', $arguments) . ')';
+                    break;
             }
         }