class.arConnectorCache.php

Go to the documentation of this file.

<?php

class arConnectorCache extends arConnector
{

    private $ttl;
    private $arConnectorDB;
    private $cache;
    const CACHE_TTL_SECONDS = 180;


    public function __construct(arConnector $arConnectorDB, int $ttl = self::CACHE_TTL_SECONDS)
    {
        $this->ttl = $ttl;
        $this->arConnectorDB = $arConnectorDB;
        $this->cache = ilGlobalCache::getInstance(ilGlobalCache::COMP_GLOBAL_SCREEN);
    }


    public function nextID(ActiveRecord $ar)
    {
        return $this->arConnectorDB->nextID($ar);
    }


    public function checkConnection(ActiveRecord $ar)
    {
        return $this->arConnectorDB->checkConnection($ar);
    }


    public function installDatabase(ActiveRecord $ar, $fields)
    {
        return $this->arConnectorDB->installDatabase($ar, $fields);
    }


    public function updateDatabase(ActiveRecord $ar)
    {
        return $this->arConnectorDB->updateDatabase($ar);
    }


    public function resetDatabase(ActiveRecord $ar)
    {
        return $this->arConnectorDB->resetDatabase($ar);
    }


    public function truncateDatabase(ActiveRecord $ar)
    {
        $this->arConnectorDB->truncateDatabase($ar);
    }


    public function checkTableExists(ActiveRecord $ar)
    {
        return $this->arConnectorDB->checkTableExists($ar);
    }


    public function checkFieldExists(ActiveRecord $ar, $field_name)
    {
        return $this->arConnectorDB->checkFieldExists($ar, $field_name);
    }


    public function removeField(ActiveRecord $ar, $field_name)
    {
        return $this->arConnectorDB->removeField($ar, $field_name);
    }


    public function renameField(ActiveRecord $ar, $old_name, $new_name)
    {
        return $this->arConnectorDB->renameField($ar, $old_name, $new_name);
    }


    public function create(ActiveRecord $ar)
    {
        $this->arConnectorDB->create($ar);
        $this->storeActiveRecordInCache($ar);
    }


    public function read(ActiveRecord $ar)
    {
        if ($this->cache->isActive()) {
            $key = $ar->getConnectorContainerName() . "_" . $ar->getPrimaryFieldValue();
            $cached_value = $this->cache->get($key);
            if (is_array($cached_value)) {
                return $cached_value;
            }

            if ($cached_value instanceof stdClass) {
                return [$cached_value];
            }
        }

        $results = $this->arConnectorDB->read($ar);

        if ($this->cache->isActive()) {
            $key = $ar->getConnectorContainerName() . "_" . $ar->getPrimaryFieldValue();

            $this->cache->set($key, $results, self::CACHE_TTL_SECONDS);
        }

        return $results;
    }


    public function update(ActiveRecord $ar)
    {
        $this->arConnectorDB->update($ar);
        $this->storeActiveRecordInCache($ar);
    }


    public function delete(ActiveRecord $ar)
    {
        $this->arConnectorDB->delete($ar);

        if ($this->cache->isActive()) {
            $key = $ar->getConnectorContainerName() . "_" . $ar->getPrimaryFieldValue();
            $this->cache->delete($key);
        }
    }


    public function readSet(ActiveRecordList $arl)
    {
        return $this->arConnectorDB->readSet($arl);
    }


    public function affectedRows(ActiveRecordList $arl)
    {
        return $this->arConnectorDB->affectedRows($arl);
    }


    public function quote($value, $type)
    {
        return $this->arConnectorDB->quote($value, $type);
    }


    public function updateIndices(ActiveRecord $ar)
    {
        $this->arConnectorDB->updateIndices($ar);
    }


    private function storeActiveRecordInCache(ActiveRecord $ar)
    {
        if ($this->cache->isActive()) {
            $key = $ar->getConnectorContainerName() . "_" . $ar->getPrimaryFieldValue();
            $value = $ar->__asStdClass();

            $this->cache->set($key, $value, self::CACHE_TTL_SECONDS);
        }
    }
}