ThinkPHP擴展，實現Redis的CURD操做。

時間  2019-11-08
標籤 thinkphp 擴展 實現 redis curd 欄目 PHP 简体版
原文   原文鏈接

接下爲將以ThinkPHP做爲MVC開發框架，詳細介紹Redis的CURD操做。須要說明 的是，在ThinkPHP中自己並不支持Redis開發環境，只支持使用Redis開發簡單的數據緩存功能。因此咱們必需要經過擴展功能，實現Redis 的編程支持。爲了方便讀者學習，筆者臨時開發了相應的模塊擴展及數據庫擴展。 下載址爲 http://beauty-soft.net/book/php_mvc/code/thinkphp_redis.html 解壓下載後的壓縮包，將獲得DbRedis.class.php文件及RedisModel.class.php文件。將 DbRedis.class.php文件複製到ThinkPHP/Extend/Driver/Db目錄；將RedisModel.class.php文 件複製到ThinkPHP/Extend/Model目錄。而後在項目配置文件中加入Redis數據庫鏈接信息，如如下代碼所示。php

Redis 配置 'REDIS_HOST'=>'192.168.0.2', 'REDIS_PORT'=>6379, 'REDIS_AUTH'=>123456, 'REDIS_DB_PREFIX'=>'',html

一、增長數據

這裏的增長數據包括Redis五大數據類型的數據添加。因爲篇幅所限，這裏再也不詳細介紹操做的實現原理，將經過代碼演示操做方式。如如下代碼所示。redis

<?php 
/** 
* redis添加數據 
* Enter description here ... 
* @author Administrator 
* 
*/ 
class AddAction extends Action{ 
    /** 
     * list類型 
     * Enter description here ... 
     */ 
    public function lists(){ 
        $Redis=new RedisModel("list11"); 
        //一次只能推送一條       
        echo $Redis->add("ceiba"); 
    } 
     /** 
     * 字符串類型 
     * Enter description here ... 
     */ 
    public function string(){ 
        $Redis=new RedisModel(); 
        $data=array( 
            "str1"=>"ceiba", //一個key，對應一個值 
            "str2"=>"李開湧", 
            "str3"=>"李明", 
        ); 
        echo $Redis->type("string")->add($data); 
    } 
    /** 
     * HASH類型 
     * Enter description here ... 
     */ 
    public function hash(){ 
        $Redis=new RedisModel("user:1"); 
             $data=array( 
               "field1"=>"ceiba", //一個key，對應一個值 
               "field2"=>"李開湧", 
               "field3"=>"李明", 
             ); 
             //支持批量添加 
             echo $Redis->type("hash")->add($data);        
    } 
     /** 
     * 集合類型 
     * Enter description here ... 
     */ 
    public function sets(){ 
             $Redis=new RedisModel("sets:1"); 
        //一次只能推送一條       
        echo $Redis->type("sets")->add("ceiba"); 
    } 
      /** 
     * 有序集合 
     * Enter description here ... 
     */ 
    public function zset(){  
        $Redis=new RedisModel("zset:1"); 
        //支持批量添加 
        $data=array( 
            //排序=>值 
            "10"=>"ceiba", 
            "11"=>"李開湧", 
            "12"=>"李明" 
        );       
        echo $Redis->type("zset")->add($data); 
    } 
} 
?>
<?php  
/**  
 * redis添加數據  
 * Enter description here ...  
 * @author Administrator  
 *  
 */  
class AddAction extends Action{  
    /**  
     * list類型  
     * Enter description here ...  
     */  
    public function lists(){  
        $Redis=new RedisModel("list11");  
        //一次只能推送一條        
        echo $Redis->add("ceiba");  
    }  
     /**  
     * 字符串類型  
     * Enter description here ...  
     */  
    public function string(){  
        $Redis=new RedisModel();  
        $data=array(  
            "str1"=>"ceiba", //一個key，對應一個值  
            "str2"=>"李開湧",  
            "str3"=>"李明",  
        );  
        echo $Redis->type("string")->add($data);  
    }  
    /**  
     * HASH類型  
     * Enter description here ...  
     */  
    public function hash(){  
        $Redis=new RedisModel("user:1");  
             $data=array(  
               "field1"=>"ceiba", //一個key，對應一個值  
               "field2"=>"李開湧",  
               "field3"=>"李明",  
             );  
             //支持批量添加  
             echo $Redis->type("hash")->add($data);         
    }  
     /**  
     * 集合類型  
     * Enter description here ...  
     */  
    public function sets(){  
             $Redis=new RedisModel("sets:1");  
        //一次只能推送一條        
        echo $Redis->type("sets")->add("ceiba");  
    }  
      /**  
     * 有序集合  
     * Enter description here ...  
     */  
    public function zset(){   
        $Redis=new RedisModel("zset:1");  
        //支持批量添加  
        $data=array(  
            //排序=>值  
            "10"=>"ceiba",  
            "11"=>"李開湧",  
            "12"=>"李明"  
        );        
        echo $Redis->type("zset")->add($data);  
    }  
}  
?>

