网站地图    收藏   

主页 > php专栏 > php类库 >

php缓存数据功能的mysqli类 - php类库

来源:自学PHP网    时间:2014-11-30 12:53 作者: 阅读:

[导读] ?php/***Mysqli类**@author废墟*@versionv1.02009-08-18*/classdb_mysqli{protected$mysqli;protected$sql;protected$rs;protected$query_......

php缓存数据功能的mysqli类

  1. <?php    
  2.     /**   
  3.     * Mysqli类   
  4.     *   
  5.     * @author 废墟   
  6.     * @version v1.0 2009-08-18  
  7.     */    
  8.     class db_mysqli {    
  9.         protected $mysqli;    
  10.         protected $sql;    
  11.         protected $rs;    
  12.         protected $query_num    = 0;    
  13.         protected $fetch_mode    = MYSQLI_ASSOC;    
  14.         protected $cache_dir    = './cache/';    
  15.         protected $cache_time    = 1800;    
  16.   
  17.         public function  __construct($dbhost$dbuser$dbpass$dbname) {    
  18.             $this->mysqli    = new mysqli($dbhost$dbuser$dbpass$dbname);    
  19.             if(mysqli_connect_errno()) {    
  20.                 $this->mysqli    = false;    
  21.                 echo '<h2>'.mysqli_connect_error().'</h2>';    
  22.                 die();    
  23.             } else {    
  24.                 $this->mysqli->set_charset("utf8");    
  25.             }    
  26.         }    
  27.   
  28.         public function  __destruct() {    
  29.             $this->free();    
  30.             $this->close();    
  31.         }    
  32.   
  33.         protected function free() {    
  34.             @$this->rs->free();    
  35.         }    
  36.   
  37.         protected function close() {    
  38.             $this->mysqli->close();    
  39.         }    
  40.   
  41.         protected function fetch() {    
  42.             return $this->rs->fetch_array($this->fetch_mode);    
  43.         }    
  44.   
  45.         protected function getQuerySql($sql$limit = null) {    
  46.             if (@preg_match("/[0-9]+(,[ ]?[0-9]+)?/is"$limit) && !preg_match("/ LIMIT [0-9]+(,[ ]?[0-9]+)?$/is"$sql)) {    
  47.                 $sql .= " LIMIT " . $limit;    
  48.             }    
  49.             return $sql;    
  50.         }    
  51.   
  52.         protected function get_cache($sql,$method) {    
  53.             include_once './cache.php';//若框架中使用__autoload(),这里可以不用加载文件    
  54.             $cache    = new cache($this->cache_dir,$this->cache_time);    
  55.             $cache_file    = md5($sql.$method);    
  56.             $res    = $cache->get_cache($cache_file);    
  57.             if(!$res) {    
  58.                 $res    = $this->$method($sql);    
  59.                 $cache->set_cache($cache_file$res);    
  60.             }    
  61.             return $res;    
  62.         }    
  63.   
  64.         public function query_num() {    
  65.             return $this->query_num;    
  66.         }    
  67.   
  68.         public function set_cache_dir($cache_dir) {    
  69.             $this->cache_dir    = $cache_dir;    
  70.         }    
  71.   
  72.         public function set_cache_time($cache_time) {    
  73.             $this->cache_time    = $cache_time;    
  74.         }    
  75.   
  76.         public function query($sql$limit = null) {    
  77.             $sql    = $this->getQuerySql($sql$limit);    
  78.             $this->sql    = $sql;    
  79.             $this->rs    = $this->mysqli->query($sql);    
  80.             if (!$this->rs) {    
  81.                 echo "<h2>".$this->mysqli->error."</h2>";    
  82.                 die();    
  83.             } else {    
  84.             $this->query_num++;    
  85.                 return $this->rs;    
  86.             }    
  87.         }    
  88.   
  89.         public function getOne($sql) {    
  90.             $this->query($sql, 1);    
  91.             $this->fetch_mode    = MYSQLI_NUM;    
  92.             $row = $this->fetch();    
  93.             $this->free();    
  94.             return $row[0];    
  95.         }    
  96.   
  97.         public function get_one($sql) {    
  98.             return $this->getOne($sql);    
  99.         }    
  100.   
  101.         public function cache_one($sql) {    
  102.             $sql    = $this->getQuerySql($sql, 1);    
  103.             return $this->get_cache($sql'getOne');    
  104.         }    
  105.   
  106.         public function getRow($sql$fetch_mode = MYSQLI_ASSOC) {    
  107.             $this->query($sql, 1);    
  108.             $this->fetch_mode    = $fetch_mode;    
  109.             $row = $this->fetch();    
  110.             $this->free();    
  111.             return $row;    
  112.         }    
  113.   
  114.         public function get_row($sql$fetch_mode = MYSQLI_ASSOC) {    
  115.             return $this->getRow($sql);   
  116.         }    
  117.   
  118.         public function cache_row($sql) {    
  119.             $sql    = $this->getQuerySql($sql, 1);    
  120.             return $this->get_cache($sql'getRow');    
  121.         }    
  122.   
  123.         public function getAll($sql$limit = null, $fetch_mode = MYSQLI_ASSOC) {    
  124.             $this->query($sql$limit);    
  125.             $all_rows = array();    
  126.             $this->fetch_mode    = $fetch_mode;    
  127.             while($rows = $this->fetch()) {    
  128.                 $all_rows[] = $rows;    
  129.             }    
  130.             $this->free();    
  131.             return $all_rows;    
  132.         }    
  133.         public function get_all($sql$limit = null, $fetch_mode = MYSQLI_ASSOC) {    
  134.             return $this->getAll($sql);    
  135.         }    
  136.   
  137.         public function cache_all($sql$limit = null) {    
  138.             $sql    = $this->getQuerySql($sql$limit);    
  139.             return $this->get_cache($sql'getAll');    
  140.         }    
  141.   
  142.         public function insert_id() {    
  143.             return $this->mysqli->insert_id();    
  144.         }    
  145.   
  146.         public function escape($str) {    
  147.             if(is_array($str)) {    
  148.                 foreach($str as $key=>$val) {    
  149.                     $str[$key] = $this->escape($val);    
  150.                 }    
  151.             } else {    
  152.                 $str = addslashes(trim($str));    
  153.             }   //开源代码phpfensi.com 
  154.             return $str;    
  155.         }    
  156.     }    
  157.     //用法    
  158.     $db    = new db_mysqli('localhost''root', 111222, 'dict');    
  159.     $db->set_cache_time(10);    
  160.     $db->set_cache_dir('./cache/sql/');    
  161.     $sql = "select * from words order by word_id limit 10,10";    
  162.     $res1 = $db->get_all($sql);    
  163.     $res2 = $db->cache_all($sql);    
  164.   
  165.     echo $db->query_num(),'<br>';    
  166.     ?>

自学PHP网专注网站建设学习,PHP程序学习,平面设计学习,以及操作系统学习

京ICP备14009008号-1@版权所有www.zixuephp.com

网站声明:本站所有视频,教程都由网友上传,站长收集和分享给大家学习使用,如由牵扯版权问题请联系站长邮箱904561283@qq.com

添加评论