search

博客列表 >PHP大牛成长之路：mysqli与PDO的增删改查操作（CURD）

PHP大牛成长之路：mysqli与PDO的增删改查操作（CURD）

周Sir-BLOG
周Sir-BLOG原创
2020年07月22日 00:42:09530浏览

mysqli与PDO的增删改查操作（CURD）

数据库结构如下：

database.php （演示公用数据库连接参数）

  1. <?php
  3. //直接以一维数组输出
  4. return [
  5.      // 数据库类型
  6.      'type'              =>  $type ?? 'mysql',   //等于：isset($type)?$type:'mysql';
  7.      // 服务器地址
  8.      'hostname'          =>  $hostname ??'127.0.0.1',
  9.      // 数据库名
  10.      'database'          => $database ?? 'php_pro',
  11.      // 用户名
  12.      'username'          => $username ?? 'root',
  13.      // 密码
  14.      'password'          => $password ?? 'root',
  15.      // 端口
  16.      'hostport'          => $hostport ?? '3306',
  17.      // 数据库编码默认采用utf8
  18.      'charset'           => $charset ?? 'utf8',
  19. ];

1、mysqli

连接数据库

  1. // 导入配置参数(一维数组）
  2. $config = require './database.php';
  5. // extract(数组,参数,前缀)将关联数组转为独立变量(返回数组长度)
  6. extract($config);
  8. //第二个参数如下：
  9. // EXTR_OVERWRITE - 默认。如果有冲突，则覆盖已有的变量。
  10. // EXTR_SKIP - 如果有冲突，不覆盖已有的变量。
  11. // EXTR_PREFIX_SAME - 如果有冲突，在变量名前加上前缀 prefix。
  12. // EXTR_PREFIX_ALL - 给所有变量名加上前缀 prefix。
  13. // EXTR_PREFIX_INVALID - 仅在不合法或数字变量名前加上前缀 prefix。
  14. // EXTR_IF_EXISTS - 仅在当前符号表中已有同名变量时，覆盖它们的值。其它的都不处理。
  15. // EXTR_PREFIX_IF_EXISTS - 仅在当前符号表中已有同名变量时，建立附加了前缀的变量名，其它的都不处理。
  16. // EXTR_REFS - 将变量作为引用提取。导入的变量仍然引用了数组参数的值。
  18. //加盐
  19. $salt="php.pro";
  21. //连接数据库(示例化mysqli对象)
  22. $mysqli = new mysqli($hostname, $username, $password, $database);
  24. // 检测错误(如果存在错误，终止脚本执行并使用mysqli函数：connect_error 输出mysqli连接错误的描述)
  25. if ($mysqli->connect_errno) exit('Connect Error: ' . $mysqli->connect_error);
  27. // 最好设置数据库字符编码，防止乱码
  28. $mysqli->set_charset($charset);

1.1、mysqli添加操作

  1. // +---------------------------------------------------------
  2. // | 1、mysqli添加操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'INSERT `users` SET `username`=?, `age`=?, `email`= ?, `password`=?;';
  7. // $sql = "INSERT INTO `users`(`username`, `age`, `email`,`password`) VALUES (?,?,?,?);";
  9. // step2: 将sql语句转为sql语句对象: stmt对象,预处理对象, 预编译语句对象
  10. $stmt = $mysqli->prepare($sql);
  12. // step3:  给占位符绑定一个变量名(变量标识符)
  13. $stmt->bind_param('sdss', $username,$age,$email,$password);
  15. // 将变量名与一个具体的值进行绑定: 变量赋值
  16. $data = [
  17.     'username'  => 'arwang',
  18.     'age'       => 30,
  19.     'email'     => 'arwang@126.com',
  20.     'password'  => md5('123456'.$salt),
  21. ];
  22. // 将关联数组解构成独立变量
  23. extract($data);
  25. // step4:执行
  26. $stmt->execute() or die($stmt->error);
  28. printf('成功的新增了 %s 条记录, 新增主键ID = %d<br>', $stmt->affected_rows, $stmt->insert_id);
  30. // step5:关闭连接
  31. $mysqli->close();

