thinkPHP框架通过Redis实现增删改查操作的方法详解

2020-10-21 10:00:06 浏览数 (1)

本文实例讲述了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数据库连接信息,如以下代码所示。

代码语言:javascript复制
'REDIS_HOST'= '192.168.0.2',
'REDIS_PORT'= 6379,
'REDIS_AUTH'= 123456,
'REDIS_DB_PREFIX'= '',

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

1、增加数据

这里的增加数据包括Redis五大数据类型的数据添加。由于篇幅所限,这里不再详细介绍操作的实现原理,将通过代码演示操作方式。如以下代码所示。

代码语言:javascript复制
<?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);
  }
}
? 

2、查询数据

代码语言:javascript复制
<?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);
  }
}

3、删除数据

代码语言:javascript复制
<?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");
  }
}
? 

0 人点赞