root/include/class.memcached.php

<?php

class adv_cache {</span>
<span class="code-keyword">
    var $vars = array();
    var $var_expires = array();
    var $is_modified = false;

    var $sql_rowset = array();
    var $sql_row_pointer = array();

    var $memcache;
    var $compress;
    var $cache_prefix;

    /**
     *
     * @param string $host - � �� memcached
     * @param int $port - ����emcached
     * @param int $compress - [0,1], �� � � �� ��
     * ���� ���     */
    function adv_cache($host = '127.0.0.1', $port = 11211, $compress = 0)
    {
        global $config;

        $this->memcache = memcache_connect($host, $port) or trigger_error('Cant connect to memcache server', E_USER_ERROR);
        $this->compress = ($compress) ? MEMCACHE_COMPRESSED : 0;
        $this->cache_prefix = 'tbdevsz/';
    }

    /**
    * Load global cache
    */
    function load()
    {
        if ( $return = $this->_exists('_global') ) {
            $this->vars = $return['vars'];
            $this->var_expires = $return['var_expires'];
        }
        else {
            return false;
        }

        return true;
    }

    /**
    * Unload cache object
    */
    function unload()
    {
        $this->save();
        unset($this->vars);
        unset($this->var_expires);
        unset($this->sql_rowset);
        unset($this->sql_row_pointer);
        $this->vars = array();
        $this->var_expires = array();
        $this->sql_rowset = array();
        $this->sql_row_pointer = array();

        memcache_close($this->memcache);
    }

    /**
    * Save modified objects
    */
    function save()
    {
        if (!$this->is_modified)
        {
            return;
        }
        $this->put('_global', array('vars' => $this->vars, 'var_expires' => $this->var_expires) );
        $this->is_modified = false;
    }

    /**
    * Tidy cache
    */
    function tidy()
    {
        return true;
    }

    /**
    * Get saved cache object
    */
    function get ( $var_name )
    {
        if ($var_name[0] == '_')
        {
            if ( $return = $this->_exists($var_name) ) {
                return $return;
            }
            else {
                return false;
            }
        }
        else
        {
            return ( $return = $this->_exists($var_name)) ? $this->vars[$var_name] : false;
        }
    }

    /**
    * Put data into cache
    */
    function put ( $var_name, $var, $ttl = 2592000 ) {

        $ttl = ( $ttl > 2592000 ) ? 2592000 : $ttl;

        if ($var_name[0] == '_')
        {
            memcache_set($this->memcache, $this->cache_prefix . 'data' . $var_name, $var, $this->compress, $ttl);
        }
        else
        {
            $this->vars[$var_name] = $var;
            $this->var_expires[$var_name] = time() + $ttl;
            $this->is_modified = true;
        }
    }

    /**
    * Purge cache data
    */
    function purge () {
        memcache_flush($this->memcache);
    }

    /**
    * Destroy cache data
    */
    function destroy($var_name, $table = '') {

        if ($var_name == 'sql' && !empty($table)) {
            $table = strtolower($table);
            $this->purge();
            //memcache_delete($this->memcache, $this->cache_prefix . 'sql/' . $table);
        }

        if (!$this->_exists($var_name))
        {
            return;
        }

        if ($var_name[0] == '_')
        {
            memcache_delete($this->memcache, $this->cache_prefix . 'data' . $var_name);
        }

        else if (isset($this->vars[$var_name]))
        {
            $this->is_modified = true;
            unset($this->vars[$var_name]);
            unset($this->var_expires[$var_name]);

            // We save here to let the following cache hits succeed
            $this->save();
        }
    }

    /**
    * Check if a given cache entry exist
    */
    function _exists($var_name)
    {
        if ($var_name[0] == '_')
        {
            return memcache_get($this->memcache, $this->cache_prefix . 'data' . $var_name);
        }
        else
        {
            if (!sizeof($this->vars))
            {
                $this->load();
            }

            if (!isset($this->var_expires[$var_name]))
            {
                return false;
            }

            return (time() > $this->var_expires[$var_name]) ? false : isset($this->vars[$var_name]);
        }
    }

    /**
    * Load cached sql query
    */
    function sql_load($query)
    {
        // Remove extra spaces and tabs
        $query = preg_replace('/[\n\r\s\t]+/', ' ', $query);
        $query_id = sizeof($this->sql_rowset);

        preg_match('/FROM (.*?)( |$)/si', $query, $matches);
        $table_name = strtolower(trim($matches[1]));

        $filename = $this->cache_prefix . 'sql/' . $table_name . '_' . md5($query);

        if ( ($this->sql_rowset[$query_id] = memcache_get($this->memcache, $filename)) === false )
        {
            return false;
        }

        $this->sql_row_pointer[$query_id] = 0;

        return $query_id;
    }

    function sql_save($query, &$query_result, $ttl)
    {

        global $db;

        $ttl = ( $ttl > 2592000 ) ? 2592000 : $ttl;

        // Remove extra spaces and tabs
        $query = preg_replace('/[\n\r\s\t]+/', ' ', $query);

        preg_match('/FROM (.*?)( |$)/si', $query, $matches);
        $table_name = strtolower(trim($matches[1]));
        $filename = $this->cache_prefix . 'sql/' . $table_name . '_' . md5($query);

        $query_id = sizeof($this->sql_rowset);
        $this->sql_rowset[$query_id] = array();
        $this->sql_row_pointer[$query_id] = 0;

        while ( $row = $db->sql_fetchrow($query_result) ) {
            $this->sql_rowset[$query_id][] = $row;
        }
        $db->sql_freeresult($query_result);

        memcache_set($this->memcache, $filename, $this->sql_rowset[$query_id], $this->compress, $ttl);

        $query_result = $query_id;
    }

}

?>