PHP8.1.21版本已发布
vue8.1.21版本已发布
jquery8.1.21版本已发布
首页
课程
路径
文章
PHP培训
精品课
下载
最新更新

博客列表 > PHP MySQLi/接口与多态------PHP培训十期线上班 学号：510251 02月11日作业

PHP MySQLi/接口与多态------PHP培训十期线上班 学号：510251 02月11日作业

赵大叔
赵大叔 原创
2020年03月03日 06:57:58 1218浏览

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常用类/属性/方法

上一条： 0225 Js数据类型 下一条： 0224 JS变量声明与访问及作用域流程控制
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多
热门课程