search

博客列表 >0817-数据库常用的CURD操作

0817-数据库常用的CURD操作

三九三伏
三九三伏原创
2022年09月02日 14:54:41409浏览

实例演示常用 的CURD操作,特别是各种常用组合,如fetch+while…

一、预处理参数绑定

PDO预处理
预处理的本质是sql语句的动态绑定
动态绑定就是执行时才绑定真实数据
SELECT * FROM `表名` WHERE `id` > ?
静态绑定，数据直接写到SQL语句中
SELECT * FROM `表名` WHERE `id` > 1

1. 动态绑定方式

1.1 匿名参数+索引数组

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //匿名参数：？
  7. $sql = 'INSERT `staff` SET `name` = ?, `gender` = ?, `email` = ?;';
  9. $stmt = $db->prepare($sql);
  11. //SQL语句中占位符“？”，用索引数组绑定真实数据
  12. $data = ['admin', 0, 'admin@php.cn'];
  14. $stmt->execute($data);
  15. echo '<hr>';
  16. //打印SQL预处理命令
  17. $stmt->debugDumpParams();
  19. echo '<br>'.$stmt->errorCode().'<br>';
  20. print_r($stmt->errorInfo());
  22. echo '<br>id = '.$db->lastInsertId().'<br>';

1.2 命名参数+关联数组

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //命名参数：“：xxxx”不用和前面一一对应
  7. $sql = 'INSERT `staff` SET `name` = :xname, `gender` = :pgender, `email` = :demail;';
  9. $stmt = $db->prepare($sql);
  11. //SQL语句中占位符“：xxxx”，用关联数组绑定真实数据
  12. // $data = [':xname' => 'admin', ':pgender' => 0, ':demail' => 'admin@php.cn'];
  13. //去掉冒号也是可以的
  14. $data = ['xname' => 'admin1', 'pgender' => 1, 'demail' => 'admin1@php.cn'];
  16. $stmt->execute($data);
  17. echo '<hr>';
  18. //打印SQL预处理命令
  19. $stmt->debugDumpParams();
  21. echo '<br>'.$stmt->errorCode().'<br>';
  22. print_r($stmt->errorInfo());
  24. echo '<br>id = '.$db->lastInsertId().'<br>';

“匿名参数+索引数组”和“命名参数+关联数组”用哪个好？
用哪个都可以，看个人喜好。

1.3 参数绑定：值绑定 bindValue()

  1. /**
  2.  * 为什么要单独设置参数，而不是在execute()时传参？
  3.  * execute()默认参数都是字符类型
  4.  * 通常数字型字符写入数据表时，会转换成正确类型，不会有问题。
  5.  * 但在分页操作时，会导致错误。
  6.  * 在参数绑定时，强制类型限制，就很有必要。
  7.  */
  10. namespace pdo_edu;
  12. use PDO;
  14. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  15. //匿名参数：？
  16. $sql = 'INSERT `staff` SET `name` = ?, `gender` = ?, `email` = ?;';
  18. $stmt = $db->prepare($sql);
  20. //bindValue()值绑定，静态绑定，所有参数有确定值。
  21. // bindValue(key, value, type)，匿名占位符，索引从1开始。
  22. // $stmt->bindValue(1, 'admin3', PDO::PARAM_STR);
  23. // $stmt->bindValue(2, 0, PDO::PARAM_INT);
  24. // $stmt->bindValue(3, 'admin3@php.cn', PDO::PARAM_STR);
  26. // 上面是写死的，更灵活应该用数组传参。
  27. list($name, $gender, $email) = ['admin4', 1, 'admin4@php.cn'];
  28. $stmt->bindValue(1, $name, PDO::PARAM_STR);
  29. $stmt->bindValue(2, $gender, PDO::PARAM_INT);
  30. $stmt->bindValue(3, $email, PDO::PARAM_STR);
  32. list($name, $gender, $email) = ['admin5', 0, 'admin5@php.cn'];
  33. $stmt->bindValue(1, $name, PDO::PARAM_STR);
  34. $stmt->bindValue(2, $gender, PDO::PARAM_INT);
  35. $stmt->bindValue(3, $email, PDO::PARAM_STR);
  38. $stmt->execute();
  39. echo '<hr>';
  40. //打印SQL预处理命令
  41. $stmt->debugDumpParams();
  43. echo '<br>'.$stmt->errorCode().'<br>';
  44. print_r($stmt->errorInfo());
  46. echo '<br>id = '.$db->lastInsertId().'<br>';

每插入一条就得绑定一次，也不方便灵活。