如果要批量添加，可以使用foreach遍历数组，解构变量：

  1. // 通过遍历一个二维数组,可以实现一次性插入多条记录
  2. $users = [
  3.     ['username'=> 'xiaoyanzi','age'=>30,'email'=>'xyz@php.cn', 'password'=>md5('123456'.$salt)],
  4.     ['username'=> 'ziwei','age'=>20,'email'=>'zw@php.cn', 'password'=>md5('123456'.$salt)],
  5.     ['username'=> 'wuage','age'=>25,'email'=>'wag@php.cn', 'password'=md5('123456'.$salt)],
  6.     ['username'=> 'erkang','age'=>33,'email'=>'ek@php.cn', 'password'=>md5('123456'.$salt)],
  7.     ['username'=> 'jinsuo','age'=>18,'email'=>'js@php.cn', 'password'=>md5('123456'.$salt)],
  8. ];
  10. foreach ($users as $user) {
  11.     extract($user);
  13.     if ($stmt->execute())
  14.         printf('成功的新增了 %s 条记录, 新增主键ID = %d<br>', $stmt->affected_rows, $stmt->insert_id);
  15.     else 
  16.         exit(sprintf('新增失败 , $d: %s', $stmt->errno, $stmt->error ));
  17. }

1.2、mysqli删除操作

  1. // +---------------------------------------------------------
  2. // | 2、mysqli删除操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'DELETE FROM  `users`  WHERE `id` = ?;';
  7. // step2: 将sql语句转为stmt对象
  8. $stmt = $mysqli->prepare($sql);
  9. // step3:  给占位符绑定一个变量名(变量标识符)
  10. $stmt->bind_param('i',$id);
  11. // 变量赋值
  12. $id=19;
  14. // step4:执行更新
  15. $stmt->execute();
  16. printf('删除了 %s 条记录', $stmt->affected_rows);
  18. // step5:关闭连接
  19. $mysqli->close();

1.3、mysqli更新操作

  1. // +---------------------------------------------------------
  2. // | 3、mysqli修改操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'UPDATE  `users` SET `username`=?, `age`=?, `email`= ?, `password`=? WHERE `id` = ?;';
  7. // step2: 将sql语句转为stmt对象
  8. $stmt = $mysqli->prepare($sql);
  9. // step3:  给占位符绑定一个变量名(变量标识符)
  10. $stmt->bind_param('sissi', $username, $age, $email, $password, $id);
  11. // 变量赋值
  12. $user = ['username'=>'lixiaoming','age'=>23,'email'=>'lixiaoming@php.cn', 'password'=>md5('123456'.$salt), 'id'=>15 ];
  13. // 将关联数组解构成独立变量
  14. extract($user);
  15. // step4:执行更新
  16. $stmt->execute();
  17. printf('更新了 %s 条记录', $stmt->affected_rows);
  19. // step5:关闭连接
  20. $mysqli->close();

