微信公众号 讲师中心
首页
文章
web3.0 后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 UI设计 计算机基础
编程手册
大前端 JavaScript 后端开发 数据库 移动端 运维开发 UI设计 计算机基础 XML Web Services
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机/移动开发 手机游戏
最近更新
搜索
web3.0 后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程
游戏教程 自媒体 新闻
首页 > 博客列表 > PHP MySQLi/接口与多态------PHP培训十期线上班 学号：510251 02月11日作业
博主信息
博文 119
粉丝 3
评论 1
访问量 121225
专题推荐
更多>
相关推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
PHP MySQLi/接口与多态------PHP培训十期线上班 学号：510251 02月11日作业
赵大叔
原创
1430人浏览过

MySQLi/接口与多态

1、MySQLi常见的CURD操作

1.1 新增

  1. <?php
  3. namespace chapter2;
  4. use mysqli;
  5. //MySQLi 面向对象方式操作数据库
  7. //新增操作
  8. //1、连接数据库
  9. //mysqli(主机名，用户名，密码，默认数据库);
  10. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  12. //2、执行SQL语句查询
  14. //准备SQL语句
  15. $sql = 'INSERT `users` SET `name` = ?, `email` = ?, `password` = ?, `register_time` = ?';
  16. //作用预处理方式，防止SQL攻击
  17. //初始化一个预处理对象
  18. $stmt = $mysqli -> stmt_init();
  20. //创建sql语句预处理对象
  21. $stmt ->prepare($sql);
  22.  //绑定变量参数
  23. $user = ['张三丰', 'zhangsanfeng@163.cn', sha1('123456'), time()];
  24. list($name, $email, $password, $register_time) = $user;
  25. $stmt -> bind_param('sssi', $name, $email, $password, $register_time);
  27. //执行
  28. $stmt -> execute();
  30. //3、处理执行有结果
  31. if ($stmt->affected_rows === 1) {
  32.    echo '添加成功,新记录主键id：' .$stmt -> insert_id ;
  33. }else {
  34.     echo '更新失败' .$stmt -> error;
  35.     }
  38. //4、关闭操作
  40. //关闭数据库连接
  41. $stmt -> close();

代码执行效果：

1.2 更新

这里只上传关键代码。

  1. //2、执行SQL语句操作
  2. //2.1 准备sql语句
  3. $sql = 'UPDATE `users` SET `name`= ?, `email` = ? WHERE `id` = ?';
  5. //初始化一个预处理对象
  6. $stmt = $mysqli -> stmt_init();
  8. //创建一个SQL预处理对象
  9. $stmt -> prepare($sql);
  11. //绑定变量参数
  12. $user = ['张无忌', 'wuji@163.com', 9];
  13. list($name, $email, $id) = $user;
  14. $stmt -> bind_param('ssi', $name, $email, $id);
  16. //执行
  17. $stmt -> execute();
  19. //3、处理执行结果
  20. if ($stmt->affected_rows === 1) :
  21.     echo '更新成功';
  22. else :
  23.     echo '更新失败' . $stmt->error;
  24. endif;

代码执行效果：

1.3 删除

  1. //2、
  2. $sql = 'DELETE FROM `users` WHERE `id` = ?';
  5. $stmt = $mysqli -> stmt_init();
  6. $stmt -> prepare($sql);
  9. $id = 9;
  10. $stmt -> bind_param('i', $id);
  14. $stmt -> execute();
  18. //3、
  19. if($stmt -> affected_rows === 1){
  20.     echo '删除成功。';
  21. }else{
  22.     echo '删除失败。';
  23. }

代码执行效果：

1.4 查询

  1. //2、
  2. $sql = 'SELECT `id`, `name`, `email` FROM `users` WHERE `id` > ?;';
  5. $stmt = $mysqli ->stmt_init();
  6. $stmt ->prepare($sql);
  8. $id = 2;
  9. $stmt ->bind_param('i', $id);
  10. $stmt ->execute();
  13. //3、
  14. $stmt->bind_result($id, $name, $email);
  16. while ($stmt ->fetch()) {
  17.     echo "$id : $name --->$email <br>";
  18. }
  21. //4、
  22. //释放结果集
  23. $stmt -> free_result();
  24. $stmt -> close();

代码执行效果：

2、面向接口实现多态操作数据库

