jgauthi / component_database Goto Github PK

<?php
// @todo: Créer une class PdoEntityFactory

class PdoEntityFactory
{
    /**
     * @return bool
     */
    public function insert()
    {
        $error = [];

        if (empty($this->id_site)) {
            $error[] = 'id_site require';
        } elseif (empty($this->id_liste)) {
            $error[] = 'id_liste require';
        } elseif ($this->active === null) {
            $this->active = 0;
        }
        if (!empty($error)) {
            throw new InvalidArgumentException(implode(', ', $error));
        }

        $arguments = [
            'id_site' => intval($this->id_site),
            'id_liste' => intval($this->id_liste),
            'active' => intval($this->active)
        ];

        $pdo = newPDO();
        $request = $pdo->prepare("INSERT INTO `{$this->__table}`
            SET id_site = :id_site,
                id_liste = :id_liste,
                active = :active
        ")->execute($arguments);

        return boolval($request);
    }

    /**
     * @return bool
     */
    public function update()
    {
        if (empty($this->id_site)) {
            throw new InvalidArgumentException('id_site require for delete this entry');
        } elseif ($this->id_liste === null && $this->active === null) {
            throw new InvalidArgumentException('id_liste or active required for update this entry');
        }

        $arguments = ['id_site' => intval($this->id_site)];
        $fields = [];

        if ($this->id_liste !== null) {
            $arguments['id_liste'] = intval($this->id_liste);
            $fields[] = 'id_liste = :id_liste';
        }
        if ($this->active !== null) {
            $arguments['active'] = intval($this->active);
            $fields[] = 'active = :active';
        }

        if (empty($fields)) {
            throw new InvalidArgumentException(__CLASS__.': No data to update');
        }

        $fields = implode(', ', $fields);

        $pdo = newPDO();
        $request = $pdo
            ->prepare("UPDATE `{$this->__table}` SET {$fields} WHERE id_site = :id_site LIMIT 1")
            ->execute($arguments)
        ;

        return boolval($request);
    }

    /**
     * @return bool
     */
    public function delete()
    {
        if (empty($this->id_site)) {
            throw new InvalidArgumentException('id_site require for delete this entry');
        }

        $pdo = newPDO();
        $request = $pdo
            ->prepare("DELETE FROM `{$this->__table}` WHERE id_site = :id_site LIMIT 1")
            ->execute(['id_site' => intval($this->id_site)])
        ;

        return boolval($request);
    }
}