您现在的位置是:门户> 编程语言> PHP

thinkPHP框架通过Redis实现增删改查操作的方法详解
2020-06-01 41人围观 0条评论
简介这篇文章主要介绍了thinkPHP框架通过Redis实现增删改查操作的方法,结合实例形式较为详细的分析了thinkPHP框架针对redis数据库的配置、连接及CURD操作相关实现技巧,需要的朋友可以参考下

    本文实例讲述了thinkPHP框架通过Redis实现增删改查操作的方法。分享给大家供大家参考,具体如下:

    一、概述

    Redis是一个NoSQL数据库,由于其数据类型的差异,所以要在MVC框架中实现CURD操作,比较繁锁。事实上在ThinkPHP框架中,只能实现简单的缓存应用。而不像MongoDB那样能够实现常见数据库的CURD操作。本文章将通过扩展的方式,实现Redis的CURD操作,这样我们就可以像操作普通的Mysql数据库那样实现Redis的编程了。

    二、实现过程

    接下为将以ThinkPHP作为MVC开发框架,详细介绍Redis的CURD操作。需要说明的是,在ThinkPHP中本身并不支持Redis开发环境,只支持使用Redis开发简单的数据缓存功能。所以我们必须要通过扩展功能,实现Redis的编程支持。为了方便读者学习,笔者临时开发了相应的模块扩展及数据库扩展。

    解压下载后的压缩包,将得到DbRedis.class.php文件及RedisModel.class.php文件。将DbRedis.class.php文件复制到ThinkPHP/Extend/Driver/Db目录;将RedisModel.class.php文件复制到ThinkPHP/Extend/Model目录。然后在项目配置文件中加入Redis数据库连接信息,如以下代码所示。

    'REDIS_HOST'=>'192.168.0.2',
    'REDIS_PORT'=>6379,
    'REDIS_AUTH'=>123456,
    'REDIS_DB_PREFIX'=>'',
    
    

    读者可根据实际环境填写即可。通过前面步骤,至此就完成了在ThinkPHP中进行Redis开发的前期准备,接下来将结合示例代码,详细演示Redis的CURD操作。

    1、增加数据

    这里的增加数据包括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);
      }
    }
    ?>
    
    

    2、查询数据

    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);
      }
    }
    
    

    3、删除数据

    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");
      }
    }
    ?>
    
    

    更多关于thinkPHP相关内容感兴趣的读者可查看本站专题:《ThinkPHP入门教程》、《thinkPHP模板操作技巧总结》、《ThinkPHP常用方法总结》、《codeigniter入门教程》、《CI(CodeIgniter)框架进阶教程》、《Zend FrameWork框架入门教程》及《PHP模板技术总结》。

    希望本文所述对大家基于ThinkPHP框架的PHP程序设计有所帮助。

分享:

文章评论