Community Learn Tools Library Leisure
search
English
Home > List of blog posts > 0817-数据库常用的CURD操作
Blogger Information
Blog 35
fans 0
comment 0
visits 16931
Special Recommendation
More>
Related recommendations
Popular Tutorials
More>
Related Tutorials
Popular Recommendations
Latest courses
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template
0817-数据库常用的CURD操作
三九三伏
Original
408 people have browsed it

实例演示常用 的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. }

Correcting teacher：PHPzPHPz

Correction status：qualified

Teacher's comments：
Statement of this Website
The copyright of this blog article belongs to the blogger. Please specify the address when reprinting! If there is any infringement or violation of the law, please contact admin@php.cn Report processing!
All comments Speak rationally on civilized internet, please comply with News Comment Service Agreement
0 comments
Author's latest blog post