1.4、mysqli查询操作

  1. // mysqli查询1: fetch_assoc() + while()
  3. // step1: sql语句
  4. $sql = 'SELECT * FROM `users` WHERE `id` > ?';
  5. // step2: 将sql语句转为stmt对象
  6. $stmt = $mysqli->prepare($sql);
  7. $stmt->bind_param('i', $id);
  9. $id = 5;
  10. // step3:执行查询
  11. $stmt->execute() or die($stmt->error);
  14. // step4:获取结果集
  15. $result = $stmt->get_result();
  17. if ($result->num_rows === 0) exit('结果为空');
  18. // fetch_assoc():以关联数组方式返回一个记录
  19. // 循环遍历
  20. while ($user=$result->fetch_assoc()) {
  21.     vprintf('%d: %s | %s <br>', $user);
  22. }
  24. // step5:释放结果
  25. $result->free();
  26. // step6:关闭连接
  27. $mysqli->close();
  1. // mysqli查询2: fetch_all() + foreach()
  3. // step1: sql语句
  4. $sql = 'SELECT * FROM `users` WHERE `id` > ?';
  5. // step2: 将sql语句转为stmt对象
  6. $stmt = $mysqli->prepare($sql);
  7. $stmt->bind_param('i', $id);
  9. $id = 5;
  10. // step3:执行查询
  11. $stmt->execute() or die($stmt->error);
  13. // step4:获取结果集
  14. $result = $stmt->get_result();
  16. if ($result->num_rows === 0) exit('结果为空');
  17. // fetch_all():以二维关联数组方式返回一个满足查询条件的所有记录集合
  18. $users=$result->fetch_all(MYSQLI_ASSOC);
  19. // 循环遍历
  20. foreach ($users as $user) {
  21.     vprintf('%d: %s ******* | %s <br>', $user);
  22. }
  24. // step5:释放结果
  25. $result->free();
  26. // step6:关闭连接
  27. $mysqli->close();
  1. // mysqli查询3: bind_result() + fetch() + while()
  2. // 将结果集中的每条记录的每个字段，与一个变量进行绑定
  4. // step1: sql语句
  5. $sql = 'SELECT `id`,`username`,`age`,`email` FROM `users` WHERE `id` > ?';
  7. // step2: 将sql语句转为stmt对象
  8. $stmt = $mysqli->prepare($sql);
  9. $stmt->bind_param('i', $id);
  10. $id = 5;
  12. // step3:执行查询
  13. $stmt->execute() or die($stmt->error);
  15. // step4:字段与变量的绑定
  16. $stmt->bind_result($id,$username,$age,$email);
  18. // 因为当前操作不涉及结果集对象，如果要获取结果集中的数量，用以下二行代码
  19. $stmt->store_result();
  20. if ($stmt->num_rows === 0) exit('没有内容');
  22. // 循环遍历
  23. while ($stmt->fetch()) {
  24.     printf('%d: %s --%d--| %s <br>', $id,$username,$age, $email);
  25. }
  27. // step5:关闭连接
  28. $mysqli->close();

2、PDO

连接数据库

  1. // 导入配置参数(一维数组）
  2. $config = require './database.php';
  4. // extract(数组,参数,前缀)将关联数组转为独立变量(返回数组长度)
  5. extract($config);
  7. //加盐
  8. $salt="php.pro";
  11. // 创建连接对象: 连接数据库
  12. // $dsn: 数据源名称
  13. // $dsn = 'mysql:host=localhost;dbname=phpedu;charset=utf8;port=3306';
  15. try {
  16.     $dsn= sprintf('%s:host=%s;dbname=%s;charset=%s;port=%s',$type,$hostname,$database,$charset,$hostport);
  17.     $pdo = new PDO($dsn, $username, $password);
  18.     // 设置结果集的默认获取模式: 只关心关联数组部分
  19.     $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
  20. } catch (PDOException $e) {
  21.     exit('Connection Error: ' . $e->getMessage());
  22. }

2.1、PDO添加操作

