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数据库连接信息，如以下代码所示。

[html] view plaincopy
  1. 'REDIS_HOST'=>'192.168.0.2',
  2. 'REDIS_PORT'=>6379,
  3. 'REDIS_AUTH'=>123456,
  4. 'REDIS_DB_PREFIX'=>'',
[html] view plain copy
  1. 'REDIS_HOST'=>'192.168.0.2',
  2. 'REDIS_PORT'=>6379,
  3. 'REDIS_AUTH'=>123456,
  4. 'REDIS_DB_PREFIX'=>'',

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

1、增加数据

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

[html] view plaincopy
  1. <?php
  2. /**
  3. * redis添加数据
  4. * Enter description here ...
  5. * @author Administrator
  6. *
  7. */
  8. class AddAction extends Action{
  9. /**
  10. * list类型
  11. * Enter description here ...
  12. */
  13. public function lists(){
  14. $Redis=new RedisModel("list11");
  15. //一次只能推送一条
  16. echo $Redis->add("ceiba");
  17. }
  18. /**
  19. * 字符串类型
  20. * Enter description here ...
  21. */
  22. public function string(){
  23. $Redis=new RedisModel();
  24. $data=array(
  25. "str1"=>"ceiba", //一个key，对应一个值
  26. "str2"=>"李开湧",
  27. "str3"=>"李明",
  28. );
  29. echo $Redis->type("string")->add($data);
  30. }
  31. /**
  32. * HASH类型
  33. * Enter description here ...
  34. */
  35. public function hash(){
  36. $Redis=new RedisModel("user:1");
  37. $data=array(
  38. "field1"=>"ceiba", //一个key，对应一个值
  39. "field2"=>"李开湧",
  40. "field3"=>"李明",
  41. );
  42. //支持批量添加
  43. echo $Redis->type("hash")->add($data);
  44. }
  45. /**
  46. * 集合类型
  47. * Enter description here ...
  48. */
  49. public function sets(){
  50. $Redis=new RedisModel("sets:1");
  51. //一次只能推送一条
  52. echo $Redis->type("sets")->add("ceiba");
  53. }
  54. /**
  55. * 有序集合
  56. * Enter description here ...
  57. */
  58. public function zset(){
  59. $Redis=new RedisModel("zset:1");
  60. //支持批量添加
  61. $data=array(
  62. //排序=>值
  63. "10"=>"ceiba",
  64. "11"=>"李开湧",
  65. "12"=>"李明"
  66. );
  67. echo $Redis->type("zset")->add($data);
  68. }
  69. }
  70. ?>
[html] view plain copy
  1. <?php
  2. /**
  3. * redis添加数据
  4. * Enter description here ...
  5. * @author Administrator
  6. *
  7. */
  8. class AddAction extends Action{
  9. /**
  10. * list类型
  11. * Enter description here ...
  12. */
  13. public function lists(){
  14. $Redis=new RedisModel("list11");
  15. //一次只能推送一条
  16. echo $Redis->add("ceiba");
  17. }
  18. /**
  19. * 字符串类型
  20. * Enter description here ...
  21. */
  22. public function string(){
  23. $Redis=new RedisModel();
  24. $data=array(
  25. "str1"=>"ceiba", //一个key，对应一个值
  26. "str2"=>"李开湧",
  27. "str3"=>"李明",
  28. );
  29. echo $Redis->type("string")->add($data);
  30. }
  31. /**
  32. * HASH类型
  33. * Enter description here ...
  34. */
  35. public function hash(){
  36. $Redis=new RedisModel("user:1");
  37. $data=array(
  38. "field1"=>"ceiba", //一个key，对应一个值
  39. "field2"=>"李开湧",
  40. "field3"=>"李明",
  41. );
  42. //支持批量添加
  43. echo $Redis->type("hash")->add($data);
  44. }
  45. /**
  46. * 集合类型
  47. * Enter description here ...
  48. */
  49. public function sets(){
  50. $Redis=new RedisModel("sets:1");
  51. //一次只能推送一条
  52. echo $Redis->type("sets")->add("ceiba");
  53. }
  54. /**
  55. * 有序集合
  56. * Enter description here ...
  57. */
  58. public function zset(){
  59. $Redis=new RedisModel("zset:1");
  60. //支持批量添加
  61. $data=array(
  62. //排序=>值
  63. "10"=>"ceiba",
  64. "11"=>"李开湧",
  65. "12"=>"李明"
  66. );
  67. echo $Redis->type("zset")->add($data);
  68. }
  69. }
  70. ?>

