Skip to the content.

Gyro-PHP > Documentation

• Home
• Downloads
• Tutorials
• Showcases
• Documentation
• Report Bug

gyro/core/model/classes/cache.db.impl.php

Go to the documentation of this file.

<?php
/**
 * An implememtation of cache as DB table
 *  
 * @author Gerd Riesselmann
 * @ingroup Model
 */
class CacheDBImpl implements ICachePersister {
        private $cache_item = null;

        /**
         * Returns true, if item is chaced 
         */
        public function is_cached($cache_keys) {
                $dao = new DAOCache();
                $dao->add_where('content_gzip', DBWhere::OP_NOT_NULL);
                $dao->set_keys($this->extract_keys($cache_keys));
                $dao->add_where('expirationdate', '>', DBFieldDateTime::NOW);
                
                if ($dao->find(DAOCache::AUTOFETCH)) {
                        $this->cache_item = $dao;
                        return true; 
                }
                else {
                        $this->cache_item = false;
                        return false;
                }
        }

        /**
         * Read from cache
         * 
         * @param Mixed A set of key params, may be an array or a string
         * @return ICacheItem The cache as array with members "content" and "data", false if cache is not found
         */
        public function read($cache_keys) {
                $dao = new DAOCache();
                $dao->add_where('content_gzip', DBWhere::OP_NOT_NULL);
                $dao->set_keys($this->extract_keys($cache_keys));
                $dao->add_where('expirationdate', '>', DBFieldDateTime::NOW);
                
                if ($dao->find(DAOCache::AUTOFETCH)) {
                        return $dao; 
                }
                else {
                        return false;
                }
        }
        
        /**
         * Store content in cache
         * 
         * @param Mixed A set of key params, may be an array or a string
         * @param string The cache
         */
        public function store($cache_keys, $content, $cache_life_time, $data = '', $is_compressed = false) {
                try {
                        // Clear old items
                        $this->remove_expired();
                        $dao = new DAOCache();
                        $dao->set_keys($this->extract_keys($cache_keys));
                        $update = $dao->find(DAOCache::AUTOFETCH);
                        
                        if ($is_compressed) {
                                $dao->set_content_compressed($content);
                        }
                        else {
                                $dao->set_content_plain($content);
                        }
                        $dao->data = $data;
                        $dao->expirationdate = time() + $cache_life_time;
                        if ($update) {
                                $dao->update();
                        }
                        else {
                                $dao->insert();
                        }
                }
                catch (Exception $ex) {
                        // If inserting into cache fails, just resume application!
                        @error_log($ex->getMessage());                  
                }               
        }
        
        /**
         * Clear the cache
         * 
         * @param Mixed A set of key params, may be an array or a string. If NULL, all is cleared
         */
        public function clear($cache_keys = NULL) {
                $dao = new DAOCache();
                if (!empty($cache_keys)) {
                        $keys = $this->extract_keys($cache_keys);
                        $dao->set_keys($keys, true);
                }
                $dao->delete(DAOCache::WHERE_ONLY);                             
        }
        
        /**
         * Transform the given param into an array of keys
         * 
         * @param Mixed A set of key params, may be an array or a string
         */
        private function extract_keys($cache_keys) {
                if (is_array($cache_keys)) {
                        return array_values($cache_keys);
                }
                else if (is_string($cache_keys) || is_numeric($cache_keys)) {
                        return array($cache_keys);
                }
                return array();         
        }

        /**
         * Removes expired cache entries
         */
        public function remove_expired() {
                $dao = new DAOCache();
                $dao->add_where('expirationdate', '<', DBFieldDateTime::NOW);
                $dao->delete(DAOCache::WHERE_ONLY);
        }
}

Imprint