[李景山php]thinkphp核心源码注释|Db.class.php
2016-07-22 09:24
561 查看
<?php // +---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK IT ] // +---------------------------------------------------------------------- // | Copyright (c) 2006-2014 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- // | Author: liu21st <liu21st@gmail.com> // +---------------------------------------------------------------------- namespace Think\Cache\Driver; use Think\Cache; defined('THINK_PATH') or exit(); /** * 数据库方式缓存驱动 * CREATE TABLE think_cache ( * cachekey varchar(255) NOT NULL, * expire int(11) NOT NULL, * data blob, * datacrc int(32), * UNIQUE KEY `cachekey` (`cachekey`) * ); */ class Db extends Cache { /** * 架构函数 * @param array $options 缓存参数 * @access public */ // 神奇的数据库缓存,我看一下,哈哈 // 也无非就是 初始化 然后 连接 然后 前缀 长度 过期时间 public function __construct($options=array()) { if(empty($options)) { $options = array ( 'table' => C('DATA_CACHE_TABLE'), ); } $this->options = $options; $this->options['prefix'] = isset($options['prefix'])? $options['prefix'] : C('DATA_CACHE_PREFIX'); $this->options['length'] = isset($options['length'])? $options['length'] : 0; $this->options['expire'] = isset($options['expire'])? $options['expire'] : C('DATA_CACHE_TIME'); $this->handler = \Think\Db::getInstance(); } /** * 读取缓存 * @access public * @param string $name 缓存变量名 * @return mixed */ // 获取缓存 public function get($name) { $name = $this->options['prefix'].addslashes($name); // 处理名字 N('cache_read',1);// 记录次数 // 获取结果 $result = $this->handler->query('SELECT `data`,`datacrc` FROM `'.$this->options['table'].'` WHERE `cachekey`=\''.$name.'\' AND (`expire` =0 OR `expire`>'.time().') LIMIT 0,1'); if(false !== $result ) { $result = $result[0]; if(C('DATA_CACHE_CHECK')) {//开启数据校验 如果数据校验有问题 if($result['datacrc'] != md5($result['data'])) {//校验错误 return false; } } $content = $result['data']; // 明确数据 if(C('DATA_CACHE_COMPRESS') && function_exists('gzcompress')) { //启用数据压缩 $content = gzuncompress($content); } $content = unserialize($content); // 返回 数字 return $content; } else { return false; } } /** * 写入缓存 * @access public * @param string $name 缓存变量名 * @param mixed $value 存储数据 * @param integer $expire 有效时间(秒) * @return boolean */ public function set($name, $value,$expire=null) { $data = serialize($value); // 整理数据 $name = $this->options['prefix'].addslashes($name); // key value 的方式 N('cache_write',1);// 记录次数 if( C('DATA_CACHE_COMPRESS') && function_exists('gzcompress')) { //数据压缩 $data = gzcompress($data,3); // 压缩数据 } if(C('DATA_CACHE_CHECK')) {//开启数据校验 $crc = md5($data); // 开启数据 校验 }else { $crc = ''; } if(is_null($expire)) { $expire = $this->options['expire']; } $expire = ($expire==0)?0: (time()+$expire) ;//缓存有效期为0表示永久缓存 $result = $this->handler->query('select `cachekey` from `'.$this->options['table'].'` where `cachekey`=\''.$name.'\' limit 0,1'); if(!empty($result) ) { // 根据记录的反馈,删除跟 新增数据 //更新记录 $result = $this->handler->execute('UPDATE '.$this->options['table'].' SET data=\''.$data.'\' ,datacrc=\''.$crc.'\',expire='.$expire.' WHERE `cachekey`=\''.$name.'\''); }else { //新增记录 $result = $this->handler->execute('INSERT INTO '.$this->options['table'].' (`cachekey`,`data`,`datacrc`,`expire`) VALUES (\''.$name.'\',\''.$data.'\',\''.$crc.'\','.$expire.')'); } if($result) { if($this->options['length']>0) { // 记录缓存队列 $this->queue($name); } return true; }else { return false; } } /** * 删除缓存 * @access public * @param string $name 缓存变量名 * @return boolean */ // 删除当前缓存 delete ,就是删除数据库的一条语句 public function rm($name) { $name = $this->options['prefix'].addslashes($name); return $this->handler->execute('DELETE FROM `'.$this->options['table'].'` WHERE `cachekey`=\''.$name.'\''); } /** * 清除缓存 * @access public * @return boolean */ // 清空啊,有点狠 public function clear() { return $this->handler->execute('TRUNCATE TABLE `'.$this->options['table'].'`'); } } // 总结,如果通过数据库做缓存的话, 第一需要建立数据表,第二,这样本来就是在数据库里面获取的数据,仅仅就是减少了运算而已。
相关文章推荐
- [李景山php]thinkphp核心源码注释|Apc.class.php
- laravel 模型删除及软删除相关实现
- getpass ()函数
- getpgid()函数
- NSOutputStream NSInputStream 简单用法
- php如何执行非缓冲查询API
- PHP 多维数组排序学习
- setpriority()
- getpriority()
- php常用的字符串处理函数
- PHP魔术方法使用总结
- wordpress数据库配置文件wp-config.php
- PHP 连接 MSSQL
- php mssql 中文各种乱码
- PHP Web木马扫描器
- PHPCMS 前台模板集合
- PHPCMS 文件目录结构
- PHP双向队列,双端队列代码
- 一个高性能的FTP客户端
- php 字符串长度的解释