DbCache.php 9.23 KB
Newer Older
Qiang Xue committed
1 2 3
<?php
/**
 * @link http://www.yiiframework.com/
Qiang Xue committed
4
 * @copyright Copyright (c) 2008 Yii Software LLC
Qiang Xue committed
5 6 7
 * @license http://www.yiiframework.com/license/
 */

Qiang Xue committed
8 9
namespace yii\caching;

10
use Yii;
11
use yii\base\InvalidConfigException;
Qiang Xue committed
12 13
use yii\db\Connection;
use yii\db\Query;
14
use yii\di\Instance;
Qiang Xue committed
15

Qiang Xue committed
16
/**
Qiang Xue committed
17
 * DbCache implements a cache application component by storing cached data in a database.
Qiang Xue committed
18
 *
19
 * By default, DbCache stores session data in a DB table named 'cache'. This table
20
 * must be pre-created. The table name can be changed by setting [[cacheTable]].
21 22
 *
 * Please refer to [[Cache]] for common cache operations that are supported by DbCache.
Qiang Xue committed
23
 *
24 25 26
 * The following example shows how you can configure the application to use DbCache:
 *
 * ~~~
Alexander Makarov committed
27
 * 'cache' => [
28 29 30
 *     'class' => 'yii\caching\DbCache',
 *     // 'db' => 'mydb',
 *     // 'cacheTable' => 'my_cache',
Alexander Makarov committed
31
 * ]
32
 * ~~~
Qiang Xue committed
33 34
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
Qiang Xue committed
35
 * @since 2.0
Qiang Xue committed
36
 */