2.1.1 bindParam变量名绑定, 引用绑定

  1. // +---------------------------------------------------------
  2. // | 1、PDO添加操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'INSERT `users` SET `username`=?, `age`=?, `email`= ?, `password`=?;';
  8. // step2: 将sql语句转为PDOstmt对象
  9. $stmt = $pdo->prepare($sql);
  11. // step3: ? 与 变量名绑定, 引用绑定
  12. $stmt->bindParam(1, $username, PDO::PARAM_STR, 30);
  13. $stmt->bindParam(2, $age, PDO::PARAM_INT, 3);
  14. $stmt->bindParam(3, $email, PDO::PARAM_STR, 100);
  15. $stmt->bindParam(4, $password, PDO::PARAM_STR, 32);
  17. // 将变量名与一个具体的值进行绑定: 变量赋值
  18. $data = [
  19.     'username'  => 'arwang',
  20.     'age'       => 30,
  21.     'email'     => 'arwang@126.com',
  22.     'password'  => md5('123456'.$salt),
  23. ];
  24. // 将关联数组解构成独立变量
  25. extract($data);
  27. // step4:执行
  28. $stmt->execute() or die(print_r($stmt->errorInfo(),true));
  30. // rowCount():返回表中受影响的记录数量,当前是新增的记录数量
  31. if ($stmt->rowCount() > 0)  echo '新增成功 ' . $stmt->rowCount() . ' 条记录,主键id: ' . $pdo->lastInsertId();
  33. // step5:关闭连接
  34. // $pdo = null;
  35. unset($pdo);

2.1.2 bindValue值绑定,变量必须先赋值

  1. // +---------------------------------------------------------
  2. // | 1、PDO添加操作：
  3. // +---------------------------------------------------------
  5. // `bindValue `值绑定,变量必须先赋值
  6. // step1: sql语句
  7. $sql = 'INSERT `users` SET `username`=?, `age`=?, `email`= ?, `password`=?;';
  9. // step2: 将sql语句转为PDOstmt对象
  10. $stmt = $pdo->prepare($sql);
  12. // step3: ? 与 值绑定,变量必须先赋值
  14. // 变量赋值
  15. $data = [
  16.     'username'  => 'arwang',
  17.     'age'       => 30,
  18.     'email'     => 'arwang@126.com',
  19.     'password'  => md5('123456'.$salt),
  20. ];
  21. // 将关联数组解构成独立变量
  22. extract($data);
  24. // 值绑定
  25. $stmt->bindValue(1, $username, PDO::PARAM_STR);
  26. $stmt->bindParam(2, $age, PDO::PARAM_INT);
  27. $stmt->bindValue(3, $email, PDO::PARAM_STR);
  28. $stmt->bindValue(4, $password, PDO::PARAM_STR);
  30. // step4:执行
  31. $stmt->execute() or die(print_r($stmt->errorInfo(),true));
  33. // rowCount():返回表中受影响的记录数量,当前是新增的记录数量
  34. if ($stmt->rowCount() > 0)  echo '新增成功 ' . $stmt->rowCount() . ' 条记录,主键id: ' . $pdo->lastInsertId();
  36. // step5:关闭连接
  37. // $pdo = null;
  38. unset($pdo);

2.1.3 bindValue值绑定简化操作

  1. // +---------------------------------------------------------
  2. // | 1、PDO添加操作：
  3. // +---------------------------------------------------------
  5. // `bindValue `值绑定简化方式
  6. // step1: sql语句
  7. $sql = 'INSERT `users` SET `username`=?, `age`=?, `email`= ?, `password`=?;';
  9. // step2: 将sql语句转为PDOstmt对象
  10. $stmt = $pdo->prepare($sql);
  12. // step3: ? 与 值绑定,变量必须先赋值
  14. // 数组赋值
  15. $data = ['arwang',30,'arwang@126.com',md5('123456'.$salt)];
  18. // step4:执行
  19. $stmt->execute($data) or die(print_r($stmt->errorInfo(),true));
  21. // rowCount():返回表中受影响的记录数量,当前是新增的记录数量
  22. if ($stmt->rowCount() > 0)  echo '新增成功 ' . $stmt->rowCount() . ' 条记录,主键id: ' . $pdo->lastInsertId();
  24. // step5:关闭连接
  25. // $pdo = null;
  26. unset($pdo);

