lifeeka / jsql

src/Extractor/JsonExtractor.php

<?php

namespace Lifeeka\JSQL\Extractor;

use Lifeeka\JSQL\Helpers\Json;

/**
 * Class JsonExtractor.
 */
class JsonExtractor
{
    public $json;

    private $table = [];
    private $data = [];
    private $foreign = [];

    public $need_id = true;
    public $snake_case_column = true;
    public $snake_case_table = true;
    public $main_table_name = "main";

    /**
     * JsonExtractor constructor.
     * @param Json $json
     * @param $mainTableName
     */
    public function __construct(Json $json, $mainTableName)
    {
        $this->json = $json;
        $this->main_table_name = $mainTableName;
    }

    /**
     * @return array
     */
    public function getTablesArray()
    {
        return $this->table;
    }

    /**
     * @return array
     */
    public function getForeignKeyArray()
    {
        return $this->foreign;
    }

    /**
     * @return array
     */
    public function getDataArray()
    {
        return $this->data;
    }


    /**
     * @param bool $data
     * @param string $prefix
     */
    public function toMysqlTables($data = false, $prefix = '')
    {
        if (!$data) {//if this is not a recursive
            $data = $this->json->toObject();
        }

        foreach ($data as $key => $value) {//loop the data

            $table_name = is_numeric($key) ? $this->main_table_name : $key;


            if (is_array($value) && is_object($value[0])) {//check whether it's a array and it's firs element is a object

                $table_data = $this->getTable($prefix . $table_name, $value); //get table sql
                $this->table[$table_data['name']] = $table_data['column'];

                $this->toMysqlTables($this->getHighestColumnArray($value), $prefix . $table_name . "_"); //get it inside tables
            } elseif (is_array($value) || is_object($value)) {//if it's a array and  firs element is not a object

                $table_data = $this->getTable($prefix . $table_name, $value);
                $this->table[$table_data['name']] = $table_data['column'];
            }
        }
    }


    /**
     * @param bool $data
     * @param string $prefix
     */
    public function toMysqlData($data = false, $prefix = '')
    {
        if (!$data) {//if this is not a recursive
            $data = $this->json->toObject();
        }
        foreach ($data as $table_name => $value) {
            if ($this->snake_case_table) {
                $table_name = $this->snakeCase($prefix . $table_name);
            }
            if (is_array($value) && !empty($value) && is_object($value[0])) {//if it's a array and  firs element is not a object
                $this->toMysqlData($value, $table_name . '_');

$value of type array is incompatible with the type boolean expected by parameter $data of Lifeeka\JSQL\Extractor\JsonExtractor::toMysqlData().

            } elseif (is_object($value) || is_array($value)) {
                $this->toMysqlData($value, $table_name . '_');

$value of type array|object is incompatible with the type boolean expected by parameter $data of Lifeeka\JSQL\Extractor\JsonExtractor::toMysqlData().

                $this->getTableData($table_name, $value);
            }
        }
    }


    /**
     * @param $table_name
     * @param $value
     */
    public function getTableData($table_name, $value)
    {
        if (isset($this->table[$table_name])) {
            $ColumnList = $this->table[$table_name];

            $DataItem = [];

            if (is_object($value)) {
                foreach ($ColumnList as $ColumnItem) {
                    if ($this->isPropertyExist($value, $ColumnItem['name'])) {
                        $CurrentItem = $this->snake_case_column ? $this->objectToSnakeCase($value) : $value;
                        $column_name = $ColumnItem['name'];
                        $DataItem[$column_name] = $CurrentItem->{$ColumnItem['name']};
                    } else {
                        $column_name = $ColumnItem['name'];
                        $DataItem[$column_name] = null;
                    }
                }
                $this->data[$table_name][] = $DataItem;
            } elseif (is_array($value)) {//reference table
                foreach ($value as $item_value) {
                    $DataItem[] = ['value' => $item_value];
                }

                $this->data[$table_name] = array_merge(($this->data[$table_name] ?? []), $DataItem);
            }
        }
    }

    /**
     * @param $table
     * @param $data
     * @return array
     */
    public function getTable($table, $data)
    {
        $column = $this->getColumn($this->getHighestColumnArray($data), $table);

        if ($this->snake_case_table) {
            $table = $this->snakeCase($table);
        }

        if ($this->snake_case_column) {
            return [
                'name' => $table,
                'column' => array_map(function ($item) {
                    return [
                        'name' => $this->snakeCase($item['name']),
                        'type' => $item['type'],
                        'ref' => $item['ref'] ?? null
                    ];
                }, $column)
            ];
        } else {
            return [
                'name' => $table,
                'column' => $column
            ];
        }
    }


