search

博客列表 >MySQLi常见CURD操作和接口实战（0211）

MySQLi常见CURD操作和接口实战（0211）

暴风战斧
暴风战斧原创
2020年02月20日 17:22:121037浏览

编程思路

MySQLi常见CURD操作直观好理解，直接写代码；接口实现数据库操作理解的时候容易理解错，多看了几遍视频看课件注释帮助理解最后写代码。

作业总结

接口实战编程完后，测试时遇到蛮多报错，都是自己小失误造成的，比如查询的’WHERE’没有敲空格，导致SQL语句不生效，’ WHERE ‘，这样才对：

  1. // 查询
  2.     public function select(string $where = '')
  3.     {
  4.         $where = empty($where) ? $where : 'WHERE' . $where;
  5.         $sql = "SELECT * FROM `users` {$where}";
  6.         $stmt = $this->pdo->prepare($sql);
  7.         $stmt->execute();
  8.         return $stmt->fetchAll(PDO::FETCH_ASSOC);
  9.     }

慢慢改，最后解决了。为了辅助自己理解记忆整理了下他们的关系：

1、手写作业

2、MySQLi常见CURD操作

  • 新增操作
  1. <?php
  3. namespace chapter02;
  5. use mysqli;
  7. //一、新增操作
  9. //1.连接数据库
  10. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  12. //2.执行SQL查询
  13. //准备sql语句
  14. $sql = 'INSERT `users` SET `name`=?, `email`=?, `password`=?, `register_time`=?;';
  15. //使用预处理方式防止sql注入攻击
  16. $stmt = $mysqli->stmt_init();
  17. //创建sql语句对象
  18. $stmt->prepare($sql);
  19. //绑定变量参数
  20. $user = ['admin', 'admin@php.cn', sha1('123456'), time()];
  21. list($name, $email, $password, $register_time) = $user;
  22. $stmt->bind_param('sssi', $name, $email, $password, $register_time);
  23. //执行
  24. $stmt->execute();
  26. //3.处理执行的结果
  27. if ($stmt->affected_rows === 1) :
  28.     echo '添加成功，新记录的主键id：' . $stmt->insert_id;
  29. else :
  30.     echo '添加失败' . $stmt->error;
  31. endif;
  33. //4.结束操作
  34. //关闭数据库连接
  35. $stmt->close();

  • 更新操作
  1. <?php
  3. namespace chapter02;
  5. use mysqli;
  7. //二、更新操作
  9. //1.连接数据库
  10. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  12. //2.执行sql查询
  13. //准备sql语句
  14. $sql = 'UPDATE `users` SET `name`=?, `email`=? WHERE `id`=?;';
  15. //使用预处理方式防止sql注入攻击
  16. $stmt = $mysqli->stmt_init();
  17. //创建sql语句对象
  18. $stmt->prepare($sql);
  20. //绑定参数变量
  21. $user = ['jack', 'jack@php.cn', '8'];
  22. list($name, $email, $id) = $user;
  23. $stmt->bind_param('ssi', $name, $email, $id);
  24. //执行
  25. $stmt->execute();
  27. //3.处理执行的结果
  28. if ($stmt->affected_rows === 1 ) :
  29.     echo '更新成功';
  30. else :
  31.     echo '更新失败';
  32. endif;
  34. //4.结束操作
  35. //关闭数据库
  36. $stmt->close();

  • 删除操作
  1. <?php
  3. namespace chapter02;
  5. use mysqli;
  7. //三、删除操作
  9. //1.连接数据库
  10. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  12. //2.执行sql查询
  13. //准备sql语句
  14. $sql = 'DELETE FROM `users` WHERE `id`=?;';
  15. //使用预处理方式防止sql注入攻击
  16. $stmt = $mysqli->stmt_init();
  17. //创建sql语句对象
  18. $stmt->prepare($sql);
  20. //绑定参数变量
  21. $id = '8';
  22. $stmt->bind_param('i', $id);
  23. //执行
  24. $stmt->execute();
  26. //3.处理执行结果
  27. if ($stmt->affected_rows === 1) :
  28.     echo '删除成功';
  29. else :
  30.     echo '删除失败';
  31. endif;
  33. //4.结束操作
  34. //关闭数据库连接
  35. $stmt->close();

  • 查询操作
  1. <?php
  2. namespace chapter02;
  3. use mysqli;
  4. //四、查询操作—使用STMT对象
  6. //1.连接数据库
  7. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  9. //2.执行SQL查询
  10. //准备sql语句
  11. $sql = 'SELECT `id`,`name`,`email` FROM `users` WHERE `id`>?;';
  12. //使用预处理方式防止sql注入攻击
  13. $stmt = $mysqli->stmt_init();
  14. //创建sql语句对象
  15. $stmt->prepare($sql);
  16. //绑定变量参数
  17. $id = 3;
  18. $stmt->bind_param('i', $id);
  19. //执行
  20. $stmt->execute();
  22. //3.处理执行的结果
  23. //将结果集中的字段/列，绑定到指定的变量上
  24. $stmt->bind_result($id, $name, $email);
  25. //遍历结果集
  26. while ($stmt->fetch()) {
  27.     echo "$id : $name ---> $email <br>";
  28. }
  30. //4.结束操作
  31. //释放结果集
  32. $stmt->free_result();
  33. //关闭数据库连接
  34. $stmt->close();

  1. <?php
  2. namespace chapter02;
  3. use mysqli;
  4. //四、查询操作—使用结果集对象
  6. //1.连接数据库
  7. $mysqli = new mysqli('localhost', 'root', 'root', 'phpedu');
  9. //2.执行SQL查询
  10. //准备sql语句
  11. $sql = 'SELECT `id`,`name`,`email` FROM `users` WHERE `id`>?;';
  12. //使用预处理方式防止sql注入攻击
  13. $stmt = $mysqli->stmt_init();
  14. //创建sql语句对象
  15. $stmt->prepare($sql);
  16. //绑定变量参数
  17. $id = 3;
  18. $stmt->bind_param('i', $id);
  19. //执行
  20. $stmt->execute();
  22. //获取到结果集对象
  23. $result = $stmt->get_result();
  25. //3.处理执行的结果
  26. //获取记录，返回关联数组
  27. while ($user = $result->fetch_assoc()) {
  28.     echo "{$user['id']} : {$user['name']} ==> {$user['email']} <br>";
  29. }
  30. echo '<hr>';
  31. //数据表指针复位
  32. $result->data_seek(0);
  34. //一次性的获取所有数据
  35. $users = $result->fetch_all(MYSQLI_ASSOC);
  36. foreach ($users as $user) {
  37.     echo "{$user['id']} : {$user['name']} ==> {$user['email']} <br>";
  38. }
  40. //4.结束操作
  41. //释放结果集
  42. $stmt->free_result();
  43. //关闭数据库连接
  44. $stmt->close();

