Add support for GROUP_CONCAT (#44)

vimeo · May 8, 2024 · c438184 · c438184
1 parent f845214
commit c438184
Showing 1 changed file with 23 additions and 0 deletions.
diff --git a/src/Processor/Expression/FunctionEvaluator.php b/src/Processor/Expression/FunctionEvaluator.php
@@ -66,6 +66,8 @@ public static function evaluate(
                 return self::sqlConcatWS($conn, $scope, $expr, $row, $result);
             case 'CONCAT':
                 return self::sqlConcat($conn, $scope, $expr, $row, $result);
+            case 'GROUP_CONCAT':
+                return self::sqlGroupConcat($conn, $scope, $expr, $row, $result);
             case 'FIELD':
                 return self::sqlColumn($conn, $scope, $expr, $row, $result);
             case 'BINARY':
@@ -932,6 +934,27 @@ private static function sqlConcat(
         return $final_concat;
     }
 
+    /**
+     * @param array<string, mixed> $row
+     */
+    private static function sqlGroupConcat(
+        FakePdoInterface $conn,
+        Scope $scope,
+        FunctionExpression $expr,
+        array $row,
+        QueryResult $result
+    ): string {
+        $args = $expr->args;
+
+        $final_concat = "";
+        foreach ($args as $arg) {
+            $val = (string) Evaluator::evaluate($conn, $scope, $arg, $row, $result);
+            $final_concat .= $val;
+        }
+
+        return $final_concat;
+    }
+
     /**
      * @param array<string, mixed> $row
      *