2.2、PDO删除操作

  1. // +---------------------------------------------------------
  2. // | 2、PDO删除操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'DELETE FROM  `users` WHERE `id` = ?;';
  7. // step2: 将sql语句转为PDOstmt对象
  8. $stmt = $pdo->prepare($sql);
  9. // step3:执行
  10. // 值直接绑定到匿名占位符?上面
  11. $stmt->execute([22]);
  12. if ($stmt->rowCount() > 0)  echo '删除成功 ' . $stmt->rowCount() . ' 条记录';
  13. // step4:关闭连接
  14. unset($pdo);

2.3、PDO修改操作

  1. // +---------------------------------------------------------
  2. // | 3、PDO修改操作：
  3. // +---------------------------------------------------------
  5. // step1: sql语句
  6. $sql = 'UPDATE  `users` SET `username`=?,`age`=?, `email`= ?, `password`=? WHERE `id` = ?;';
  8. // step2: 将sql语句转为PDOstmt对象
  9. $stmt = $pdo->prepare($sql);
  11. // step3:执行
  12. // 将值直接绑定到匿名占位符?上面
  13. $stmt->execute(['arwang',33,'arwang@php.cn', md5('123456'.$salt), 11]);
  14. if ($stmt->rowCount() > 0)  echo '更新成功 ' . $stmt->rowCount() . ' 条记录';
  16. // step4:关闭连接
  17. unset($pdo);

2.4、PDO查询操作

  1. // pdo查询操作: fetch() + while()
  3. // step1: sql语句
  4. $sql = 'SELECT `id`,`username`,`age`,`email` FROM  `users` WHERE `id` >= ?;';
  6. // step2: 将sql语句转为PDOstmt对象
  7. $stmt = $pdo->prepare($sql);
  9. // step3:执行
  10. // 将值直接绑定到匿名占位符?上面
  11. $stmt->execute([5]);
  13. while ($user = $stmt->fetch()) {
  14.     vprintf('<li>%s: %s | %s</li>', $user);
  15. }
  17. // step4:关闭连接
  18. unset($pdo);
  1. // pdo查询操作2: fetchAll() + foreach()
  2. // step1: sql语句
  3. $sql = 'SELECT `id`,`username`,`age`,`email` FROM  `users` WHERE `id` >= ?;';
  5. // step2: 将sql语句转为PDOstmt对象
  6. $stmt = $pdo->prepare($sql);
  8. // 将值直接绑定到匿名占位符?上面
  9. $stmt->execute([5]);
  11. $users = $stmt->fetchAll();
  13. foreach ($users as $user) {
  14.     vprintf('<li>%s: %s | %s</li>', $user);
  15. }
  17. // step4:关闭连接
  18. unset($pdo);
  1. // +---------------------------------------------------------
  2. // | 4、PDO查询操作：
  3. // +---------------------------------------------------------
  5. // pdo查询操作3: bindColumn() + fetch() + while()
  7. // step1: sql语句
  8. $sql = 'SELECT `id`,`username`,`age`,`email` FROM  `users` WHERE `id` >= ?;';
  10. // step2: 将sql语句转为PDOstmt对象
  11. $stmt = $pdo->prepare($sql);
  13. // step3:执行
  14. // 将值直接绑定到匿名占位符?上面
  15. $stmt->execute([5]);
  17. // 将三个字段与三个变量绑定
  18. $stmt->bindColumn('id', $id);
  19. $stmt->bindColumn('username', $username);
  20. $stmt->bindColumn('age', $age);
  21. $stmt->bindColumn('email', $email);
  23. while ($stmt->fetch(PDO::FETCH_BOUND)) {zensan
  24.     printf('<li>%d: %s -%d | %s</li>',$id, $username,$age, $email);
  25. }
  27. // step4:关闭连接
  28. unset($pdo);

总结

  • 对mysqli和PDO的增删改查有了更深的理解
  • mysqli和PDO的常用方法使用老师总结的写在了另一篇博客，因为老师总结的值得收藏查阅。
    https://www.php.cn/blog/detail/23346.html
上一条：mysqli与PDO操作数据库方法收藏下一条：PHP 使用 mysqli 类连接数据库并遍历结果
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多