1.4 参数绑定：引用绑定bindParam()

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //heredoc
  7. $sql = <<<SQL
  8.     INSERT `staff` 
  9.     SET `name` = ?, `gender` = ?, `email` = ?;
  10. SQL;    
  12. $stmt = $db->prepare($sql);
  14. // 引用绑定
  15. $stmt->bindParam(1, $name, PDO::PARAM_STR);
  16. $stmt->bindParam(2, $gender, PDO::PARAM_INT);
  17. $stmt->bindParam(3, $email, PDO::PARAM_STR);
  21. // list($name, $gender, $email) = ['admin6', 1, 'admin6@php.cn'];
  22. // $stmt->execute();
  23. // echo '<hr>';
  24. // 在增加两条条
  25. // list($name, $gender, $email) = ['admin7', 0, 'admin7@php.cn'];
  26. // $stmt->execute();
  27. // echo '<hr>';
  28. // list($name, $gender, $email) = ['admin8', 1, 'admin8@php.cn'];
  29. // $stmt->execute();
  30. // echo '<hr>';
  31. // $stmt->execute();
  32. // echo '<hr>';
  33. // //打印SQL预处理命令
  34. // $stmt->debugDumpParams();
  36. // echo '<br>'.$stmt->errorCode().'<br>';
  37. // print_r($stmt->errorInfo());
  39. // echo '<br>id = '.$db->lastInsertId().'<br>';
  42. // 用循环和二维数组添加多条
  43. $data = [
  44.     ['admin9', 0, 'admin9@php.cn'],
  45.     ['admin10', 1, 'admin10@php.cn'],
  46.     ['admin11', 0, 'admin11@php.cn'],    
  47. ];
  48. foreach($data as list($name, $gender, $email)){
  49.     $stmt->execute();
  50.     echo '<hr>';
  51.     //打印SQL预处理命令
  52.     $stmt->debugDumpParams();
  54.     echo '<br>'.$stmt->errorCode().'<br>';
  55.     print_r($stmt->errorInfo());
  57.     echo '<br>id = '.$db->lastInsertId().'<br>';
  58. }

1.5 错误处理

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //heredoc
  7. $sql = <<<SQL
  8.     INSERT `staff` SET `name` = ?, `gender` = ?, `email` = ?;
  9. SQL;    
  11. $stmt = $db->prepare($sql);
  13. //注释“引用绑定”，引起错误
  14. // $stmt->bindParam(1, $name, PDO::PARAM_STR);
  15. // $stmt->bindParam(2, $gender, PDO::PARAM_INT);
  16. // $stmt->bindParam(3, $email, PDO::PARAM_STR);
  18. $data = [
  19.     ['admin12', 0, 'admin12@php.cn'],
  20.     //['admin13', 0, 'admin13@php.cn'],
  21. ];
  23. foreach($data as list($name, $gender, $email)){
  24.     if($stmt->execute()){
  25.         if($stmt->rowCount() > 0){
  26.             echo 'sql执行成功,id ='.$db->lastInsertId().'<br>';
  27.             echo '<hr>';
  28.         }else{
  29.             echo '执行失败';
  30.             print_r($stmt->errorInfo());
  31.         }
  32.     }else{
  33.         echo 'sql执行失败';
  34.         print_r($stmt->errorInfo());
  35.     }    
  36. }

Tips

  1. else：应用于开发调试阶段，生产环境中应将错误信息集中写到日志文件中。
  2. sql执行失败很常见，通常是语法错误，例如字段名写错等。
  3. 新增失败通常是权限问题，如没有插入权限或者当前表被锁定只读等，磁盘满也有可能。

1.6 更新

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //heredoc
  7. $sql = <<<SQL
  8.     UPDATE `staff` SET `name` = ?, `gender` = ?, `email` = ?
  9.     WHERE `id`= ?;
  10. SQL;    
  12. // ！！！！最高提示：禁止无条件更新，生产环境必须杜绝。
  13. // stripos()忽略大小写
  14. if (false === stripos($sql, 'where'))
  15. {
  16.     exit('禁止无条件更新！');
  17. }
  19. $stmt = $db->prepare($sql);
  22. $stmt->bindParam(1, $name, PDO::PARAM_STR);
  23. $stmt->bindParam(2, $gender, PDO::PARAM_INT);
  24. $stmt->bindParam(3, $email, PDO::PARAM_STR);
  25. $stmt->bindParam(4, $id, PDO::PARAM_INT);
  27. $data = [
  28.     ['admin8', 0, 'admin8@php.cn', 8],
  30. ];
  32. foreach($data as list($name, $gender, $email, $id)){
  33.     if($stmt->execute()){
  34.         if($stmt->rowCount() > 0){
  35.             echo '成功更新了'.$stmt->rowCount().'条记录<br>';
  36.             echo '<hr>';
  37.         }else{
  38.             echo '更新重复：没有记录被更新！<br>';
  39.             print_r($stmt->errorInfo());
  40.             $stmt->debugDumpParams();
  41.         }
  42.     }else{
  43.         echo 'sql执行失败';
  44.         print_r($stmt->errorInfo());
  45.     }    
  46. }