2、查询数据

[html] view plaincopy
  1. <?php
  2. // redis查询数据
  3. class IndexAction extends Action {
  4. public function page(){
  5. $this->display();
  6. }
  7. /**
  8. * 列表类型，默认类型
  9. * Enter description here ...
  10. */
  11. public function lists(){
  12. //dump(C("REDIS_HOST"));
  13. $Redis=new RedisModel("list1");
  14. $field=array(
  15. "nmae","age","pro"
  16. );
  17. $data=$Redis->field($field)->select();
  18. dump($data);
  19. //获得队列中的记录总数
  20. $count=$Redis->count();
  21. dump($count);
  22. }
  23. /**
  24. * 字符串类型
  25. * Enter description here ...
  26. */
  27. public function string(){
  28. $Redis=new RedisModel();
  29. //field 表示每个key名称
  30. $rows=$Redis->type("string")->field(array("str1","str2"))->select();
  31. dump($rows);
  32. }
  33. /**
  34. * HASH类型
  35. * Enter description here ...
  36. */
  37. public function hash(){
  38. $Redis=new RedisModel("h9");
  39. //默认显示所有HASH字段，可以通过field连惯操作限制
  40. $rows=$Redis->type("hash")->field(array("field1"))->select();
  41. dump($rows);
  42. //统计总记录
  43. $count=$Redis->type("hash")->count();
  44. dump($count);
  45. }
  46. /**
  47. * 集合类型
  48. * Enter description here ...
  49. */
  50. public function sets(){
  51. $Redis=new RedisModel();
  52. $arr=array(
  53. "s3","s4"
  54. );
  55. $rows=$Redis->type("sets")->field($arr)->where("sinterstore")->select();//求交集
  56. dump($rows);
  57. $rows=$Redis->type("sets")->field($arr)->where("sunion")->select();//求并集
  58. dump($rows);
  59. $rows=$Redis->type("sets")->field($arr)->where("sdiff")->select();//求差集
  60. dump($rows);
  61. $Redis=new RedisModel("s3");
  62. $rows=$Redis->type("sets")->select(); //返回单个集合列表中的所有成员
  63. dump($rows);
  64. //统计记录
  65. $Redis=new RedisModel("s3");
  66. $count=$Redis->type("sets")->count();
  67. dump($count);
  68. }
  69. /**
  70. * 有序集合
  71. * Enter description here ...
  72. */
  73. public function zset(){
  74. $Redis=new RedisModel("z2");
  75. //默认显示0到20
  76. $data=$Redis->type("zset")->limit("0,-1")->select();
  77. dump($data);
  78. //使用zRevRange显示数据，数组第2个参数为true时显示排序号
  79. $data=$Redis->type("zset")->limit("0,-1")->order(array("zRevRange",true))->select();
  80. dump($data);
  81. //不设置limit时，将统计所有记录
  82. $count=$Redis->type("zset")->limit("0,1")->count();
  83. dump($count);
  84. }
  85. }