Qiang Xue committed
37
class DbCache extends Cache
Qiang Xue committed
38
{
39 40 41 42 43 44 45 46 47 48 49
    /**
     * @var Connection|string the DB connection object or the application component ID of the DB connection.
     * After the DbCache object is created, if you want to change this property, you should only assign it
     * with a DB connection object.
     */
    public $db = 'db';
    /**
     * @var string name of the DB table to store cache content.
     * The table should be pre-created as follows:
     *
     * ~~~
50
     * CREATE TABLE cache (
51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71
     *     id char(128) NOT NULL PRIMARY KEY,
     *     expire int(11),
     *     data BLOB
     * );
     * ~~~
     *
     * where 'BLOB' refers to the BLOB-type of your preferred DBMS. Below are the BLOB type
     * that can be used for some popular DBMS:
     *
     * - MySQL: LONGBLOB
     * - PostgreSQL: BYTEA
     * - MSSQL: BLOB
     *
     * When using DbCache in a production server, we recommend you create a DB index for the 'expire'
     * column in the cache table to improve the performance.
     */
    public $cacheTable = '{{%cache}}';
    /**
     * @var integer the probability (parts per million) that garbage collection (GC) should be performed
     * when storing a piece of data in the cache. Defaults to 100, meaning 0.01% chance.
     * This number should be between 0 and 1000000. A value 0 meaning no GC will be performed at all.
72
     */
73
    public $gcProbability = 100;
Qiang Xue committed
74

75 76 77 78 79 80 81 82
    /**
     * Initializes the DbCache component.
     * This method will initialize the [[db]] property to make sure it refers to a valid DB connection.
     * @throws InvalidConfigException if [[db]] is invalid.
     */
    public function init()
    {
        parent::init();
83
        $this->db = Instance::ensure($this->db, Connection::className());
84
    }
Qiang Xue committed
85

86 87 88 89 90 91
    /**
     * Checks whether a specified key exists in the cache.
     * This can be faster than getting the value from the cache if the data is big.
     * Note that this method does not check whether the dependency associated
     * with the cached data, if there is any, has changed. So a call to [[get]]
     * may return false while exists returns true.
92 93
     * @param mixed $key a key identifying the cached value. This can be a simple string or
     * a complex data structure consisting of factors representing the key.
94 95 96 97 98
     * @return boolean true if a value exists in cache, false if the value is not in the cache or expired.
     */
    public function exists($key)
    {
        $key = $this->buildKey($key);
Qiang Xue committed
99

100 101 102 103 104 105 106 107 108 109 110 111
        $query = new Query;
        $query->select(['COUNT(*)'])
            ->from($this->cacheTable)
            ->where('[[id]] = :id AND ([[expire]] = 0 OR [[expire]] >' . time() . ')', [':id' => $key]);
        if ($this->db->enableQueryCache) {
            // temporarily disable and re-enable query caching
            $this->db->enableQueryCache = false;
            $result = $query->createCommand($this->db)->queryScalar();
            $this->db->enableQueryCache = true;
        } else {
            $result = $query->createCommand($this->db)->queryScalar();
        }
112

113 114
        return $result > 0;
    }
115

116 117 118
    /**
     * Retrieves a value from cache with a specified key.
     * This is the implementation of the method declared in the parent class.
119
     * @param string $key a unique key identifying the cached value
120 121 122 123 124 125 126 127 128 129 130 131 132
     * @return string|boolean the value stored in cache, false if the value is not in the cache or expired.
     */
    protected function getValue($key)
    {
        $query = new Query;
        $query->select(['data'])
            ->from($this->cacheTable)
            ->where('[[id]] = :id AND ([[expire]] = 0 OR [[expire]] >' . time() . ')', [':id' => $key]);
        if ($this->db->enableQueryCache) {
            // temporarily disable and re-enable query caching
            $this->db->enableQueryCache = false;
            $result = $query->createCommand($this->db)->queryScalar();
            $this->db->enableQueryCache = true;
Qiang Xue committed
133

134 135 136 137 138
            return $result;
        } else {
            return $query->createCommand($this->db)->queryScalar();
        }
    }
Qiang Xue committed
139

140 141
    /**
     * Retrieves multiple values from cache with the specified keys.
142
     * @param array $keys a list of keys identifying the cached values
143 144 145 146 147 148 149 150 151 152 153 154
     * @return array a list of cached values indexed by the keys
     */
    protected function getValues($keys)
    {
        if (empty($keys)) {
            return [];
        }
        $query = new Query;
        $query->select(['id', 'data'])
            ->from($this->cacheTable)
            ->where(['id' => $keys])
            ->andWhere('([[expire]] = 0 OR [[expire]] > ' . time() . ')');
Qiang Xue committed
155

156 157 158 159 160 161 162
        if ($this->db->enableQueryCache) {
            $this->db->enableQueryCache = false;
            $rows = $query->createCommand($this->db)->queryAll();
            $this->db->enableQueryCache = true;
        } else {
            $rows = $query->createCommand($this->db)->queryAll();
        }
Qiang Xue committed
163

164 165 166 167 168 169 170
        $results = [];
        foreach ($keys as $key) {
            $results[$key] = false;
        }
        foreach ($rows as $row) {
            $results[$row['id']] = $row['data'];
        }
171

172 173
        return $results;
    }
Qiang Xue committed
174

175 176 177 178
    /**
     * Stores a value identified by a key in cache.
     * This is the implementation of the method declared in the parent class.
     *
179 180 181
     * @param string $key the key identifying the value to be cached
     * @param string $value the value to be cached
     * @param integer $duration the number of seconds in which the cached value will expire. 0 means never expire.
182 183
     * @return boolean true if the value is successfully stored into cache, false otherwise
     */
Qiang Xue committed
184
    protected function setValue($key, $value, $duration)
185 186 187
    {
        $command = $this->db->createCommand()
            ->update($this->cacheTable, [
Qiang Xue committed
188
                'expire' => $duration > 0 ? $duration + time() : 0,
189 190
                'data' => [$value, \PDO::PARAM_LOB],
            ], ['id' => $key]);
Qiang Xue committed
191

192 193
        if ($command->execute()) {
            $this->gc();
194

195 196
            return true;
        } else {
Qiang Xue committed
197
            return $this->addValue($key, $value, $duration);
198 199
        }
    }
Qiang Xue committed
200

201 202 203 204
    /**
     * Stores a value identified by a key into cache if the cache does not contain this key.
     * This is the implementation of the method declared in the parent class.
     *
205 206 207
     * @param string $key the key identifying the value to be cached
     * @param string $value the value to be cached
     * @param integer $duration the number of seconds in which the cached value will expire. 0 means never expire.
208 209
     * @return boolean true if the value is successfully stored into cache, false otherwise
     */
Qiang Xue committed
210
    protected function addValue($key, $value, $duration)
211 212
    {
        $this->gc();
Qiang Xue committed
213

214 215 216 217
        try {
            $this->db->createCommand()
                ->insert($this->cacheTable, [
                    'id' => $key,
Qiang Xue committed
218
                    'expire' => $duration > 0 ? $duration + time() : 0,
219 220 221 222 223 224 225 226 227 228 229 230
                    'data' => [$value, \PDO::PARAM_LOB],
                ])->execute();

            return true;
        } catch (\Exception $e) {
            return false;
        }
    }

    /**
     * Deletes a value with the specified key from cache
     * This is the implementation of the method declared in the parent class.
231
     * @param string $key the key of the value to be deleted
232 233 234 235 236 237 238 239 240 241 242 243 244 245
     * @return boolean if no error happens during deletion
     */
    protected function deleteValue($key)
    {
        $this->db->createCommand()
            ->delete($this->cacheTable, ['id' => $key])
            ->execute();

        return true;
    }

    /**
     * Removes the expired data values.
     * @param boolean $force whether to enforce the garbage collection regardless of [[gcProbability]].
246
     * Defaults to false, meaning the actual deletion happens with the probability as specified by [[gcProbability]].
247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269
     */
    public function gc($force = false)
    {
        if ($force || mt_rand(0, 1000000) < $this->gcProbability) {
            $this->db->createCommand()
                ->delete($this->cacheTable, '[[expire]] > 0 AND [[expire]] < ' . time())
                ->execute();
        }
    }

    /**
     * Deletes all values from cache.
     * This is the implementation of the method declared in the parent class.
     * @return boolean whether the flush operation was successful.
     */
    protected function flushValues()
    {
        $this->db->createCommand()
            ->delete($this->cacheTable)
            ->execute();

        return true;
    }
Qiang Xue committed
270
}