src/Core/Cache/DatabaseCacheDriver.php

   1 <?php
   2
   3 namespace Friendica\Core\Cache;
   4
   5 use Friendica\Core\Cache;
   6 use Friendica\Database\DBA;
   7 use Friendica\Util\DateTimeFormat;
   8
   9 /**
  10  * Database Cache Driver
  11  *
  12  * @author Hypolite Petovan <hypolite@mrpetovan.com>
  13  */
  14 class DatabaseCacheDriver extends AbstractCacheDriver implements ICacheDriver
  15 {
  16         /**
  17          * (@inheritdoc)
  18          */
  19         public function getAllKeys($prefix = null)
  20         {
  21                 if (empty($prefix)) {
  22                         $where = ['`expires` >= ?', DateTimeFormat::utcNow()];
  23                 } else {
  24                         $where = ['`expires` >= ? AND `k` LIKE CONCAT(?, \'%\')', DateTimeFormat::utcNow(), $prefix];
  25                 }
  26
  27                 $stmt = DBA::select('cache', ['k'], $where);
  28
  29                 $keys = [];
  30                 while ($key = DBA::fetch($stmt)) {
  31                         array_push($keys, $key['k']);
  32                 }
  33                 DBA::close($stmt);
  34
  35                 return $keys;
  36         }
  37
  38         /**
  39          * (@inheritdoc)
  40          */
  41         public function get($key)
  42         {
  43                 $cache = DBA::selectFirst('cache', ['v'], ['`k` = ? AND (`expires` >= ? OR `expires` = -1)', $key, DateTimeFormat::utcNow()]);
  44
  45                 if (DBA::isResult($cache)) {
  46                         $cached = $cache['v'];
  47                         $value = @unserialize($cached);
  48
  49                         // Only return a value if the serialized value is valid.
  50                         // We also check if the db entry is a serialized
  51                         // boolean 'false' value (which we want to return).
  52                         if ($cached === serialize(false) || $value !== false) {
  53                                 return $value;
  54                         }
  55                 }
  56
  57                 return null;
  58         }
  59
  60         /**
  61          * (@inheritdoc)
  62          */
  63         public function set($key, $value, $ttl = Cache::FIVE_MINUTES)
  64         {
  65                 if ($ttl > 0) {
  66                         $fields = [
  67                                 'v' => serialize($value),
  68                                 'expires' => DateTimeFormat::utc('now + ' . $ttl . 'seconds'),
  69                                 'updated' => DateTimeFormat::utcNow()
  70                         ];
  71                 } else {
  72                         $fields = [
  73                                 'v' => serialize($value),
  74                                 'expires' => -1,
  75                                 'updated' => DateTimeFormat::utcNow()
  76                         ];
  77                 }
  78
  79                 return DBA::update('cache', $fields, ['k' => $key], true);
  80         }
  81
  82         /**
  83          * (@inheritdoc)
  84          */
  85         public function delete($key)
  86         {
  87                 return DBA::delete('cache', ['k' => $key]);
  88         }
  89
  90         /**
  91          * (@inheritdoc)
  92          */
  93         public function clear($outdated = true)
  94         {
  95                 if ($outdated) {
  96                         return DBA::delete('cache', ['`expires` < NOW()']);
  97                 } else {
  98                         return DBA::delete('cache', ['`k` IS NOT NULL ']);
  99                 }
 100         }
 101 }