二、查詢數據

<?php 
// redis查詢數據 
class IndexAction extends Action { 
    public function page(){ 
        $this->display(); 
    } 
    /** 
     * 列表類型，默認類型 
     * Enter description here ... 
     */ 
    public function lists(){ 
        //dump(C("REDIS_HOST"));  
        $Redis=new RedisModel("list1"); 
        $field=array( 
            "nmae","age","pro" 
        ); 
        $data=$Redis->field($field)->select(); 
        dump($data); 
        //得到隊列中的記錄總數 
        $count=$Redis->count(); 
        dump($count); 
    } 
    /** 
     * 字符串類型 
     * Enter description here ... 
     */ 
    public function string(){ 
            $Redis=new RedisModel(); 
            //field 表示每一個key名稱 
            $rows=$Redis->type("string")->field(array("str1","str2"))->select(); 
            dump($rows); 
    } 
    /** 
     * HASH類型 
     * Enter description here ... 
     */ 
    public function hash(){ 
            $Redis=new RedisModel("h9"); 
            //默認顯示全部HASH字段，能夠經過field連慣操做限制 
            $rows=$Redis->type("hash")->field(array("field1"))->select(); 
            dump($rows); 
            //統計總記錄 
            $count=$Redis->type("hash")->count(); 
            dump($count);        
    } 
    /** 
     * 集合類型 
     * Enter description here ... 
     */ 
    public function sets(){ 
            $Redis=new RedisModel(); 
            $arr=array( 
            "s3","s4" 
            ); 
       $rows=$Redis->type("sets")->field($arr)->where("sinterstore")->select();//求交集 
          dump($rows); 
          $rows=$Redis->type("sets")->field($arr)->where("sunion")->select();//求並集 
          dump($rows); 
          $rows=$Redis->type("sets")->field($arr)->where("sdiff")->select();//求差集 
          dump($rows); 
          $Redis=new RedisModel("s3"); 
          $rows=$Redis->type("sets")->select(); //返回單個集合列表中的全部成員 
          dump($rows); 
          //統計記錄 
          $Redis=new RedisModel("s3"); 
          $count=$Redis->type("sets")->count();  
          dump($count);      
    } 
    /** 
     * 有序集合 
     * Enter description here ... 
     */ 
    public function zset(){  
        $Redis=new RedisModel("z2");  
        //默認顯示0到20      
        $data=$Redis->type("zset")->limit("0,-1")->select(); 
        dump($data); 
        //使用zRevRange顯示數據，數組第2個參數爲true時顯示排序號 
         $data=$Redis->type("zset")->limit("0,-1")->order(array("zRevRange",true))->select(); 
        dump($data); 
        //不設置limit時，將統計全部記錄 
        $count=$Redis->type("zset")->limit("0,1")->count(); 
        dump($count); 

    } 
}
<?php  
// redis查詢數據  
class IndexAction extends Action {  
    public function page(){  
        $this->display();  
    }  
    /**  
     * 列表類型，默認類型  
     * Enter description here ...  
     */  
    public function lists(){  
        //dump(C("REDIS_HOST"));   
        $Redis=new RedisModel("list1");  
        $field=array(  
            "nmae","age","pro"  
        );  
        $data=$Redis->field($field)->select();  
        dump($data);  
        //得到隊列中的記錄總數  
        $count=$Redis->count();  
        dump($count);  
    }  
    /**  
     * 字符串類型  
     * Enter description here ...  
     */  
    public function string(){  
            $Redis=new RedisModel();  
            //field 表示每一個key名稱  
            $rows=$Redis->type("string")->field(array("str1","str2"))->select();  
            dump($rows);  
    }  
    /**  
     * HASH類型  
     * Enter description here ...  
     */  
    public function hash(){  
            $Redis=new RedisModel("h9");  
            //默認顯示全部HASH字段，能夠經過field連慣操做限制  
            $rows=$Redis->type("hash")->field(array("field1"))->select();  
            dump($rows);  
            //統計總記錄  
            $count=$Redis->type("hash")->count();  
            dump($count);         
    }  
    /**  
     * 集合類型  
     * Enter description here ...  
     */  
    public function sets(){  
            $Redis=new RedisModel();  
            $arr=array(  
            "s3","s4"  
            );  
       $rows=$Redis->type("sets")->field($arr)->where("sinterstore")->select();//求交集  
          dump($rows);  
          $rows=$Redis->type("sets")->field($arr)->where("sunion")->select();//求並集  
          dump($rows);  
          $rows=$Redis->type("sets")->field($arr)->where("sdiff")->select();//求差集  
          dump($rows);  
          $Redis=new RedisModel("s3");  
          $rows=$Redis->type("sets")->select(); //返回單個集合列表中的全部成員  
          dump($rows);  
          //統計記錄  
          $Redis=new RedisModel("s3");  
          $count=$Redis->type("sets")->count();   
          dump($count);       
    }  
    /**  
     * 有序集合  
     * Enter description here ...  
     */  
    public function zset(){   
        $Redis=new RedisModel("z2");   
        //默認顯示0到20       
        $data=$Redis->type("zset")->limit("0,-1")->select();  
        dump($data);  
        //使用zRevRange顯示數據，數組第2個參數爲true時顯示排序號  
         $data=$Redis->type("zset")->limit("0,-1")->order(array("zRevRange",true))->select();  
        dump($data);  
        //不設置limit時，將統計全部記錄  
        $count=$Redis->type("zset")->limit("0,1")->count();  
        dump($count);  

    }  
}

