Pleets / dronephp

src/Db/TableGateway/EntityAdapter.php

<?php
/**
 * DronePHP (http://www.dronephp.com)
 *
 * @link      http://github.com/Pleets/DronePHP
 * @copyright Copyright (c) 2016-2018 Pleets. (http://www.pleets.org)
 * @license   http://www.dronephp.com/license
 * @author    Darío Rivera <fermius.us@gmail.com>
 */

namespace Drone\Db\TableGateway;

use Drone\Db\Entity;
use Drone\Db\SQLFunction;

/**
 * EntityAdapter class
 *
 * This class allows to persist objects to database (Data Mapper pattern)
 */
class EntityAdapter
{
    /**
     * The gateway linked
     *
     * @var TableGateway $tableGateway
     */
    private $tableGateway;

    /**
     * Constructor
     *
     * @param TableGateway $tableGateway
     */
    public function __construct(TableGateway $tableGateway)
    {
        $this->tableGateway = $tableGateway;
    }

    /**
     * Returns the tableGateway
     *
     * @return TableGateway
     */
    public function getTableGateway()
    {
        return $this->tableGateway;
    }

    /**
     * Returns a rowset with entity instances
     *
     * @param array $where
     *
     * @return Entity[]
     */
    public function select(array $where)
    {
        $result = $this->tableGateway->select($where);

        if (!count($result)) {
            return $result;
        }

        $array_result = [];

        foreach ($result as $row) {
            $filtered_array = [];

            foreach ($row as $key => $value) {
                if (is_string($key)) {
                    $filtered_array[$key] = $value;
                }
            }

            $user_entity = get_class($this->tableGateway->getEntity());

            $entity = new $user_entity($filtered_array);

            $array_result[] = $entity;
        }

        return $array_result;
    }

    /**
     * Creates a row from an entity or array
     *
     * @param Entity|array $entity
     *
     * @throws InvalidArgumentException
     *
     * @return resource|object
     */
    public function insert($entity)
    {
        if ($entity instanceof Entity) {
            $entity = get_object_vars($entity);
        } elseif (!is_array($entity)) {

The condition is_array($entity) is always true.

            throw new \InvalidArgumentException("Invalid type given. Drone\Db\Entity or Array expected");
        }

        $this->parseEntity($entity);

        return $this->tableGateway->insert($entity);
    }

    /**
     * Updates an entity
     *
     * @param Entity|array $entity
     * @param array $where
     *
     * @throws RuntimeException from internal execute()
     * @throws InvalidArgumentException
     *
     * @return object|resource
     */
    public function update($entity, $where)
    {
        if ($entity instanceof Entity) {
            $changedFields = $entity->getChangedFields();
            $entity = get_object_vars($entity);

            $fieldsToModify = [];

            foreach ($entity as $key => $value) {
                if (in_array($key, $changedFields)) {
                    $fieldsToModify[$key] = $value;
                }
            }

            $entity = $fieldsToModify;
        } elseif (!is_array($entity)) {

The condition is_array($entity) is always true.

            throw new \InvalidArgumentException("Invalid type given. Drone\Db\Entity or Array expected");
        }

        $this->parseEntity($entity);

        return $this->tableGateway->update($entity, $where);
    }

    /**
     * Deletes an entity
     *
     * @param Entity|array $entity
     *
     * @throws RuntimeException from internal execute()
     * @throws InvalidArgumentException
     *
     * @return object|resource
     */
    public function delete($entity)
    {
        if ($entity instanceof Entity) {
            $entity = get_object_vars($entity);
        } elseif (!is_array($entity)) {

The condition is_array($entity) is always true.

            throw new \InvalidArgumentException("Invalid type given. Drone\Db\Entity or Array expected");
        }

        return $this->tableGateway->delete($entity);
    }

    /**
     * Converts several objects to SQLFunction objects
     *
     * @param array $entity
     *
     * @return array
     */
    private function parseEntity(array &$entity)
    {
        $drv = $this->getTableGateway()->getDb()->getDriverName();

        foreach ($entity as $field => $value) {
            if ($value instanceof \DateTime) {
                switch ($drv) {
                    case 'Oci8':
                        $entity[$field] = new SQLFunction('TO_DATE', [$value->format('Y-m-d'), 'YYYY-MM-DD']);
                        break;
                    case 'Mysqli':
                        $entity[$field] = new SQLFunction('STR_TO_DATE', [$value->format('Y-m-d'), '%Y-%m-%d']);
                        break;
                    case 'Sqlsrv':
                        $entity[$field] = new SQLFunction('CONVERT', ['DATETIME', $value->format('Y-m-d')]);
                        break;
                }
            }
        }

        return $entity;
    }
}