Database : JsonType

thor/Database/PdoExtension/PdoRequester.php

@@ -104,7 +104,7 @@ final public function getPdoHandler(): PdoHandler
         return $this->handler;
     }
 
-    static function in(array $elements) : string
+    public static function in(array $elements) : string
     {
         return '(' . implode(',', array_fill(0, count($elements), '?')) . ')';
     }

thor/Database/PdoTable/TableType/JsonType.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace Thor\Database\PdoTable\TableType;
+
+/**
+ *
+ */
+
+/**
+ *
+ */
+class JsonType extends BaseType
+{
+
+    /**
+     * @param int $sqlStringSize
+     * @param string $sqlStringType
+     * @param bool $associative
+     */
+    public function __construct(
+        int                   $sqlStringSize = 16384,
+        string                $sqlStringType = 'VARCHAR',
+        private readonly bool $associative = true,
+    ) {
+        parent::__construct("$sqlStringType($sqlStringSize)", 'int');
+    }
+
+    /**
+     * @param mixed $sqlValue
+     *
+     * @return mixed
+     */
+    public function toPhpValue(mixed $sqlValue): array
+    {
+        return json_decode($sqlValue, $this->associative);
+    }
+
+    /**
+     * @param mixed $phpValue
+     *
+     * @return string
+     */
+    public function toSqlValue(mixed $phpValue): string
+    {
+        return json_encode($phpValue);
+    }
+}