    /**
     * @param $data
     * @param $table
     * @return array
     */
    public function getColumn($data, $table)
    {
        $ForeignKeys = $this->json->getForeignKeys();

        $Columns = [];

        if (is_object($data)) {
            foreach ($data ?? [] as $Column => $Value) {
                if (!is_array($Value) && !is_object($Value) && !empty($Column) && !is_numeric($Column)) {
                    if (isset($ForeignKeys[JsonExtractor::snakeCase($table)]) && $ForeignKeys[JsonExtractor::snakeCase($table)]['name'] == JsonExtractor::snakeCase($Column)) {
                        $Columns[] = ['name' => $Column, 'type' => 'foreign_key', 'ref' => $ForeignKeys[JsonExtractor::snakeCase($table)]['ref']];
                    } elseif ($Column == 'id') {
                        $Columns[] = ['name' => $Column, 'type' => 'primary_key'];
                    } else {
                        $Columns[] = ['name' => $Column, 'type' => gettype($this->getActualDataType($Value, ""))];
                    }
                }
            }
        } elseif (is_array($data)) {
            $Columns[] = ['name' => 'value', 'type' => gettype($this->getActualDataType($data[0], ""))];
        }
        return $Columns;
    }

    /**
     * @param $data
     * @param $column
     * @return array
     */
    public function getData($data, $column)
    {
        $values = [];

        $index = 0;
        foreach ($data as $row_item) {
            foreach ($column as $column_item) {
                switch (is_object($row_item)) {
                    case true:
                        $values[$index][$column_item['name']] = $this->getActualDataType(($row_item->{$column_item['name']}) ?? null, null);
                        break;
                    case false:
                        $values[$index][$column_item['name']] = $this->getActualDataType(($data->{$column_item['name']}) ?? null, null);
                        break;
                }
            }
            $index++;
        }


        return $values;
    }

    /**
     * @param $input
     *
     * @return string
     */
    public static function snakeCase($input)
    {
        preg_match_all('!([A-Z][A-Z0-9]*(?=$|[A-Z][a-z0-9])|[A-Za-z][a-z0-9]+)!', $input, $matches);
        $ret = $matches[0];

        foreach ($ret as &$match) {
            $match = $match == strtoupper($match) ? strtolower($match) : lcfirst($match);
        }

        return implode('_', $ret);
    }

    /**
     * @param $Object
     * @return \stdClass
     */
    public static function objectToSnakeCase($Object)
    {
        $ReturnObject = new \stdClass();

        foreach ($Object as $ObjectAttribute => $ObjectItem) {
            $ReturnObject->{JsonExtractor::snakeCase($ObjectAttribute)} = $ObjectItem;
        }
        return $ReturnObject;
    }


    /**
     * @param Object $Object
     * @param $Attribute
     * @return bool
     */
    public function isPropertyExist($Object, $Attribute)
    {
        foreach (array_keys(get_object_vars($Object)) as $CurrentAttributeName) {
            if ($this->snake_case_column && $this->snakeCase($CurrentAttributeName) == $Attribute) {
                return true;
            } elseif ($CurrentAttributeName === $Attribute) {
                return true;
            }
        }

        return false;
    }


    /**
     * @param $array
     * @return bool|mixed
     */
    public static function getHighestColumnArray($array)
    {
        if (is_object($array) || (is_array($array) && !is_object($array[0]) && !is_array($array[0]))) {
            return $array;
        }

        $Highest = false;
        $ColumnCount = false;
        $HighestSubCount = false;

        foreach ($array as $array_item) {
            $current_sub = 0;
            //check how many array/object have
            foreach ($array_item as $SubArrayItem) {
                if (is_array($SubArrayItem) || is_object($SubArrayItem)) {
                    $current_sub = $current_sub + 2;
                }
            }
            //check how many column have
            if ($ColumnCount <= @count($array_item) || !$Highest) {
                if ($current_sub > $HighestSubCount || !$Highest) {
                    $Highest = $array_item;
                    $HighestSubCount = $current_sub;
                    $ColumnCount = @count($array_item);
                }
            }
        }


        return $Highest;
    }

    /**
     * @param $array
     * @return string
     */
    public static function getStringFromData($array)
    {
        $String = [];

        foreach ($array as $item_row) {
            $value = [];
            foreach ($item_row as $item) {
                if (empty($item) && !is_numeric($item)) {
                    $value[] = "null";
                } elseif (is_numeric($item)) {
                    $value[] = $item;
                } else {
                    $value[] = '"' . addcslashes($item, "W") . '"';
                }
            }
            $String[] = '(' . implode(",", $value) . ')';
        }

        return "values" . implode(", ", $String);
    }

    /**
     * @param $array
     * @return string
     */
    public static function getStringFromColumns($array)
    {
        $String = [];
        foreach ($array as $column) {
            $String[] = "`" . JsonExtractor::snakeCase($column['name']) . "`";
        }

        return implode(",", $String);
    }


    /**
     * @param $Data
     * @param $empty_val
     * @return int|string
     */
    public static function getActualDataType($Data, $empty_val)
    {
        $Data = trim($Data);
        if (is_numeric($Data)) {
            return $Data + 0;
        } elseif (empty($Data)) {
            return $empty_val;
        } else {
            return (string)$Data;
        }
    }
}