[html] view plain copy
  1. <?php
  2. // redis查询数据
  3. class IndexAction extends Action {
  4. public function page(){
  5. $this->display();
  6. }
  7. /**
  8. * 列表类型，默认类型
  9. * Enter description here ...
  10. */
  11. public function lists(){
  12. //dump(C("REDIS_HOST"));
  13. $Redis=new RedisModel("list1");
  14. $field=array(
  15. "nmae","age","pro"
  16. );
  17. $data=$Redis->field($field)->select();
  18. dump($data);
  19. //获得队列中的记录总数
  20. $count=$Redis->count();
  21. dump($count);
  22. }
  23. /**
  24. * 字符串类型
  25. * Enter description here ...
  26. */
  27. public function string(){
  28. $Redis=new RedisModel();
  29. //field 表示每个key名称
  30. $rows=$Redis->type("string")->field(array("str1","str2"))->select();
  31. dump($rows);
  32. }
  33. /**
  34. * HASH类型
  35. * Enter description here ...
  36. */
  37. public function hash(){
  38. $Redis=new RedisModel("h9");
  39. //默认显示所有HASH字段，可以通过field连惯操作限制
  40. $rows=$Redis->type("hash")->field(array("field1"))->select();
  41. dump($rows);
  42. //统计总记录
  43. $count=$Redis->type("hash")->count();
  44. dump($count);
  45. }
  46. /**
  47. * 集合类型
  48. * Enter description here ...
  49. */
  50. public function sets(){
  51. $Redis=new RedisModel();
  52. $arr=array(
  53. "s3","s4"
  54. );
  55. $rows=$Redis->type("sets")->field($arr)->where("sinterstore")->select();//求交集
  56. dump($rows);
  57. $rows=$Redis->type("sets")->field($arr)->where("sunion")->select();//求并集
  58. dump($rows);
  59. $rows=$Redis->type("sets")->field($arr)->where("sdiff")->select();//求差集
  60. dump($rows);
  61. $Redis=new RedisModel("s3");
  62. $rows=$Redis->type("sets")->select(); //返回单个集合列表中的所有成员
  63. dump($rows);
  64. //统计记录
  65. $Redis=new RedisModel("s3");
  66. $count=$Redis->type("sets")->count();
  67. dump($count);
  68. }
  69. /**
  70. * 有序集合
  71. * Enter description here ...
  72. */
  73. public function zset(){
  74. $Redis=new RedisModel("z2");
  75. //默认显示0到20
  76. $data=$Redis->type("zset")->limit("0,-1")->select();
  77. dump($data);
  78. //使用zRevRange显示数据，数组第2个参数为true时显示排序号
  79. $data=$Redis->type("zset")->limit("0,-1")->order(array("zRevRange",true))->select();
  80. dump($data);
  81. //不设置limit时，将统计所有记录
  82. $count=$Redis->type("zset")->limit("0,1")->count();
  83. dump($count);
  84. }
  85. }

3、删除数据

[html] view plaincopy
  1. <?php
  2. /**
  3. * Redis删除数据
  4. * Enter description here ...
  5. * @author Administrator
  6. *
  7. */
  8. class DeleteAction extends Action{
  9. /**
  10. * list类型
  11. * Enter description here ...
  12. */
  13. public function lists(){
  14. $Redis=new RedisModel("mylist");
  15. //根据索引号，删除指定的list元素
  16. echo $Redis->where(3)->delete();
  17. //ltrim区间批量删除，保留4~5之间的记录
  18. echo $Redis->type("list")->where(array("4","5"))->delete("ltrim");
  19. //lpop单条顺序弹出
  20. echo $Redis->type("list")->delete("lpop");
  21. }
  22. /**
  23. * 字符串类型
  24. * Enter description here ...
  25. */
  26. public function string(){
  27. $Redis=new RedisModel();
  28. //直接删除key，这各方式适用于所有数据类型
  29. echo $Redis->type("string")->field(array("str1","str2"))->delete();
  30. }
  31. /**
  32. * HASH类型
  33. * Enter description here ...
  34. */
  35. public function hash(){
  36. $Redis=new RedisModel("user:1");
  37. //删除指定hash中的指定字段(field),不支持批量删除
  38. echo $Redis->type("hash")->where("field1")->delete();
  39. }
  40. /**
  41. * 集合类型
  42. * Enter description here ...
  43. */
  44. public function sets(){
  45. $Redis=new RedisModel("s1");
  46. //删除sets:1集合中名为age的value
  47. echo $Redis->type("sets")->where("age")->delete();
  48. }
  49. /**
  50. * 有序集合
  51. * Enter description here ...
  52. */
  53. public function zset(){
  54. $Redis=new RedisModel("z1");
  55. //根据集合元素value进行删除
  56. echo $Redis->type("zset")->where("two")->delete();
  57. //根据排序号进行区间批量删除，保留2~3之间的记录
  58. echo $Redis->type("zset")->where(array("1","4"))->delete("zremRangeByScore");
  59. //根据索引号进行区间批量删除，保留2~3之间的记录
  60. echo $Redis->type("zset")->where(array("1","3"))->delete("zRemRangeByRank");
  61. }
  62. }
  63. ?>