成功时，

重复的更新将被拦截，

  1. ....
  2. //不写条件WHERE测试
  3. $sql = <<<SQL
  4.     UPDATE `staff` SET `name` = ?, `gender` = ?, `email` = ?
  5.     ;
  6. SQL;    
  8. // 最高提示：禁止无条件更新，生产环境必须杜绝。
  9. // stripos()忽略大小写
  10. if (false === stripos($sql, 'where'))
  11. {
  12.     exit('禁止无条件更新！');
  13. }
  14. ....

1.7 删除

  1. namespace pdo_edu;
  3. use PDO;
  5. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  6. //heredoc
  7. $sql = <<<SQL
  8.     DELETE FROM `staff` 
  9.     WHERE `id`= ?;
  10. SQL;    
  12. // 最高提示：禁止无条件删除，生产环境必须杜绝。
  13. // stripos()忽略大小写
  14. if (false === stripos($sql, 'where'))
  15. {
  16.     exit('禁止无条件删除！');
  17. }
  19. $stmt = $db->prepare($sql);
  21. $stmt->bindParam(1, $id, PDO::PARAM_INT);
  23. $data = [
  24.     [11],
  25.     [10],
  26. ];
  28. foreach($data as list($id)){
  30.     echo $id.'<br>';
  31.     if($stmt->execute()){
  32.         if($stmt->rowCount() > 0){
  33.             echo '成功删除了'.$stmt->rowCount().'条记录<br>';
  34.             echo '<hr>';
  35.         }else{
  36.             echo '重复删除：没有记录被删除！<br>';
  37.             print_r($stmt->errorInfo());
  38.             // $stmt->debugDumpParams();
  39.         }
  40.     }else{
  41.         echo 'sql执行失败';
  42.         print_r($stmt->errorInfo());
  43.     }    
  44. }

1.8 查询

1.8.1 fetch + while

  1. // 查询 fetch + while
  2. namespace pdo_edu;
  4. use PDO;
  6. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  7. //heredoc
  8. $sql = <<<SQL
  9.     SELECT `id`, `name`, `email` FROM `staff` 
  10.     LIMIT ?;
  11. SQL;    
  14. $stmt = $db->prepare($sql);
  16. // $num = 5;
  17. // $stmt->bindParam(1, $num, PDO::PARAM_INT);
  19. $stmt->bindValue(1, 5, PDO::PARAM_INT);
  23. if($stmt->execute()){
  24.     // fetch()逐条获取，指针自动后移指向下一条，失败返回false，成功返回记录。
  25.     // $staff = $stmt->fetch(PDO::FETCH_ASSOC);
  26.     // if($staff)
  27.     // {
  28.     //     printf('<pre>%s</pre><br>',print_r($staff, true));
  29.     // }else
  30.     // {
  31.     //     echo '没有查询到数据！<br>';
  32.     // }
  34.     while($staff = $stmt->fetch(PDO::FETCH_ASSOC))
  35.     {
  36.         printf('<pre>%s</pre><br>',print_r($staff, true));
  37.     }
  39. }else{
  40.     echo 'sql执行失败';
  41.     print_r($stmt->errorInfo());
  42.     $stmt->debugDumpParams();
  43. }

1.8.2 fetchall

  1. // 查询 fetchall
  2. namespace pdo_edu;
  4. use PDO;
  6. $db = new PDO('mysql:dbname=phpedu', 'phpedu', 'phpedu');
  7. //heredoc
  8. $sql = <<<SQL
  9.     SELECT `id`, `name`, `email` FROM `staff` 
  10.     LIMIT ?;
  11. SQL;    
  14. $stmt = $db->prepare($sql);
  16. // $num = 5;
  17. // $stmt->bindParam(1, $num, PDO::PARAM_INT);
  19. $stmt->bindValue(1, 4, PDO::PARAM_INT);
  23. if($stmt->execute()){
  24.     // fetchall()获取全部记录。
  25.     while($staffs = $stmt->fetchAll(PDO::FETCH_ASSOC))
  26.     {
  27.         foreach($staffs as
  28.         $staff){
  29.             printf('<pre>%s</pre><br>',print_r($staff, true));
  30.         }
  31.     }
  33. }else{
  34.     echo 'sql执行失败';
  35.     print_r($stmt->errorInfo());
  36.     $stmt->debugDumpParams();
  37. }

上一条：PHPExcel导出证件号问题下一条：知识付费系统源码（pc+小程序+h5+app）免授权附搭建下载教程
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多