class.ilGlobalCacheDBLayer.php

Go to the documentation of this file.

<?php
require_once('./Services/GlobalCache/classes/class.ilGlobalCache.php');

class ilGlobalCacheDBLayer {

        protected $component = '';
        protected $loaded = false;
        protected $table_name = '';
        protected static $instances = array();
        protected $raw_data = array();
        protected $cached_results = array();
        protected $ttl = NULL;
        protected $global_cache;
        protected $wheres = array();


        protected function __construct($component, $table_name, $ttl = NULL) {
                $this->setTtl($ttl);
                $this->setComponent($component);
                $this->setTableName($table_name);
                $this->global_cache = ilGlobalCache::getInstance($component);
                $this->readFromCache();
                if (! $this->getLoaded()) {
                        $this->readFromDB();
                        $this->writeToCache();
                        $this->setLoaded(true);
                }
        }


        protected function readFromCache() {
                if ($this->global_cache->isActive()) {
                        $data = $this->global_cache->get($this->getTableName() . '_raw_data');
                        $cached_results = $this->global_cache->get($this->getTableName() . '_cached_results');
                        if (is_array($data)) {
                                $this->setRawData($data);
                                $this->setCachedResults($cached_results);
                                $this->setLoaded(true);
                        }
                }
        }


        protected function writeToCache() {
                if ($this->global_cache->isActive()) {
                        $this->global_cache->set($this->getTableName() . '_raw_data', $this->getRawData(), $this->getTtl());
                        $this->updateCachedResults();
                }
        }


        protected function readFromDB() {
                global $ilDB;
                $q = 'SELECT * FROM ' . $this->getTableName();
                $res = $ilDB->query($q);
                $raw_data = array();
                while ($set = $ilDB->fetchObject($res)) {
                        $raw_data[] = $set;
                }
                $this->setRawData($raw_data);
        }


        public function getWhere($field, $value, $case_sensitive = true) {
                return $this->filter($this->getRawData(), $field, $value, $case_sensitive);
        }


        public function filter(array $data, $field, $value, $case_sensitive = true, $strip = true) {
                if (is_array($value)) {
                        $index = md5(serialize($value)) . $case_sensitive;
                } else {
                        $index = $value . $case_sensitive;
                }
                if (isset($this->cached_results[$this->getTableName()][$field][$index])) {
                        return $this->cached_results[$this->getTableName()][$field][$index];
                }
                $result = array();
                foreach ($data as $dat) {
                        if ($case_sensitive) {
                                if (is_array($value)) {
                                        if (in_array($dat->{$field}, $value)) {
                                                $result[] = $dat;
                                        }
                                } elseif ($dat->{$field} == $value) {

                                        $result[] = $dat;
                                }
                        } else {
                                if (is_array($value)) {
                                        if (preg_grep("/" . $dat->{$field} . "/i", $value)) {
                                                $result[] = $dat;
                                        }
                                } elseif (strcasecmp($dat->{$field}, $value) == 0) {
                                        $result[] = $dat;
                                }
                        }
                }
                if (count($result) == 1 AND $strip) {
                        $result = $result[0];
                }

                $this->cached_results[$this->getTableName()][$field][$index] = $result;
                $this->updateCachedResults();

                return $result;
        }


        protected function updateCachedResults() {
                $this->global_cache->set($this->getTableName() . '_cached_results', $this->getCachedResults());
        }


        public function where($field, $value, $case_sensitive = true) {
                $ilGcDbWhere = new ilGcDbWhere();
                $ilGcDbWhere->setField($field);
                $ilGcDbWhere->setValue($value);
                $ilGcDbWhere->setCaseSensitive($case_sensitive);
                $this->wheres[] = $ilGcDbWhere;

                return $this;
        }


        public function get($strip = true) {
                $result = $this->getRawData();
                foreach ($this->wheres as $ilGcDbWhere) {
                        $result = $this->filter($result, $ilGcDbWhere->getField(), $ilGcDbWhere->getValue(), $ilGcDbWhere->getCaseSensitive(), false);
                }

                if (count($result) == 1 AND $strip) {
                        //                      echo '<pre>' . print_r($result, 1) . '</pre>';
                        $result = $result[0];
                }

                return $result;
        }


        public static function getInstance($component, $table_name) {
                if (! isset(self::$instances[$component . $table_name])) {
                        self::$instances[$component . $table_name] = new self($component, $table_name);
                }

                return self::$instances[$component . $table_name];
        }


        public function setCachedResults($cached_results) {
                $this->cached_results = $cached_results;
        }


        public function getCachedResults() {
                return $this->cached_results;
        }


        public function setRawData($raw_data) {
                $this->raw_data = $raw_data;
        }


        public function getRawData() {
                return $this->raw_data;
        }


        public function setTableName($table_name) {
                $this->table_name = $table_name;
        }


        public function getTableName() {
                return $this->table_name;
        }


        public function setLoaded($loaded) {
                $this->loaded = $loaded;
        }


        public function getLoaded() {
                return $this->loaded;
        }


        public function setComponent($component) {
                $this->component = $component;
        }


        public function getComponent() {
                return $this->component;
        }


        public function setTtl($ttl) {
                $this->ttl = $ttl;
        }


        public function getTtl() {
                return $this->ttl;
        }
}

class ilGcDbWhere {

        protected $field = '';
        protected $value;
        protected $case_sensitive = true;


        public function setCaseSensitive($case_sensitive) {
                $this->case_sensitive = $case_sensitive;
        }


        public function getCaseSensitive() {
                return $this->case_sensitive;
        }


        public function setField($field) {
                $this->field = $field;
        }


        public function getField() {
                return $this->field;
        }


        public function setValue($value) {
                $this->value = $value;
        }


        public function getValue() {
                return $this->value;
        }
}


?>