三、刪除數據

<?php 
/** 
* Redis刪除數據 
* Enter description here ... 
* @author Administrator 
* 
*/ 
class DeleteAction extends Action{ 
    /** 
     * list類型 
     * Enter description here ... 
     */ 
    public function lists(){ 
        $Redis=new RedisModel("mylist"); 
            //根據索引號，刪除指定的list元素          
        echo $Redis->where(3)->delete(); 
        //ltrim區間批量刪除，保留4~5之間的記錄 
echo $Redis->type("list")->where(array("4","5"))->delete("ltrim");  
        //lpop單條順序彈出     
echo $Redis->type("list")->delete("lpop");  

    } 
     /** 
     * 字符串類型 
     * Enter description here ... 
     */ 
    public function string(){ 
           $Redis=new RedisModel(); 
           //直接刪除key，這各方式適用於全部數據類型 
           echo $Redis->type("string")->field(array("str1","str2"))->delete(); 
    } 
    /** 
     * HASH類型 
     * Enter description here ... 
     */ 
    public function hash(){ 
        $Redis=new RedisModel("user:1");         
             //刪除指定hash中的指定字段(field),不支持批量刪除 
             echo $Redis->type("hash")->where("field1")->delete();  

    } 
     /** 
     * 集合類型 
     * Enter description here ... 
     */ 
    public function sets(){ 
             $Redis=new RedisModel("s1"); 
        //刪除sets:1集合中名爲age的value     
        echo $Redis->type("sets")->where("age")->delete(); 
    } 
    /** 
     * 有序集合 
     * Enter description here ... 
     */ 
    public function zset(){  
        $Redis=new RedisModel("z1"); 
        //根據集合元素value進行刪除 
        echo $Redis->type("zset")->where("two")->delete();  
        //根據排序號進行區間批量刪除，保留2~3之間的記錄 
        echo $Redis->type("zset")->where(array("1","4"))->delete("zremRangeByScore");  
        //根據索引號進行區間批量刪除，保留2~3之間的記錄 
        echo $Redis->type("zset")->where(array("1","3"))->delete("zRemRangeByRank");  
    } 
} 
?>
<?php  
/**  
 * Redis刪除數據  
 * Enter description here ...  
 * @author Administrator  
 *  
 */  
class DeleteAction extends Action{  
    /**  
     * list類型  
     * Enter description here ...  
     */  
    public function lists(){  
        $Redis=new RedisModel("mylist");  
            //根據索引號，刪除指定的list元素           
        echo $Redis->where(3)->delete();  
        //ltrim區間批量刪除，保留4~5之間的記錄  
echo $Redis->type("list")->where(array("4","5"))->delete("ltrim");   
        //lpop單條順序彈出      
echo $Redis->type("list")->delete("lpop");   

    }  
     /**  
     * 字符串類型  
     * Enter description here ...  
     */  
    public function string(){  
           $Redis=new RedisModel();  
           //直接刪除key，這各方式適用於全部數據類型  
           echo $Redis->type("string")->field(array("str1","str2"))->delete();  
    }  
    /**  
     * HASH類型  
     * Enter description here ...  
     */  
    public function hash(){  
        $Redis=new RedisModel("user:1");          
             //刪除指定hash中的指定字段(field),不支持批量刪除  
             echo $Redis->type("hash")->where("field1")->delete();   

    }  
     /**  
     * 集合類型  
     * Enter description here ...  
     */  
    public function sets(){  
             $Redis=new RedisModel("s1");  
        //刪除sets:1集合中名爲age的value      
        echo $Redis->type("sets")->where("age")->delete();  
    }  
    /**  
     * 有序集合  
     * Enter description here ...  
     */  
    public function zset(){   
        $Redis=new RedisModel("z1");  
        //根據集合元素value進行刪除  
        echo $Redis->type("zset")->where("two")->delete();   
        //根據排序號進行區間批量刪除，保留2~3之間的記錄  
        echo $Redis->type("zset")->where(array("1","4"))->delete("zremRangeByScore");   
        //根據索引號進行區間批量刪除，保留2~3之間的記錄  
        echo $Redis->type("zset")->where(array("1","3"))->delete("zRemRangeByRank");   
    }  
}  
?>

在Redis中，更新數據與添加數據是能夠相互轉換的，因此這裏再也不介紹。更多的功能特性及使用方法，隨着時間的推移，筆者會進行更新。本書讀者可在配套網站中獲得後續支持。thinkphp

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程