1098 lines
35 KiB
PHP
1098 lines
35 KiB
PHP
<?php
|
||
/**
|
||
* The cache library of zentaopms.
|
||
*
|
||
* @copyright Copyright 2009-2024 禅道软件（青岛）有限公司(ZenTao Software (Qingdao) Co., Ltd. www.zentao.net)
|
||
* @license ZPL(https://zpl.pub/page/zplv12.html) or AGPL(https://www.gnu.org/licenses/agpl-3.0.en.html)
|
||
* @author Gang Liu <liugang@chandao.com>
|
||
* @package cache
|
||
* @link https://www.zentao.net
|
||
*/
|
||
namespace Zentao\Cache;
|
||
|
||
\helper::import(dirname(__FILE__) . DS . 'simple-cache' . DS . 'CacheInterface.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'simple-cache' . DS . 'CacheException.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'simple-cache' . DS . 'InvalidArgumentException.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'driver' . DS . 'ApcuDriver.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'driver' . DS . 'RedisDriver.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'driver' . DS . 'YacDriver.php');
|
||
\helper::import(dirname(__FILE__) . DS . 'driver' . DS . 'FileDriver.php');
|
||
|
||
use ZenTao\Cache\SimpleCache\InvalidArgumentException;
|
||
|
||
class cache
|
||
{
|
||
const DRIVER_APCU = 'Apcu';
|
||
|
||
const DRIVER_FILE = 'File';
|
||
|
||
const DRIVER_YAC = 'Yac';
|
||
|
||
const DRIVER_REDIS = 'Redis';
|
||
|
||
const DRIVER_LIST = [self::DRIVER_APCU, self::DRIVER_FILE, self::DRIVER_YAC, self::DRIVER_REDIS];
|
||
|
||
/**
|
||
* 全局应用程序对象。
|
||
* Global application object.
|
||
*
|
||
* @access private
|
||
* @var object
|
||
*/
|
||
private $app;
|
||
|
||
/**
|
||
* 全局数据库操作对象。
|
||
* Global database operation object.
|
||
*
|
||
* @access private
|
||
* @var object
|
||
*/
|
||
private $dao;
|
||
|
||
/**
|
||
* 全局数据库操作句柄。
|
||
* Global database operation handler.
|
||
*
|
||
* @access private
|
||
* @var object
|
||
*/
|
||
private $dbh;
|
||
|
||
/**
|
||
* 全局配置对象。
|
||
* Global configuration object.
|
||
*
|
||
* @access private
|
||
* @var object
|
||
*/
|
||
private $config;
|
||
|
||
/**
|
||
* 全局缓存对象。
|
||
* Global cache object.
|
||
*
|
||
* @access private
|
||
* @var object
|
||
*/
|
||
private $cache;
|
||
|
||
/**
|
||
* 缓存状态。
|
||
* Cache status.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $status = 'enabled';
|
||
|
||
/**
|
||
* 缓存命名空间。
|
||
* Cache namespace.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $namespace;
|
||
|
||
/**
|
||
* 缓存键连接符。
|
||
* Cache key connector.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $connector;
|
||
|
||
/**
|
||
* 缓存键。
|
||
* Cache key.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $key = '';
|
||
|
||
/**
|
||
* 缓存标签。
|
||
* Cache label.
|
||
*
|
||
* @access private
|
||
* @var array
|
||
*/
|
||
private $labels = [];
|
||
|
||
/**
|
||
* 影响缓存的表名。
|
||
* Table name that affects cache.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $table = '';
|
||
|
||
/**
|
||
* 影响缓存的事件。
|
||
* Event that affects cache.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $event = '';
|
||
|
||
/**
|
||
* 影响缓存的 WHERE 子句。
|
||
* WHERE clause that affects cache.
|
||
*
|
||
* @access private
|
||
* @var string
|
||
*/
|
||
private $where = '';
|
||
|
||
/**
|
||
* 受影响的对象列表。
|
||
* Affected object list.
|
||
*
|
||
* @access private
|
||
* @var array
|
||
*/
|
||
private $objects = [];
|
||
|
||
/**
|
||
* 构造函数，根据配置文件初始化缓存对象。
|
||
* Constructor, initialize cache object according to the configuration file.
|
||
*
|
||
* @param object $app 全局应用程序对象。
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function __construct(object $app)
|
||
{
|
||
$this->app = $app;
|
||
$this->dao = $app->dao;
|
||
$this->dbh = $app->dbh;
|
||
$this->config = $app->config;
|
||
|
||
if(empty($this->config->cache->enable)) return $this->log('The cache is not enabled', __FILE__, __LINE__);
|
||
|
||
$driver = ucfirst(strtolower($this->config->cache->driver));
|
||
|
||
if(!in_array($driver, self::DRIVER_LIST)) return $this->log("Driver {$driver} is not supported.", __FILE__, __LINE__);
|
||
if($driver != self::DRIVER_FILE && !extension_loaded($driver)) return $this->log("Driver ext-{$driver} is not loaded.", __FILE__, __LINE__);
|
||
|
||
$connector = $driver == self::DRIVER_REDIS ? ':' : '-';
|
||
$className = "ZenTao\Cache\Driver\\{$driver}Driver";
|
||
$scope = $this->config->cache->scope;
|
||
$namespace = $this->config->cache->namespace;
|
||
$lifetime = $this->config->cache->lifetime;
|
||
$redis = $this->config->redis;
|
||
|
||
$this->setNamespace($namespace);
|
||
$this->setConnector($connector);
|
||
|
||
if($driver == self::DRIVER_APCU) return $this->cache = new $className($namespace, $lifetime, $scope, $connector);
|
||
if($driver == self::DRIVER_REDIS) return $this->cache = new $className($namespace, $lifetime, $scope, $connector, $redis);
|
||
if($driver == self::DRIVER_YAC) return $this->cache = new $className($namespace, $lifetime);
|
||
if($driver == self::DRIVER_FILE) return $this->cache = new $className($namespace, $lifetime, $app->getCacheRoot());
|
||
}
|
||
|
||
/**
|
||
* 设置缓存状态。
|
||
* Set cache status.
|
||
*
|
||
* @param string $status 缓存状态。enabled: 启用缓存；disabled: 禁用缓存。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setStatus(string $status)
|
||
{
|
||
$this->status = $status;
|
||
}
|
||
|
||
/**
|
||
* 设置缓存命名空间。
|
||
* Set cache namespace.
|
||
*
|
||
* @param string $namespace 缓存命名空间。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setNamespace(string $namespace)
|
||
{
|
||
$this->namespace = $namespace;
|
||
}
|
||
|
||
/**
|
||
* 设置缓存键连接符。
|
||
* Set cache key connector.
|
||
*
|
||
* @param string $connector 缓存键连接符。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setConnector(string $connector)
|
||
{
|
||
$this->connector = $connector;
|
||
}
|
||
|
||
/**
|
||
* 设置缓存键。
|
||
* Set cache key.
|
||
*
|
||
* @param string $key 缓存键。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setKey(string $key)
|
||
{
|
||
$this->key = $key;
|
||
}
|
||
|
||
/**
|
||
* 设置影响缓存的表名。
|
||
* Set the table name that affects the cache.
|
||
*
|
||
* @param string $table 表名。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setTable(string $table)
|
||
{
|
||
$this->table = $table;
|
||
}
|
||
|
||
/**
|
||
* 设置影响缓存的事件。
|
||
* Set the event that affects the cache.
|
||
*
|
||
* @param string $event 事件。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setEvent(string $event)
|
||
{
|
||
$this->event = $event;
|
||
}
|
||
|
||
/**
|
||
* 设置影响缓存的 WHERE 子句。
|
||
* Set the WHERE clause that affects the cache.
|
||
*
|
||
* @param string $where WHERE 子句。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setWhere(string $where)
|
||
{
|
||
$this->where = $where;
|
||
}
|
||
|
||
/**
|
||
* 设置受影响的对象列表。
|
||
* Set the list of affected objects.
|
||
*
|
||
* @param array $objects 对象列表。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function setObjects(array $objects)
|
||
{
|
||
$this->objects = $objects;
|
||
}
|
||
|
||
/**
|
||
* 获取表的主键字段。
|
||
* Get the primary key field of the table.
|
||
*
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
public function getTableField(): string
|
||
{
|
||
return $this->config->cache->raw[$this->table];
|
||
}
|
||
|
||
/**
|
||
* 获取表的缓存代号。
|
||
* Get the cache code of the table.
|
||
*
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private function getTableCode(): string
|
||
{
|
||
return str_replace(['`', $this->config->db->prefix], '', $this->table);
|
||
}
|
||
|
||
/**
|
||
* 获取原始数据类型缓存的键。该缓存用于保存表的原始数据。
|
||
* Get the key of the raw data type cache. This cache is used to save the original data of the table.
|
||
*
|
||
* @param string $code 缓存代号。
|
||
* @param int|string $id 主键值。
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private function getRawCacheKey(string $code, int|string $id): string
|
||
{
|
||
return $this->createKey('raw', $code, $id);
|
||
}
|
||
|
||
/**
|
||
* 获取集合类型缓存的键。该缓存用于保存表的主键字段。
|
||
* Get the key of the set type cache. This cache is used to save the primary key field of the table.
|
||
*
|
||
* @param string $code 缓存代号。
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private function getSetCacheKey(string $code): string
|
||
{
|
||
return $this->createKey('set', $code, 'list');
|
||
}
|
||
|
||
/**
|
||
* 获取结果类型缓存的键。该缓存用于保存表的计算结果。
|
||
* Get the key of the result type cache. This cache is used to save the calculation results of the table.
|
||
*
|
||
* @param string $key 缓存键。
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private function getResCacheKey(string $key): string
|
||
{
|
||
$args = explode('_', str_replace('cache', 'res', strtolower($key)));
|
||
return $this->createKey(...$args);
|
||
}
|
||
|
||
/**
|
||
* 新增数据时更新缓存。
|
||
* Update cache when adding data.
|
||
*
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function create()
|
||
{
|
||
$code = $this->getTableCode();
|
||
$setCacheKey = $this->getSetCacheKey($code);
|
||
$objectIdList = $this->cache->get($setCacheKey);
|
||
if(!is_array($objectIdList)) return;
|
||
|
||
$objectID = $this->dbh->lastInsertID();
|
||
if(!$objectID) return $this->log('Failed to fetch last insert id.', __FILE__, __LINE__);
|
||
|
||
/* 获取新增的数据。Get the new data. */
|
||
$sql = $this->dao->select('*')->from($this->table)->where('id')->eq($objectID)->sqlobj->get();
|
||
$object = $this->query($sql, 'fetch');
|
||
if(!$object) return $this->log('Failed to fetch new object. The sql is: ' . $sql, __FILE__, __LINE__);
|
||
|
||
/* 把新增的数据保存到缓存中。Save the new data to cache. */
|
||
$field = $this->getTableField();
|
||
$rawCacheKey = $this->getRawCacheKey($code, $object->$field);
|
||
$this->cache->set($rawCacheKey, $object);
|
||
|
||
/* 把新增的数据的 id 保存到缓存中。Save the id of the new data to cache. */
|
||
$this->cache->set($setCacheKey, $objectIdList ? array_merge($objectIdList, [$object->$field]) : [$object->$field]);
|
||
|
||
if(empty($this->config->cache->res[$this->table])) return;
|
||
|
||
/* 删除受影响的缓存。Delete the affected cache. */
|
||
$this->deleteAffectedCache([$object]);
|
||
}
|
||
|
||
/**
|
||
* 更新数据时更新缓存。
|
||
* Update cache when updating data.
|
||
*
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function update()
|
||
{
|
||
if(empty($this->objects)) return $this->log('No objects to update.', __FILE__, __LINE__);
|
||
|
||
$field = $this->getTableField();
|
||
$code = $this->getTableCode();
|
||
|
||
/* 获取被更新数据的 id 列表。Get the id list of the updated data. */
|
||
$objectIdList = array_map(function($object) use ($field) { return $object->$field; }, $this->objects);
|
||
|
||
/* 获取更新后的数据。Get the updated data. */
|
||
$sql = $this->dao->select('*')->from($this->table)->where($field)->in($objectIdList)->sqlobj->get();
|
||
$objects = $this->query($sql, 'fetchAll', $field);
|
||
if(!$objects) return $this->log('Failed to fetch updated objects. The sql is: ' . $sql, __FILE__, __LINE__);
|
||
|
||
/* 把更新后的数据保存到缓存中。Save the updated data to cache. */
|
||
$values = [];
|
||
foreach($objects as $object)
|
||
{
|
||
$rawCacheKey = $this->getRawCacheKey($code, $object->$field);
|
||
$values[$rawCacheKey] = $object;
|
||
}
|
||
$this->cache->setMultiple($values);
|
||
|
||
if(empty($this->config->cache->res[$this->table])) return;
|
||
|
||
/* 获取受影响的数据。Get the affected data. */
|
||
foreach($objectIdList as $objectID)
|
||
{
|
||
if(isset($this->objects[$objectID]) && isset($objects[$objectID]) && $this->objects[$objectID] == $objects[$objectID]) unset($this->objects[$objectID], $objects[$objectID]);
|
||
}
|
||
$affectedObjects = array_merge($this->objects, $objects);
|
||
|
||
/* 删除受影响的缓存。Delete the affected cache. */
|
||
$this->deleteAffectedCache($affectedObjects);
|
||
}
|
||
|
||
/**
|
||
* 删除数据时更新缓存。
|
||
* Update cache when deleting data.
|
||
*
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function delete()
|
||
{
|
||
if(empty($this->objects)) return $this->log('No objects to delete.', __FILE__, __LINE__);
|
||
|
||
$code = $this->getTableCode();
|
||
$setCacheKey = $this->getSetCacheKey($code);
|
||
$objectIdList = $this->cache->get($setCacheKey);
|
||
if(!is_array($objectIdList)) return;
|
||
|
||
$field = $this->getTableField();
|
||
|
||
/* 把被删除的数据从缓存中删除。Delete the deleted data from cache. */
|
||
$affectedKeys = [];
|
||
foreach($this->objects as $object) $affectedKeys[] = $this->getRawCacheKey($code, $object->$field);
|
||
$this->cache->deleteMultiple($affectedKeys);
|
||
|
||
/* 把被删除的数据的 id 从缓存中删除。Delete the id of the deleted data from cache. */
|
||
$this->cache->set($setCacheKey, array_diff($objectIdList, array_map(function($object) use ($field) { return $object->$field; }, $this->objects)));
|
||
|
||
if(empty($this->config->cache->res[$this->table])) return;
|
||
|
||
/* 删除受影响的缓存。Delete the affected cache. */
|
||
$this->deleteAffectedCache($this->objects);
|
||
}
|
||
|
||
/**
|
||
* 删除受影响的缓存。
|
||
* Delete the affected cache.
|
||
*
|
||
* @param array $objects 受影响的对象列表。
|
||
* @access private
|
||
* @return void
|
||
*/
|
||
private function deleteAffectedCache(array $objects)
|
||
{
|
||
/* 根据受影响的数据查找受影响的缓存。Find the affected cache by the affected data. */
|
||
$keys = [];
|
||
foreach($this->config->cache->res[$this->table] as $res)
|
||
{
|
||
$res = (object)$res;
|
||
|
||
/* 如果没有设置关联字段则整个缓存都受影响。If no associated fields are set, the entire cache is affected. */
|
||
if(empty($res->fields))
|
||
{
|
||
$keys[] = $this->getResCacheKey($res->name);
|
||
continue;
|
||
}
|
||
|
||
/* 根据关联字段查找受影响的缓存。Find the affected cache by the associated fields. */
|
||
foreach($objects as $object)
|
||
{
|
||
$key = $this->getResCacheKey($res->name);
|
||
foreach($res->fields as $field)
|
||
{
|
||
if(!isset($object->$field)) return $this->log("Field {$field} does not exist in table {$this->table}.", __FILE__, __LINE__);
|
||
|
||
$key .= $this->connector . $object->$field;
|
||
}
|
||
$keys[] = $key;
|
||
}
|
||
}
|
||
|
||
/* 删除受影响的缓存。Delete the affected cache. */
|
||
$this->cache->deleteMultiple($keys);
|
||
}
|
||
|
||
/**
|
||
* 执行数据库查询操作。
|
||
* Execute database query operation.
|
||
*
|
||
* @param string $sql SQL语句。
|
||
* @param string $function 查询函数。
|
||
* @param string $field 字段名。
|
||
* @access private
|
||
* @return array|object
|
||
*/
|
||
private function query($sql, $function = 'fetchAll', $field = ''): array|object
|
||
{
|
||
$rows = $this->dao->query($sql)->$function();
|
||
if($function == 'fetchAll' && !empty($field))
|
||
{
|
||
$objects = [];
|
||
foreach($rows as $row) $objects[$row->$field] = $row;
|
||
return $objects;
|
||
}
|
||
return $rows;
|
||
}
|
||
|
||
/**
|
||
* 检查表是否有缓存设置。
|
||
* Check if the table has cache settings.
|
||
*
|
||
* @param string $table 表名。
|
||
* @access private
|
||
* @return bool
|
||
*/
|
||
private function checkTable(string $table = ''): bool
|
||
{
|
||
if(empty($table)) $table = $this->table;
|
||
return !empty($this->config->cache->raw[$table]);
|
||
}
|
||
|
||
/**
|
||
* 记录日志信息。
|
||
* Record log information.
|
||
*
|
||
* @param string $message 日志信息。
|
||
* @param string $file 文件名。
|
||
* @param string $line 行号。
|
||
* @access private
|
||
* @return false
|
||
*/
|
||
private function log(string $message, string $file, string $line): bool
|
||
{
|
||
if(!$this->config->debug) return false;
|
||
|
||
$runMode = PHP_SAPI == 'cli' ? '_cli' : '';
|
||
$logFile = $this->app->getLogRoot() . 'cache' . $runMode . '.' . date('Ymd') . '.log.php';
|
||
if(!file_exists($logFile)) file_put_contents($logFile, '<?php die(); ?' . ">\n");
|
||
|
||
$content = date('Ymd H:i:s') . ': ' . $this->getURI() . "\nError: {$message} in $file on line $line\n";
|
||
file_put_contents($logFile, $content, FILE_APPEND);
|
||
|
||
if($this->config->debug >= 2) $this->app->triggerError($message, __FILE__, __LINE__, true);
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 获取 URI。
|
||
* Get URI.
|
||
*
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private function getURI(): string
|
||
{
|
||
$uri = $this->app->getURI();
|
||
if($uri) return $uri;
|
||
|
||
if($this->config->requestType == 'GET') return $_SERVER['REQUEST_URI'];
|
||
|
||
if($this->config->requestType == 'PATH_INFO' || $this->config->requestType == 'PATH_INFO2')
|
||
{
|
||
$pathInfo = $this->app->getPathInfo();
|
||
if(empty($pathInfo)) return '';
|
||
|
||
$dotPos = strrpos($pathInfo, '.');
|
||
if($dotPos) return substr($pathInfo, 0, $dotPos);
|
||
return $pathInfo;
|
||
}
|
||
|
||
return '';
|
||
}
|
||
|
||
/**
|
||
* 初始化指定表的缓存。
|
||
* Initialize the cache of the specified table.
|
||
*
|
||
* @access private
|
||
* @return array
|
||
*/
|
||
private function initTableCache(): array
|
||
{
|
||
$field = $this->getTableField();
|
||
$sql = $this->dao->select('*')->from($this->table)->sqlobj->get();
|
||
$objects = $this->query($sql, 'fetchAll', $field);
|
||
if(!$objects) return [];
|
||
|
||
$values = [];
|
||
$code = $this->getTableCode();
|
||
foreach($objects as $key => $object)
|
||
{
|
||
$rawCacheKey = $this->getRawCacheKey($code, $key);
|
||
$values[$rawCacheKey] = $object;
|
||
}
|
||
|
||
$this->cache->setMultiple($values);
|
||
|
||
$setCacheKey = $this->getSetCacheKey($code);
|
||
$this->cache->set($setCacheKey, array_keys($objects));
|
||
|
||
return $objects;
|
||
}
|
||
|
||
/**
|
||
* 生成缓存键。
|
||
* Generate cache key.
|
||
*
|
||
* @param mixed ...$args 缓存键的参数。
|
||
* @access public
|
||
* @return string
|
||
*/
|
||
public function createKey(...$args): string
|
||
{
|
||
return $this->namespace . $this->connector . implode($this->connector, $args);
|
||
}
|
||
|
||
/**
|
||
* 从缓存中获取指定表指定 id 的数据。
|
||
* Get the data of the specified table and id from the cache.
|
||
*
|
||
* @param string $table 表名。
|
||
* @param int|string $id 主键值。
|
||
* @access public
|
||
* @return object|false
|
||
*/
|
||
public function fetch(string $table, int|string $id): object|null
|
||
{
|
||
if($this->status == 'disabled') return null;
|
||
if(!$this->checkTable($table)) return $this->log("Table {$table} is not set in the cache configuration", __FILE__, __LINE__);
|
||
|
||
if(empty($table)) return $this->log('The table name is empty', __FILE__, __LINE__);
|
||
if(empty($id)) return $this->log('The id is empty', __FILE__, __LINE__);
|
||
|
||
$this->setTable($table);
|
||
|
||
$code = $this->getTableCode();
|
||
$key = $this->getRawCacheKey($code, $id);
|
||
$object = $this->cache->get($key);
|
||
if($object) return $object;
|
||
|
||
$objects = $this->initTableCache();
|
||
return isset($objects[$id]) ? $objects[$id] : null;
|
||
}
|
||
|
||
/**
|
||
* 从缓存中获取指定表的所有数据。
|
||
* Get all data of the specified table from the cache.
|
||
*
|
||
* @param string $table 表名。
|
||
* @param array $objectIdList 主键值列表。
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function fetchAll(string $table, array $objectIdList = []): array
|
||
{
|
||
if($this->status == 'disabled') return [];
|
||
if(!$this->checkTable($table)) return $this->log("Table {$table} is not set in the cache configuration", __FILE__, __LINE__);
|
||
|
||
if(empty($table)) return $this->log('The table name is empty', __FILE__, __LINE__);
|
||
|
||
$this->setTable($table);
|
||
|
||
$code = $this->getTableCode();
|
||
|
||
/* 尝试获取指定表的所有主键字段的值。Try to get the values of all primary key fields of the specified table. */
|
||
$setCacheKey = $this->getSetCacheKey($code);
|
||
$allObjectIdList = $this->cache->get($setCacheKey);
|
||
|
||
/* 如果主键字段的值为空，则初始化指定表的缓存。If the value of the primary key field is empty, initialize the cache of the specified table. */
|
||
if(!$allObjectIdList)
|
||
{
|
||
$allData = $this->initTableCache();
|
||
if(empty($objectIdList)) return $allData;
|
||
|
||
return array_intersect_key($allData, $objectIdList);
|
||
}
|
||
|
||
/* 如果主键字段的值不为空，则从缓存中获取数据。If the value of the primary key field is not empty, get the data from the cache. */
|
||
if(empty($objectIdList)) $objectIdList = $allObjectIdList;
|
||
|
||
$keys = [];
|
||
foreach($objectIdList as $objectID)
|
||
{
|
||
if(!$objectID) continue;
|
||
$keys[$objectID] = $this->getRawCacheKey($code, $objectID);
|
||
}
|
||
|
||
$objects = $this->cache->getMultiple(array_values($keys));
|
||
|
||
/* 如果缓存中没有全部的数据，则从数据库中获取缺失的数据。If not all data in cache, get the missing data from the database. */
|
||
if(count($keys) > count($objects))
|
||
{
|
||
$lostObjects = [];
|
||
$diffIdList = array_keys(array_diff($keys, array_keys($objects)));
|
||
$sql = $this->dao->select('*')->from($table)->where('id')->in($diffIdList)->sqlobj->get();
|
||
$diffObjects = $this->query($sql, 'fetchAll');
|
||
foreach($diffObjects as $object)
|
||
{
|
||
$rawCacheKey = $this->getRawCacheKey($code, $object->id);
|
||
$lostObjects[$rawCacheKey] = $object;
|
||
}
|
||
|
||
/* 把缺失的数据保存到缓存中。Save the missing data to cache. */
|
||
$this->cache->setMultiple($lostObjects);
|
||
|
||
$objects += $lostObjects;
|
||
}
|
||
|
||
if(!$objects) return [];
|
||
|
||
$result = [];
|
||
$field = $this->getTableField();
|
||
foreach($objects as $object) $result[$object->$field] = $object;
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 从自动缓存的计算结果中获取符合查询条件的数据。
|
||
* Get data that meets the query conditions from the calculation results of the automatic cache.
|
||
*
|
||
* @param string $table 表名。
|
||
* @param array $conditions 查询条件。
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function fetchAutoCache(string $table, array $conditions): array
|
||
{
|
||
if($this->status == 'disabled') return [];
|
||
if(!$this->checkTable($table)) return $this->log("Table {$table} is not set in the cache configuration", __FILE__, __LINE__);
|
||
|
||
$conditions = array_filter($conditions, function($condition)
|
||
{
|
||
return $condition['operator'] == 'eq';
|
||
});
|
||
|
||
if(empty($conditions)) return [];
|
||
|
||
$this->setTable($table);
|
||
|
||
/* 按字段排序查询条件以确保缓存的唯一性。Sort the query conditions by field to ensure the uniqueness of the cache. */
|
||
usort($conditions, function($a, $b)
|
||
{
|
||
return strcmp($a['field'], $b['field']);
|
||
});
|
||
|
||
/* 根据查询条件生成缓存键。Generate a cache key based on the query conditions. */
|
||
$values = array_column($conditions, 'value');
|
||
$code = $this->getTableCode();
|
||
$cacheKey = $this->createKey('cache', $code, 'auto', ...$values);
|
||
|
||
/* 从缓存中获取符合查询条件的主键字段的值。Get the value of the primary key field that meets the query conditions from the cache. */
|
||
$idList = $this->getByKey($cacheKey);
|
||
if(is_null($idList))
|
||
{
|
||
/* 如果没有缓存，从数据库中获取符合查询条件的主键字段的值并更新缓存。If there is no cache, get the value of the primary key field that meets the query conditions from the database and update the cache. */
|
||
$field = $this->getTableField();
|
||
$dao = $this->dao->select($field)->from($table)->where('1=1');
|
||
foreach($conditions as $condition) $dao->andWhere($condition['field'])->eq($condition['value']);
|
||
$sql = $dao->sqlobj->get();
|
||
$objects = $this->query($sql, 'fetchAll');
|
||
foreach($objects as $object) $idList[] = $object->$field;
|
||
$this->saveByKey($cacheKey, $idList);
|
||
|
||
/* 把缓存键写入数据库以便执行 dao::exec() 时自动更新。Write the cache key to the database for automatic update when executing dao::exec(). */
|
||
$fields = implode(',', array_column($conditions, 'field'));
|
||
$sql = $this->dao->select('1')->from(TABLE_AUTOCACHE)->where('code')->eq($code)->andWhere('fields')->eq($fields)->sqlobj->get();
|
||
$autoCache = $this->query($sql, 'fetch');
|
||
if(!$autoCache)
|
||
{
|
||
$autoCache = new \stdClass();
|
||
$autoCache->code = $code;
|
||
$autoCache->fields = $fields;
|
||
$sql = $this->dao->insert(TABLE_AUTOCACHE)->data($autoCache)->get();
|
||
try
|
||
{
|
||
$this->dbh->exec($sql);
|
||
}
|
||
catch(PDOException $e)
|
||
{
|
||
$this->dao->sqlError($e);
|
||
}
|
||
}
|
||
}
|
||
if(!$idList) return [];
|
||
|
||
/* 根据主键字段的值从缓存中获取数据。Get data from the cache according to the value of the primary key field. */
|
||
return $this->fetchAll($table, $idList);
|
||
}
|
||
|
||
/**
|
||
* 设置缓存键。
|
||
* Set cache key.
|
||
*
|
||
* @param string $key 缓存键。
|
||
* @param mixed ...$args 缓存键的参数。
|
||
* @access public
|
||
* @return object
|
||
*/
|
||
public function key($key, ...$args)
|
||
{
|
||
if(empty($this->config->cache->keys[$key])) return $this->log("Key {$key} is not defined", __FILE__, __LINE__);
|
||
|
||
$cache = $this->config->cache->keys[$key];
|
||
if(!empty($cache->fields) && !empty($args))
|
||
{
|
||
$tableFields = $this->dao->descTable($cache->table);
|
||
foreach($cache->fields as $index => $field)
|
||
{
|
||
if(!isset($tableFields[$field])) return $this->log("Field {$field} does not exist in table {$cache->table}", __FILE__, __LINE__);
|
||
if(!isset($args[$index])) continue;
|
||
|
||
$tableField = $tableFields[$field];
|
||
if(stripos($tableField->type, 'int') !== false) $args[$index] = (int) $args[$index];
|
||
if(stripos($tableField->type, 'float') !== false) $args[$index] = (float)$args[$index];
|
||
if(stripos($tableField->type, 'decimal') !== false) $args[$index] = (float)$args[$index];
|
||
if(stripos($tableField->type, 'double') !== false) $args[$index] = (float)$args[$index];
|
||
}
|
||
}
|
||
|
||
$key = $this->getResCacheKey(constant($key));
|
||
foreach($args as $arg) $key .= $this->connector . $arg;
|
||
|
||
$this->setKey($key);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 设置缓存标签。
|
||
* Set cache label.
|
||
*
|
||
* @param string $label 缓存标签。
|
||
* @access public
|
||
* @return object
|
||
*/
|
||
public function label(string $label)
|
||
{
|
||
if(empty($label)) return $this->log('The label is empty', __FILE__, __LINE__);
|
||
if(empty($this->key)) return $this->log('The key is empty', __FILE__, __LINE__);
|
||
if(isset($this->labels[$label])) return $this->log("Label {$label} already used", __FILE__, __LINE__);
|
||
$this->labels[$label] = $this->key;
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 根据当前缓存键获取缓存。
|
||
* Get cache according to the current cache key.
|
||
*
|
||
* @access public
|
||
* @return mixed
|
||
*/
|
||
public function get()
|
||
{
|
||
if($this->status == 'disabled') return null;
|
||
if(empty($this->key)) return $this->log('The key is empty', __FILE__, __LINE__);
|
||
return $this->cache->get($this->key);
|
||
}
|
||
|
||
/**
|
||
* 根据指定缓存键获取缓存。
|
||
* Get cache according to the specified cache key.
|
||
*
|
||
* @param string $key 缓存键。
|
||
* @access public
|
||
* @return mixed
|
||
*/
|
||
public function getByKey(string $key)
|
||
{
|
||
if($this->status == 'disabled') return null;
|
||
if(empty($key)) return $this->log('The key is empty', __FILE__, __LINE__);
|
||
|
||
return $this->cache->get($key);
|
||
}
|
||
|
||
/**
|
||
* 根据当前缓存键保存缓存。
|
||
* Save cache according to the current cache key.
|
||
*
|
||
* @param mixed $value 缓存值。
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function save($value)
|
||
{
|
||
if($this->status == 'disabled') return false;
|
||
if(empty($this->key)) return $this->log('The key is empty', __FILE__, __LINE__);
|
||
return $this->cache->set($this->key, $value);
|
||
}
|
||
|
||
/**
|
||
* 根据指定缓存建保存缓存。
|
||
* Save cache according to the specified cache key.
|
||
*
|
||
* @param string $key 缓存键。
|
||
* @param mixed $value 缓存值。
|
||
* @param int $ttl 缓存时间。
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function saveByKey(string $key, $value, int $ttl = 0)
|
||
{
|
||
if($this->status == 'disabled') return false;
|
||
if(empty($key)) return $this->log('The key is empty', __FILE__, __LINE__);
|
||
|
||
return $this->cache->set($key, $value, $ttl);
|
||
}
|
||
|
||
/**
|
||
* 根据指定缓存标签保存缓存。
|
||
* Save cache according to the specified cache label.
|
||
*
|
||
* @param string $label 缓存标签。
|
||
* @param mixed $value 缓存值。
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function saveByLabel(string $label, $value)
|
||
{
|
||
if($this->status == 'disabled') return false;
|
||
if(empty($label)) return $this->log('The label is empty', __FILE__, __LINE__);
|
||
if(empty($this->labels[$label])) return $this->log("Label {$label} does not exist", __FILE__, __LINE__);
|
||
|
||
return $this->cache->set($this->labels[$label], $value);
|
||
}
|
||
|
||
/**
|
||
* 重置缓存相关设置项。
|
||
* Reset cache related settings.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function reset()
|
||
{
|
||
$this->setKey('');
|
||
$this->setTable('');
|
||
$this->setEvent('');
|
||
$this->setWhere('');
|
||
$this->setObjects([]);
|
||
}
|
||
|
||
/**
|
||
* 执行数据库操作前准备更新缓存需要的设置项。
|
||
* Prepare the settings required to update the cache before executing the database operation.
|
||
*
|
||
* @param string $table 表名。
|
||
* @param string $event 事件。
|
||
* @param string $sql SQL 语句。
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function prepare(string $table, string $event, string $sql)
|
||
{
|
||
$this->reset();
|
||
|
||
if($this->status == 'disabled') return;
|
||
if(!$this->checkTable($table)) return;
|
||
|
||
if(empty($table)) return $this->log('Table name is required.', __FILE__, __LINE__);
|
||
if(empty($event)) return $this->log('Event type is required.', __FILE__, __LINE__);
|
||
if(empty($sql)) return $this->log('SQL statement is required.', __FILE__, __LINE__);
|
||
|
||
$this->setTable($table);
|
||
$this->setEvent($event);
|
||
|
||
if($event == 'update' || $event == 'delete')
|
||
{
|
||
/* 获取 WHERE 子句的内容。Get the content of WHERE clause. */
|
||
$whereLen = strlen(\DAO::WHERE);
|
||
$wherePOS = strrpos($sql, \DAO::WHERE);
|
||
$groupPOS = strrpos($sql, \DAO::GROUPBY);
|
||
$havingPOS = strrpos($sql, \DAO::HAVING);
|
||
$orderPOS = strrpos($sql, \DAO::ORDERBY);
|
||
$limitPOS = strrpos($sql, \DAO::LIMIT);
|
||
$splitPOS = $orderPOS ? $orderPOS : $limitPOS;
|
||
$splitPOS = $havingPOS ? $havingPOS : $splitPOS;
|
||
$splitPOS = $groupPOS ? $groupPOS : $splitPOS;
|
||
|
||
$where = '';
|
||
if($wherePOS)
|
||
{
|
||
if($splitPOS)
|
||
{
|
||
$where = substr($sql, $wherePOS + $whereLen, $splitPOS - $wherePOS - $whereLen);
|
||
}
|
||
else
|
||
{
|
||
$where = substr($sql, $wherePOS + $whereLen);
|
||
}
|
||
}
|
||
|
||
/* 执行操作后数据已经被修改，所以需要提前获取被影响的数据。*/
|
||
$field = $this->getTableField();
|
||
$sql = $this->dao->select('*')->from($table)->beginIF($where)->where($where)->fi()->sqlobj->get();
|
||
$objects = $this->query($sql, 'fetchAll', $field);
|
||
|
||
$this->setWhere($where);
|
||
$this->setObjects($objects);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 执行数据库操作后更新缓存。
|
||
* Update the cache after executing the database operation.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function sync()
|
||
{
|
||
if($this->status == 'disabled') return;
|
||
if(!$this->checkTable()) return;
|
||
|
||
if(empty($this->table)) return $this->log('Table name is required.', __FILE__, __LINE__);
|
||
if(empty($this->event)) return $this->log('Event type is required.', __FILE__, __LINE__);
|
||
|
||
if($this->event == 'insert') $this->create();
|
||
if($this->event == 'update') $this->update();
|
||
if($this->event == 'delete') $this->delete();
|
||
|
||
$this->reset();
|
||
}
|
||
|
||
/**
|
||
* 清空缓存。
|
||
* Clear cache.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function clear()
|
||
{
|
||
$this->setStatus('disabled');
|
||
$this->cache->clear();
|
||
$this->setStatus('normal');
|
||
}
|
||
|
||
/**
|
||
* 关闭缓存连接。
|
||
* Close cache connection.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function close()
|
||
{
|
||
if(method_exists($this->cache, 'close')) $this->cache->close();
|
||
}
|
||
|
||
/**
|
||
* 获取内存使用情况。
|
||
* Get memory usage.
|
||
*
|
||
* @param string $type
|
||
* @return string
|
||
*/
|
||
public function memory(string $type)
|
||
{
|
||
return $this->cache->memory($type);
|
||
}
|
||
}
|