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);
        }
    }
}