[html] view plain copy
  1. <?php
  2. /**
  3. * Redis删除数据
  4. * Enter description here ...
  5. * @author Administrator
  6. *
  7. */
  8. class DeleteAction extends Action{
  9. /**
  10. * list类型
  11. * Enter description here ...
  12. */
  13. public function lists(){
  14. $Redis=new RedisModel("mylist");
  15. //根据索引号，删除指定的list元素
  16. echo $Redis->where(3)->delete();
  17. //ltrim区间批量删除，保留4~5之间的记录
  18. echo $Redis->type("list")->where(array("4","5"))->delete("ltrim");
  19. //lpop单条顺序弹出
  20. echo $Redis->type("list")->delete("lpop");
  21. }
  22. /**
  23. * 字符串类型
  24. * Enter description here ...
  25. */
  26. public function string(){
  27. $Redis=new RedisModel();
  28. //直接删除key，这各方式适用于所有数据类型
  29. echo $Redis->type("string")->field(array("str1","str2"))->delete();
  30. }
  31. /**
  32. * HASH类型
  33. * Enter description here ...
  34. */
  35. public function hash(){
  36. $Redis=new RedisModel("user:1");
  37. //删除指定hash中的指定字段(field),不支持批量删除
  38. echo $Redis->type("hash")->where("field1")->delete();
  39. }
  40. /**
  41. * 集合类型
  42. * Enter description here ...
  43. */
  44. public function sets(){
  45. $Redis=new RedisModel("s1");
  46. //删除sets:1集合中名为age的value
  47. echo $Redis->type("sets")->where("age")->delete();
  48. }
  49. /**
  50. * 有序集合
  51. * Enter description here ...
  52. */
  53. public function zset(){
  54. $Redis=new RedisModel("z1");
  55. //根据集合元素value进行删除
  56. echo $Redis->type("zset")->where("two")->delete();
  57. //根据排序号进行区间批量删除，保留2~3之间的记录
  58. echo $Redis->type("zset")->where(array("1","4"))->delete("zremRangeByScore");
  59. //根据索引号进行区间批量删除，保留2~3之间的记录
  60. echo $Redis->type("zset")->where(array("1","3"))->delete("zRemRangeByRank");
  61. }
  62. }
  63. ?>