2.1 配置数据库连接参数和声明主要接口

  1. <?php
  2. // 接口实战：使用PDO/MySQLi实现数据库的多想操作
  4. namespace chapter2;
  6. //配置数据库的连接参数
  7. interface iDbParam
  8. {
  9.     const HOST = 'localhost';
  10.     const TYPE = 'mysql';
  11.     const DBNAME = 'phpedu';
  12.     const USER_NAME = 'root';
  13.     const PASSWORD = 'root';
  14.     const CHARSET = 'utf8';
  15.     const PORT = '3306';
  16. }
  18. //接口构造方法
  19. //接口构造方法
  20. interface iDblink
  21. {
  22.     //接口允许的构造方法
  23.     public function __construct(...$linkParams);
  24. }
  26. //接口方法：后面的代码就是用下面的这个主接口
  27. //接口之间允许继承，而且允许多重继承
  28. interface iCURD extends iDbParam,iDblink
  29. {
  30.     //新增
  31.     public function insert (array $data);
  33.     //查询
  34.     public function select (string $where = '');
  36.     //更新
  37.     public function update (array $data, string $where);
  39.     //删除
  40.     public function delete (string $where);
  42. }

2.2 PDO来实现数据操作（实现接口方法）

  1. <?php
  2. namespace chapter2;
  4. //用PDO来实现数据操作
  5. use PDO;
  7. //加载iCURD 的接口声明
  8. require 'demo7.php';
  10. class Db_PDO implements iCURD
  11. {
  12.     //连接对象
  13.     private $pdo = null;
  15.     //实现接口构造方法：连接数据库
  16.     public function __construct(...$linkParams)
  17.     {
  18.         list($dsn, $username, $password) = $linkParams;
  19.         $this -> pdo = new PDO ($dsn, $username, $password);
  20.     }
  22.     //新增
  23.     public function insert (array $data)
  24.     {
  25.         $sql = "INSERT `users` SET `name` = ?, `email` = ?, `password` = ?, `register_time` = ?";
  26.         $stmt = $this -> pdo ->prepare($sql);
  27.         $stmt -> execute($data);
  28.         return $stmt -> rowCount() === 1 ? '新增成功。' : '新增失败。';
  29.     }
  31.     //查询
  32.     public function select (string $where = '')
  33.     {
  34.         $where = empty($where) ? $where : 'WHERE' .$where;
  35.         $sql = "SELECE * FROM `user` {$where}";
  36.         $stmt = $this -> pdo -> prepare($sql);
  37.         $stmt -> execute();
  38.         return $stmt -> fetchALL(PDO::FETCH_ASSOC);
  39.     }
  41.     //更新
  42.     public function update (array $data, string $where)
  43.     {
  44.         //设置更新参数
  45.         $params = '';
  46.         foreach ($data as $key => $value) {
  47.             $params .= "`{$key}` = `{$value}`, ";
  48.         }
  49.         //将最后的“,”去掉
  50.         $params = rtrim($params, ', ');
  52.         //执行更新
  53.         $sql = "UPDATE `users` SET {$params} WHERE {$where}";
  54.         $stmt = $this -> pdo -> prepare($sql);
  55.         $stmt -> execute;
  56.         return $stmt -> rowCount() === 1 ? '更新成功' : '更新失败';
  57.     }
  59.     //删除
  60.     public function delete (string $where)
  61.     {
  62.         $sql = "DELETE FROM `users` WHERE {$where}";
  63.         $stmt = $this -> pdo -> prepare($sql);
  64.         $stmt -> execute();
  65.         return $stmt -> rowCount() === 1 ? '删除成功' : '删除失败';
  66.     }
  68. }

2.3 MySQLi来实现数据操作（实现接口方法）

  1. <?php
  2. namespace chapter2;
  4. //用MySQLi来实现数据操作
  5. use MySQLi;
  7. //加载iCURD 的接口声明
  8. require 'demo7.php';
  10. class Db_MySQLi implements iCURD
  11. {
  12.     //连接对象
  13.     private $mysqli = null;
  15.     //实现接口构造方法：连接数据库
  16.     public function __construct(...$linkParams)
  17.     {
  18.         list($host, $username, $password, $dbname) = $linkParams;
  19.         $this -> mysqli = new mysqli ($host, $username, $password, $dbname);
  21.         // 设置默认字符集
  22.         $this -> mysqli -> set_charset('utf8');
  23.     }
  25.     //新增
  26.     public function insert (array $data)
  27.     {
  28.         $sql = "INSERT `users` SET `name` = ?, `email` = ?, `password` = ?, `register_time` = ?";
  29.         $stmt = $this -> mysqli ->prepare($sql);
  30.         $stmt -> bind_param('sssi', $name, $email, $password, $register_time);
  31.         list($name, $email, $password, $register_time) = $data;
  32.         $stmt -> execute();
  33.         return $stmt -> affected_rows === 1 ? '新增成功。' : '新增失败。';
  34.     }
  36.     //查询
  37.     public function select (string $where = '')
  38.     {
  39.         $where = empty($where) ? $where : 'WHERE' .$where;
  40.         $sql = "SELECE * FROM `user` {$where}";
  41.         $stmt = $this -> mysqli -> prepare($sql);
  42.         $stmt -> execute();
  43.         return $stmt -> get_result();
  44.     }
  46.     //更新
  47.     public function update (array $data, string $where)
  48.     {
  49.         //设置更新参数
  50.         $params = '';
  51.         foreach ($data as $key => $value) {
  52.             $params .= "`{$key}` = `{$value}`, ";
  53.         }
  54.         //将最后的“,”去掉
  55.         $params = rtrim($params, ', ');
  57.         //执行更新
  58.         $sql = "UPDATE `users` SET {$params} WHERE {$where}";
  59.         $stmt = $this -> mysqli -> prepare($sql);
  60.         $stmt -> execute();
  61.         return $stmt -> affected_rows === 1 ? '更新成功' : '更新失败';
  62.     }
  64.     //删除
  65.     public function felete (string $where)
  66.     {
  67.         $sql = "DELETE FROM `users` WHERE {$where}";
  68.         $stmt = $this -> mysqli -> prepare($sql);
  69.         $stmt -> execute();
  70.         return $stmt -> affected_row === 1 ? '删除成功' : '删除失败';
  71.     }
  73. }

