XoopsPersistableObjectHandler.php

Go to the documentation of this file.

<?php
namespace Xoops\Core\Kernel;

use Xoops\Core\Database\Connection;
use Xoops\Core\Kernel\CriteriaElement;
use Xoops\Core\Kernel\XoopsModelFactory;
use Xoops\Core\Kernel\XoopsObjectHandler;

abstract class XoopsPersistableObjectHandler extends XoopsObjectHandler
{
    protected $handler;

    private $handlers = array('read' => null, 'stats' => null, 'joint' => null, 'write' => null, 'sync' => null);

    public $table;

    public $keyName;

    public $className;

    public $table_link;

    public $identifierName;

    public $field_link;

    public $field_object;

    public $keyName_link;

    protected function __construct(
        Connection $db = null,
        $table = '',
        $className = '',
        $keyName = '',
        $identifierName = ''
    ) {
        parent::__construct($db);
        $this->table = $this->db2->prefix($table);
        $this->keyName = $keyName;
        $this->className = $className;
        if ($identifierName) {
            $this->identifierName = $identifierName;
        }
    }

    public function setHandler($handler = null, $args = null, $path = null)
    {
        $this->handler = null;
        if (is_object($handler)) {
            $this->handler = $handler;
        } else {
            if (is_string($handler)) {
                $xmf = XoopsModelFactory::getInstance();
                $this->handler = $xmf->loadHandler($this, $handler, $args, $path);
            }
        }
        return $this->handler;
    }

    public function loadHandler($name, $args = null)
    {
        static $handlers;
        if (!isset($handlers[$name])) {
            $xmf = XoopsModelFactory::getInstance();
            $handlers[$name] = $xmf->loadHandler($this, $name, $args);
        }
        /* @var $handler XoopsModelAbstract */
        $handler = $handlers[$name];
        $handler->setHandler($this);
        $handler->setVars($args);

        return $handler;

    }

    public function __call($name, $args)
    {
        if (is_object($this->handler) && is_callable(array($this->handler, $name))) {
            return call_user_func_array(array($this->handler, $name), $args);
        }
        foreach (array_keys($this->handlers) as $_handler) {
            $handler = $this->loadHandler($_handler);
            if (is_callable(array($handler, $name))) {
                return call_user_func_array(array($handler, $name), $args);
            }
        }

        return null;
    }

    public function create($isNew = true)
    {
                if (empty($this->className)) return false;

        /* @var $obj XoopsObject */
        $obj = new $this->className();
        if ($isNew === true) {
            $obj->setNew();
        }
        return $obj;
    }

    public function get($id = null, $fields = null)
    {
        $object = null;
        if (empty($id)) {
            $object = $this->create();
            return $object;
        }
        $qb = $this->db2->createXoopsQueryBuilder();
        $eb = $qb->expr();
        if (is_array($fields) && count($fields) > 0) {
            if (!in_array($this->keyName, $fields)) {
                $fields[] = $this->keyName;
            }
            $first=true;
            foreach ($fields as $field) {
                if ($first) {
                    $first=false;
                    $qb->select($field);
                } else {
                    $qb->addSelect($field);
                }
            }
        } else {
            $qb->select('*');
        }
        $qb->from($this->table, null)
            ->where($eb->eq($this->keyName, ':id'))
            ->setParameter(':id', $id, \PDO::PARAM_INT);
        if (!$result = $qb->execute()) {
            return $object;
        }
        $row = $result->fetch(\PDO::FETCH_ASSOC);
        if (!$row) {
            return $object;
        }
        $object = $this->create(false);
        $object->assignVars($row);

        return $object;
    }

    public function insert(XoopsObject $object, $force = true)
    {
        /* @var $handler XoopsModelWrite */
        $handler = $this->loadHandler('write');
        return $handler->insert($object, $force);
    }

    public function delete(XoopsObject $object, $force = false)
    {
        /* @var $handler XoopsModelWrite */
        $handler = $this->loadHandler('write');
        return $handler->delete($object, $force);
    }

    public function deleteAll(CriteriaElement $criteria, $force = true, $asObject = false)
    {
                if (empty($criteria)) return false;

        /* @var $handler XoopsModelWrite */
        $handler = $this->loadHandler('write');
        return $handler->deleteAll($criteria, $force, $asObject);
    }

    public function updateAll($fieldname, $fieldvalue, CriteriaElement $criteria, $force = false)
    {
                if (empty($criteria)) return false;

        /* @var $handler XoopsModelWrite */
        $handler = $this->loadHandler('write');
        return $handler->updateAll($fieldname, $fieldvalue, $criteria, $force);
    }

    public function getObjects(CriteriaElement $criteria = null, $id_as_key = false, $as_object = true)
    {
        /* @var $handler XoopsModelRead */
        $handler = $this->loadHandler('read');
        $ret = $handler->getObjects($criteria, $id_as_key, $as_object);
        return $ret;
    }

    public function getAll(CriteriaElement $criteria = null, $fields = null, $asObject = true, $id_as_key = true)
    {
        /* @var $handler XoopsModelRead */
        $handler = $this->loadHandler('read');
        $ret = $handler->getAll($criteria, $fields, $asObject, $id_as_key);
        return $ret;
    }

    public function getList(CriteriaElement $criteria = null, $limit = 0, $start = 0)
    {
        /* @var $handler XoopsModelRead */
        $handler = $this->loadHandler('read');
        $ret = $handler->getList($criteria, $limit, $start);
        return $ret;
    }

    public function getIds(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelRead */
        $handler = $this->loadHandler('read');
        $ret = $handler->getIds($criteria);
        return $ret;
    }

    public function getCount(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelStats */
        $handler = $this->loadHandler('stats');
        return $handler->getCount($criteria);
    }

    public function getCounts(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelStats*/
        $handler = $this->loadHandler('stats');
        return $handler->getCounts($criteria);
    }

    public function getByLink(
        CriteriaElement $criteria = null,
        $fields = null,
        $asObject = true,
        $field_link = null,
        $field_object = null
    ) {
        /* @var $handler XoopsModelJoint */
        $handler = $this->loadHandler('joint');
        $ret = $handler->getByLink($criteria, $fields, $asObject, $field_link, $field_object);
        return $ret;
    }

    public function getCountByLink(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelJoint */
        $handler = $this->loadHandler('joint');
        $ret = $handler->getCountByLink($criteria);
        return $ret;
    }

    public function getCountsByLink(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelJoint */
        $handler = $this->loadHandler('joint');
        $ret = $handler->getCountsByLink($criteria);
        return $ret;
    }

    public function updateByLink($data, CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelJoint */
        $handler = $this->loadHandler('joint');
        $ret = $handler->updateByLink($data, $criteria);
        return $ret;
    }

    public function deleteByLink(CriteriaElement $criteria = null)
    {
        /* @var $handler XoopsModelJoint */
        $handler = $this->loadHandler('joint');
        $ret = $handler->deleteByLink($criteria);
        return $ret;
    }

    public function cleanOrphan($table_link = '', $field_link = '', $field_object = '')
    {
        /* @var $handler XoopsModelSync */
        $handler = $this->loadHandler('sync');
        $ret = $handler->cleanOrphan($table_link, $field_link, $field_object);
        return $ret;
    }

    public function synchronization($table_link = '', $field_link = '', $field_object = '')
    {
        $retval = $this->cleanOrphan($table_link, $field_link, $field_object);
        return $retval;
    }
}