thinkphp 通过Redis实现增删改查操作相关推荐

  1. thinkphp连mysql增删改查_ThinkPHP5.1框架数据库链接和增删改查操作示例

    本文实例讲述了ThinkPHP5.1框架数据库链接和增删改查操作.分享给大家供大家参考,具体如 本文实例讲述了ThinkPHP5.1框架数据库链接和增删改查操作.分享给大家供大家参考,具体如下: 一. ...

  2. 【接口测试】Day5-使用pymysql库对mysql数据库进行增删改查操作

    目录 今日目标 一.数据库介绍 二.数据库基本操作 1.安装 2.操作流程(重点) 1. 创建连接 2. 获取游标 3. 执行sql 4. 关闭游标 5. 关闭连接 3.数据准备 4.数据库基本操作 ...

  3. Go使用Gin+Redis实现增删改查

    Go使用Gin+Redis实现增删改查 0.前置知识 Go中的struct. Redis.Gin框架. Web基础. 1.架构 使用Redis作为数据库,Gin作为Web框架. 2.功能模块 1.自定 ...

  4. python增删改查的框架_简单的Django框架增删改查操作

    Django之orm对MysqL数据库的增删改查操作简介: 利用Django中orm来查找数据库中的数据,对数据库进行增.删.改.查: 增:新增数据 # 操作数据库user表新增记录 # 方式1: u ...

  5. python操作mysql的增删改查_详解使用pymysql在python中对mysql的增删改查操作(综合)...

    这一次将使用pymysql来进行一次对MySQL的增删改查的全部操作,相当于对前五次的总结: 先查阅数据库: 现在编写源码进行增删改查操作,源码为: #!/usr/bin/python #coding ...

  6. 学生信息管理系统（连接数据库，面向对象的方法实现学生信息的增删改查操作）...

    ---------------------------------------------------------------------------------------------------- ...

  7. 后盾网lavarel视频项目---lavarel使用模型进行增删改查操作

    后盾网lavarel视频项目---lavarel使用模型进行增删改查操作 一.总结 一句话总结: 使用模型操作常用方法 查一条:$model=Tag::find($id); 删一条:Tag::dest ...

  8. java调用oracle删除,使用IDEA对Oracle数据库进行简单增删改查操作

    1.1 java中的数据存储技术 在java中,数据库存取技术可分为如下几类: 1.jdbc直接访问数据库 2.jdo(java data object)是java对象持久化的新的规范,也是一个用于存 ...

  9. 使用JDBC，完成对如下表的增删改查操作

    使用JDBC,完成对如下表的增删改查操作 增加操作 使用循环和随机数技巧,增加1000个数据.要求积分在0-200,注册时间均匀分布在2018年各个月份.从26个字母中随机取出3个字母作为昵称,昵称不 ...

  10. sqlite数据库的基本增删改查操作

    2019独角兽企业重金招聘Python工程师标准>>> 效果图示例 1.在清单里添加相应的权限 <uses-permission android:name="andr ...

最新文章

  1. ALTER AVAILABILITY GROUP (Transact-SQL)
  2. JVM中GC小对象配置
  3. non-overlapping-intervals
  4. 什么时候使用resulttype_ResultMap和ResultType在使用中的区别
  5. 单页面应用的路由问题
  6. 微机原理-8086CPU
  7. 安装企业微信和微信-ubuntu
  8. 混淆矩阵 Confusion Matrix
  9. 攻防世界web练习区
  10. word如何拆分表格
  11. 升级合作伙伴计划，实现全面赋能
  12. 快手官宣全员开启大小周？996、997，网友：「国产式加班」花样真多！
  13. Java实验6 接口、异常处理、注解与反射答案
  14. Google Maps Api Geocoding 传递参数和返回参数的解析（Json）
  15. 使用全局变量有什么好处?有什么坏处?_徒手深蹲的好处和坏处是什么，空中健身告诉你...
  16. share mouse键盘不能在再另一个屏幕使用
  17. 尋找《案件取证操作教程EnCase》.ppt。
  18. 新能源汽车里程宣传有夸大之嫌
  19. 计算机适合女生的岗位 就业方向有什么
  20. UWB定位基站电路保护方案

热门文章

  1. ios android 系统字体,ios、android 系统字体说明
  2. php的redis安装配置,Redis 的安装配置介绍_php
  3. UEFI开发探索31–鼠标GUI构建
  4. 在Windows server 2019 Core 版本上安装SQL2016
  5. ibm的服务器怎么重装系统,ibm服务器系统安装的具体教程
  6. 用java进行安卓开发的步骤_如何在windows下Android开发IDE搭建步骤
  7. Python 装逼手机号码方法 低配版 map方法解析
  8. C语言例题-打印日历
  9. 电机学感应电动机重点知识总结（现有题目中反映的）
  10. 27_iOS干货19之网络4_在线http/https素材资源