2.4 通用类:面向接口实现多态，动态支持PDO/MySQLi

  1. <?php
  3. namespace chapter2;
  5. //通用类：数据库操作，面向接口实现多态，动态支持PDO/MySQLi
  7. use chapter2\iCURD;
  9. class DB
  10. {
  11.     //新增
  12.     public static function insert(iCURD $db, array $data)
  13.     {
  14.         return $db->insert($data);
  15.     }
  17.     //查询
  18.     public static function select(iCURD $db, string $where = '')
  19.     {
  20.         return $db->select($where);
  21.     }
  23.     //更新
  24.     public static function update(iCURD $db, array $data, string $where = '')
  25.     {
  26.         return $db->update($data, $where);
  27.     }
  29.     //删除
  30.     public static function delete(iCURD $db, string $where = '')
  31.     {
  32.         return $db->delete($where);
  33.     }
  34. }

2.5 演示PDO操作

  1. <?php
  3. namespace chapter2;
  5. //使用PDO来操作数据库，接口实现
  7. //加载PDO操作类：Db_PDO
  8. require 'demo8.php';
  10. //加载数据库通用类
  11. require 'demo10.php';
  13. //创建DSN
  14. $dsn = iDbParam::TYPE .':host=' .iDbParam::HOST .';dbname=' .iDbParam::DBNAME .';charset=' .iDbParam::CHARSET;
  16. //die($dsn);
  17. $link = new Db_PDO($dsn, iDbParam::USER_NAME, iDbParam::PASSWORD);
  19. //测试新增
  20. //echo DB::insert($link, ['guojue', 'guojue@163.cm', sha1('123456'), time()]);
  22. //查询
  23. //foreach (DB::select($link, 'id > 2') as $user){
  24. //    echo "{$user['id']} --- {$user['name']} --- {$user['email']} <br>";
  25. //}
  27. //更新
  28. //echo DB::update($link, ['name'=>'赵大叔', 'email'=>'dashuzhao@php.cn'], 'id= 11');
  30. //删除
  31. echo DB::delete($link, 'id = 10');

代码执行效果：






2.6 演示MySQLi操作

  1. <?php
  4. namespace chapter2;
  6. //使用MySQLi来操作数据库，接口实现
  8. //加载MySQLi操作类：Db_MySQLi
  9. require 'demo9.php';
  11. //加载数据库通用类
  12. require 'demo10.php';
  15. //die($dsn);
  16. $link = new Db_MySQLi(iDbParam::HOST, iDbParam::USER_NAME, iDbParam::PASSWORD, iDbParam::DBNAME);
  18. //测试新增
  19. //echo DB::insert($link, ['linmeimei', 'linmeimei@php.cn', sha1('123456'), time()]);
  21. //查询
  22. //foreach (DB::select($link, 'id > 2') as $user){
  23. //    echo "{$user['id']} --- {$user['name']} --- {$user['email']} <br>";
  24. //}
  26. //更新
  27. //echo DB::update($link, ['name'=>'赵大叔', 'email'=>'dashuzhao@php.cn'], 'id= 13');
  29. //删除
  30. echo DB::delete($link, 'id = 12');

代码执行效果：






3、MySQLi常用类/属性/方法

批改老师：天蓬老师天蓬老师

批改状态：合格

老师批语：这个作业写得相当出色, 代码规范, 注释简洁, 总结也很棒
本博文版权归博主所有，转载请注明地址！如有侵权、违法，请联系admin@php.cn举报处理！
全部评论 文明上网理性发言，请遵守新闻评论服务协议
0条评论
作者最新博文
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新 English
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • PHP学习

  • 技术支持

  • 返回顶部
    • 登录PHP中文网，和优秀的人一起学习！
    全站2000+教程免费学
    微信扫码登录