src/Fufle/Database/ConnectionManager.php

@@ -3,6 +3,7 @@
 namespace Fufle\Database;
 
 use PDO;
+use Fufle\Database\QueryData;
 
 class ConnectionManager {
     private static $connection;
@@ -12,15 +13,19 @@ class ConnectionManager {
     }
 
     public static function Query(string $query, array|object $params = [], string $output = 'stdObject') {
-        $stmt = self::$connection->prepare($query);
+        $data = new QueryData($query, $params);
-        $stmt->execute($params);
+        $data->normalize();
+        $stmt = self::$connection->prepare($data->query);
+        $stmt->execute($data->params);
         $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
         return $stmt->fetch();
     }
 
     public static function QueryAll(string $query, array|object $params = [], string $output = 'stdObject') {
-        $stmt = self::$connection->prepare($query);
+        $data = new QueryData($query, $params);
-        $stmt->execute($params);
+        $data->normalize();
+        $stmt = self::$connection->prepare($data->query);
+        $stmt->execute($data->params);
         $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
         return $stmt->fetchAll();
     }

src/Fufle/Database/QueryData.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Fufle\Database;
+
+class QueryData {
+    public function __construct(
+        public string $query,
+        public array|object $params
+        ) {
+
+    }
+
+    public function normalize() {
+        $params = (array)$this->params;
+        $replaces = [];
+        foreach($params as $name => $param) {
+            if (is_array($param)) {
+                $replaces2 = [];
+                foreach($param as $i => $p) {
+                    $params[$name.$i.'x'] = $p;
+                    $replaces[] = ':'.$name.$i.'x';
+                }
+                unset($params[$name]);
+                $this->query = str_replace(':'.$name, implode(', ', $replaces), $this->query);
+            }
+        }
+        $this->params = $params;
+    }
+}

src/Fufle/ORM/Model.php

@@ -9,6 +9,19 @@ abstract class Model {
     protected static ?string $table = null;
     private static ?IQuery $query = null;
 
+    protected static array $fields = [];
+
+    public function toArray(): array {
+        $array = [];
+        $fields = static::$fields;
+        foreach($fields as $field) {
+            if ($this->{$field} ?? null !== null) {
+                $array[$field] = $this->{$field};
+            }
+        }
+        return $array;
+    }
+
     protected static function QueryModel() {
         if (self::$query === null && self::class !== static::class) {
             self::$query = static::QueryModel();