这篇文章主要介绍了关于php数据库缓存实现思路,有着一定的参考价值,现在分享给大家,有需要的朋友可以参考一下
缓存SQL查询结果 为什么要缓存查询结果? 缓存查询结果能极大地改进脚本执行时间和资源需求。 缓存SQL查询结果也允许你通过后期处理数据。如果你用文件缓存去存储全部脚本的输出结果(HTML输出),这样可能是行不通的。 当你执行一个SQL查询时,点典的处理过程是: 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a连接数据库 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a准备SQL查询 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a发送查询到数据库 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a取得返回结果 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a关闭数据库连接 以上方法非常占用资源并且相反的影响了脚本的性能。只能通过取得的大量返回数据和数据库服务器的位置这二个要素来相互协调。尽管持续连接可以改进连接数据库时的负载,但非常耗费内存资源,如果获取的是大量的数据,那么存储的全部时间会非常短暂。 创建一条SQL查询: SQL(结构化查询语言)查询被用作操作数据库及它内容的接口。SQL可用于定义和编辑表的结构,插入数据到表,更新或删除表中的信息。 SQL是用于与数据通讯的语言,在大多数PHP数据库扩展(MySQL,ODBC,Oracle等)通过传递SQL查询到数据库中来管理整个过程。 本教程中,仅仅用select语言来获取数据库中的数据。这些数据将被缓存,之后将用作数据源。 决定什么时候更新缓存: 根据程序的需要,缓存可以采取多种形式。最常见的3种方式是: 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a时间触发缓存(过期的时间戳) 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a内容改变触发缓存(发现数据改变后,相应地更新缓存) 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a人工触发缓存(人工的方式告知系统信息超期并且强制产生新的缓存) 你的缓存需求可能是以上原理的一个或多个的综合。本教程将讨论时间触发方式。然而,在一个全面的缓存机制中,3种方式的综合将被使用。 缓存结果: 基本的缓存是用PHP的两个函数serialize()和unserialize()(译注:这二个函数分别代表序列化与反序列化)。 函数serialize()用于存储PHP的值,它能保证不失去这些值的类型和结构。 事实上,PHP的session扩展是用序列化过的变量,把session变量($_SESSION)存储在系统的一个文件中。 函数unserialize()与以上操作相反并且使序列化过的字符串返回到它原来的结构和数据内容。 在本例中,以一个电子商务商店为例。商店有2个基本表,categories和products(此处为原始数据库表名).product表可能每天都在变化,categories仍然是不变静止的。 要显示产品,你可以用一个输出缓存脚本来存储输出的HTML结果到一个文件中。然而categories表可能需要后期处理。例如,所有的目录通过变量category_id(通过$_REQUEST['category_id']来取得)被显示,你可能希望高亮当前被选择的目录。 表categories结构 FieldType KeyExtracategory_idcategory_namecategory_descriptionint(10) unsignedvarchar(255)textPRIauto_incremen在本例中,通过时间触发缓存技术被运用,设定一段时间后让其缓存SQL输出过期。在此特殊的例子中,定一段时间为24小时。 序列化例子: 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a连接数据库 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a执行查询 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a取得所有结果构成一个数组以便后面你可以访问 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a序列化数组 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a保存序列化过的数组到文件中 [php] view plaincopy $file = 'sql_cache.txt'; $link = mysql_connect('localhost','username','password') or die (mysql_error()); mysql_select_db('shop') or die (mysql_error()); /* 构造SQL查询 */ $query = "SELECT * FROM categories"; $result = mysql_query($query) or die (mysql_error()); while ($record = mysql_fetch_array($result) ) { $records[] = $record; } $OUTPUT = serialize($records); $fp = fopen($file,"w"); // 以写权限的方式打开文件 fputs($fp, $OUTPUT); fclose($fp); 查看sql_cache.txt文件,里面的内容可能类似这样的: a:1:{i:0;a:6:{i:0;s:1:"1";s:11:"category_id";s:1:"1";i:1;s:9:"Computers";s:13:"category_name";s:9: "Computers" ;i:2;s:25:"Description for computers";s:20:"category_description" ;s:25:"Description for computers";}} 这个输出是它的变量和类型的内部表现形式。假若你用mysql_fetch_array()函数返回数字索引的数组和一个关联的数组(这就是为什么数据看起来像是发生了两次),一个是数字索引,另一个是字符串索引。 使用缓存: 要用缓存,你需要用函数unserialize()来使数据还原成原始格式与类型。 你可以用file_get_contents()这个函数来读取sql_cache.txt文件的内容,把它赋给一个变量。 请注意:这个函数在PHP4.3.0及以上版本有效。若你使用的是一个老版本的PHP,一个简单的方法是用file()函数(读整个文件到一个数组,每行变成一个数组)。implode()函数用于把数组的各元素连接成一个字符串然后使用unserialize()反序列化。 // file_get_contents() 适合于for PHP < 4.3.0 [php] view plaincopy $file = 'sql_cache.txt'; $records = unserialize(implode('',file($file))); //现在你可以通过$records数组并且取得原始查询的数据: foreach ($records as $id=>$row) { print $row['category_name']."<br>"; } 注意$records是数组(一个包含了查询结果的数字索引列——每行是一个数字和一个字符串...真是混乱)的一排。 把它们放在一块: 基于本例子中的时间来决定是否缓存。如果文件修改的时间戳比当前时间戳减去过期时间戳大,那么就用缓存,否则更新缓存。 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a检查文件是否存在并且时间戳小于设置的过期时间 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a获取存储在缓存文件中的记录或者更新缓存文件 [php] view plaincopy $file = 'sql_cache.txt'; $expire = 86400; // 24 小时 (单位:秒) if (file_exists($file) && filemtime($file) > (time() - $expire)) { // 取得缓存中的记录 $records = unserialize(file_get_contents($file)); } else { // 通过 serialize() 函数创建缓存 } 附加其它可能的: 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a把缓存结果存储在共享内存中以获取更快的速度 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a增加一个功能随机地运行SQL查询并且检查是否输出与缓存输出一致。如果不一致,则更新缓存(本函数运行次数的概率可以定为1/100)。通过哈希算法(如MD5())可以协助判断字符串或者文件是否改变。 437fcc348f7b1c54dc1b8f8cb5743cbcl 04c6c2c265887a55041405a81efec09a增加一个管理员的功能,人工的删除这个缓存文件,以强制更新缓存(如file_exists()函数返回false时)。你可以用函数unlink()删除文件。 脚本: [php] view plaincopy $file = 'sql_cache.txt'; $expire = 86400; // 24 小时 if (file_exists($file) && filemtime($file) > (time() - $expire)) { $records = unserialize(file_get_contents($file)); } else { $link = mysql_connect('localhost','username','password') or die (mysql_error()); mysql_select_db('shop') or die (mysql_error()); /* 构造SQL查询 */ $query = "SELECT * FROM categories"; $result = mysql_query($query) or die (mysql_error()); while ($record = mysql_fetch_array($result) ) { $records[] = $record; } $OUTPUT = serialize($records); $fp = fopen($file,"w"); fputs($fp, $OUTPUT); fclose($fp); } // end else // 查询结果在数组 $records 中 foreach ($records as $id=>$row) { if ($row['category_id'] == $_REQUEST['category_id']) { // 被选择的目录显示粗体字 print '<B>'.$row['category_name'].'</B><BR>'; } else { // 其它目录显示用常规字体 print $row['category_name'].'<br>'; } } // end foreach |
以上是php数据库缓存实现思路的详细内容。更多信息请关注PHP中文网其他相关文章!