3.接口实战

  • 3.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. interface iDbLink
  20. {
  21.     // 接口中允许构造方法
  22.     public function __construct(...$linkParams);
  23. }
  25. // 接口方法: 后面的代码就是用下面的这个主接口
  26. // 接口之间允许继承, 而且允许多重继承
  27. interface iCURD extends iDbLink, iDbParam
  28. {
  29.     // 新增
  30.     public function insert(array $data);
  32.     // 查询
  33.     public function select(string $where = '');
  35.     // 更新
  36.     public function update(array $data, string $where);
  38.     // 删除
  39.     public function delete(string $where);
  40. }
  • 3.2.PDO实现方法
  1. <?php
  3. namespace chapter2;
  5. // 用PDO来实现数据库操作
  6. use PDO;
  8. // 加载iCURD的接口声明
  9. require 'demo7.php';
  11. class Db_PDO implements iCURD
  12. {
  13.     // 连接对象
  14.     private $pdo = null;
  16.     // 实现接口中的构造方法:连接数据库
  17.     public function __construct(...$linkParams)
  18.     {
  19.         list($dsn, $username, $password) = $linkParams;
  20.         $this->pdo = new PDO($dsn, $username, $password);
  21.     }
  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 = "SELECT * FROM `users` {$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.     }
  67. }
  • 3.3.MySQLi实现方法
  1. <?php
  3. namespace chapter2;
  5. // 用MySQLi来实现数据库操作
  6. use mysqli;
  8. // 加载iCURD的接口声明
  9. require 'demo7.php';
  11. class Db_MySQLi implements iCURD
  12. {
  13.     // 连接对象
  14.     private $mysqli = null;
  16.     // 实现接口中的构造方法:连接数据库
  17.     public function __construct(...$linkParams)
  18.     {
  19.         list($host, $username, $password, $dbname) = $linkParams;
  20.         $this->mysqli = new mysqli($host, $username, $password, $dbname);
  21.         // 设置默认字符集
  22.         $this->mysqli -> set_charset('utf8');
  23.     }
  24.     // 新增
  25.     public function insert(array $data)
  26.     {
  27.         $sql = "INSERT `users` SET `name`=?, `email`=?,`password`=?,`register_time`=?";
  28.         $stmt = $this->mysqli->prepare($sql);
  29.         $stmt->bind_param('sssi', $name, $email, $password, $register_time);
  30.         list($name, $email, $password, $register_time) = $data;
  31.         $stmt->execute();
  32.         return $stmt->affected_rows === 1 ? '新增成功' : '新增失败';
  33.     }
  35.     // 查询
  36.     public function select(string $where = '')
  37.     {
  38.         $where = empty($where) ? $where : ' WHERE ' . $where;
  39.         $sql = "SELECT * FROM `users` {$where}";
  40.         $stmt = $this->mysqli->prepare($sql);
  41.         $stmt->execute();
  42.         return $stmt->get_result();
  43.     }
  45.     // 更新
  46.     public function update(array $data, string $where)
  47.     {
  48.         // 设置更新参数
  49.         $params = '';
  50.         foreach ($data as $key => $value) {
  51.             $params .= "`{$key}` = '{$value}', ";
  52.         }
  53.         // 将最后的", "去掉
  54.         $params = rtrim($params, ', ');
  56.         // 执行更新
  57.         $sql = "UPDATE `users` SET {$params} WHERE {$where}";
  58.         $stmt = $this->mysqli->prepare($sql);
  59.         $stmt->execute();
  60.         return $stmt->affected_rows === 1 ? '更新成功' : '更新失败';
  61.     }
  63.     // 删除
  64.     public function delete(string $where)
  65.     {
  66.         $sql = "DELETE FROM  `users` WHERE {$where}";
  67.         $stmt = $this->mysqli->prepare($sql);
  68.         $stmt->execute();
  69.         return $stmt->affected_rows === 1 ? '删除成功' : '删除失败';
  70.     }
  71. }
  • 3.4.通用类DB
  1. <?php
  2. namespace chapter2;
  3. // 通用类: 数据库操作,面向接口实现多态, 动态的支持PDO, MySQLi
  4. use chapter2\iCURD;
  5. class DB
  6. {
  7.     // 新增
  8.     public static function insert(iCURD $db, array $data)
  9.     {
  10.         return $db->insert($data);
  11.     }
  13.     // 查询
  14.     public static function select(iCURD $db, string $where = '')
  15.     {
  16.         return $db->select($where);
  17.     }
  19.     // 更新
  20.     public static function update(iCURD $db, array $data, string $where= '')
  21.     {
  22.         return $db->update($data, $where);
  23.     }
  25.     // 删除
  26.     public static function delete(iCURD $db, string $where= '')
  27.     {
  28.         return $db->delete($where);
  29.     }
  30. }
  • 3.5.PDO实现数据库操作
  1. <?php
  2. namespace chapter02;
  3. //使用PDO来操作数据库：接口实现
  5. // 加载PDO操作类: Db_PDO
  6. require 'demo8.php';
  7. //加载数据库的通用类
  8. require 'demo10.php';
  10. //先创建DSN
  11. $dsn = iDbParam::TYPE . ':host=' . iDbParam::HOST . ';dbname=' . iDbParam::DBNAME . ';charset=' . iDbParam::CAHRSET;
  13. $link = new Db_PDO($dsn, iDbParam::USER_NAME, iDbParam::PASSWORD);
  15. //var_dump($link);
  16. //var_dump($dsn);
  18. //测试新增操作
  19. echo DB::insert($link, ['欧阳峰', 'rose@php.cn', sha1('123456'), time()]);
  20. echo '<hr>';
  21. //
  22. //测试查询
  23. foreach (DB::select($link,'id > 2') as $user) {
  24.     echo "{$user['id']} -- {$user['name']} -- {$user['email']} <br>";
  25. }
  26. echo '<hr>';
  28. //测试更新
  29. echo DB::update($link, ['id'=>'9', 'email'=>'ouyang@php.cn'], 'id=26');
  30. echo '<hr>';
  32. //测试删除
  33. echo DB::delete($link, 'id=8');

  • 3.6.MySQLi实现数据库操作
  1. <?php
  2. namespace chapter02;
  3. //使用MySQLi来操作数据库：接口实现
  5. // 加载MySQLi操作类: Db_MySQLi
  6. require 'demo9.php';
  7. //加载数据库的通用类
  8. require 'demo10.php';
  10. //连接实例
  11. $link = new Db_MySQLi(iDbParam::HOST, iDbParam::USER_NAME, iDbParam::PASSWORD, iDbParam::DBNAME);
  13. //var_dump($link);
  14. //var_dump($dsn);
  16. //测试新增操作
  17. echo DB::insert($link, ['丘处机', 'rose@php.cn', sha1('123456'), time()]);
  18. echo '<hr>';
  20. //测试查询
  21. foreach (DB::select($link,'id > 3') as $user) {
  22.     echo "{$user['id']} -- {$user['name']} -- {$user['email']} <br>";
  23. }
  24. echo '<hr>';
  26. ////测试更新
  27. echo DB::update($link, ['name'=>'郭芙蓉', 'email'=>'guofurong@php.cn'], 'id=3');
  28. //echo DB::update($link, ['id'=>'8'], 'id=9');
  29. echo '<hr>';
  31. //测试删除
  32. echo DB::delete($link, 'id=2');

上一条：除了laravel和thinkphp框架，PHP还有哪些框架，如何选择框架呢？这里有个框架汇总介绍~下一条：0210命名空间与全局成员导入
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多