search

博客列表 >11月22日_PDO连接数据库，并实现增删查改操作

11月22日_PDO连接数据库，并实现增删查改操作

fkkf467
fkkf467原创
2019年11月23日 16:52:02634浏览

1. PDO连接数据库

  1. <?php
  3. //$pdo = new PDO('mysql:host=localhost;dbname=movie', 'root', 'root');
  4. //print_r($pdo);
  6. // 参数
  7. $db = [
  8.     'type' => 'mysql',
  9.     'host' => 'localhost',
  10.     'dbname' => 'movie',
  11.     'username' => 'root',
  12.     'password' => 'root',
  13.     'port' => 3306
  14. ];
  16. $dsn = "{$db['type']}:host={$db['host']};dbname={$db['dbname']}";
  18. // 连接数据库，并进行异常处理
  19. try {
  20.     $pdo = new PDO($dsn, $db['username'], $db['password']);
  21. //    print_r($pdo);
  22. } catch (PDOException $e) {
  23.     die('错误信息：' . $e->getMessage());
  24. }

2. PDO操作数据库实现新增数据

  1. <?php
  3. // 1. 连接数据库
  4. require __DIR__ . '/connect.php';
  6. // 2. 创建SQL语句模板
  7. $sql = 'INSERT INTO `movie_list` SET `movie_name`= :movie_name,`movie_img`= :movie_img,
  8. `movie_director`= :movie_director,`movie_write`= :movie_write,`movie_star`= :movie_star,
  9. `movie_type`= :movie_type,`movie_area`= :movie_area,`movie_language`= :movie_language,
  10. `add_time`= :add_time,`movie_length`= :movie_length,`movie_introduction`= :movie_introduction';
  12. // 3. 创建SQL语句对象
  13. $stmt = $pdo->prepare($sql);
  14. //print_r($stmt);
  16. // 4. 将变量绑定到SQL语句模板的命名占位符上
  17. $movie_name = '犯罪现场';
  18. $movie_img = 'fzxc.jpg';
  19. $movie_director = '冯志强';
  20. $movie_write = '冯志强';
  21. $movie_star = '古天乐 宣萱 张继聪 谭耀文';
  22. $movie_type = '悬疑 惊悚 犯罪';
  23. $movie_area = '中国香港';
  24. $movie_language = '粤语';
  25. $add_time = '2019-10-12';
  26. $movie_length = '105';
  27. $movie_introduction = '《犯罪現場》以通缉犯徐糠伏尸屋事件开始，负责调查的警官林法栋（张继聪 饰）发现涉及
  28. 一宗一个月前的劫案，当中同谋包括汪新元（古天乐 饰）、红毛（凌文龙 饰）与欧阳（李灿森 饰），而犯罪现场
  29. 唯一目击证人是一只鹦鹉，林法栋锁定汪新元为嫌犯。不过案情卻不如想像中直接……';
  30. $stmt -> bindParam('movie_name',$movie_name,PDO::PARAM_STR);
  31. $stmt -> bindParam('movie_img',$movie_img,PDO::PARAM_STR);
  32. $stmt -> bindParam('movie_director',$movie_director,PDO::PARAM_STR);
  33. $stmt -> bindParam('movie_write',$movie_write,PDO::PARAM_STR);
  34. $stmt -> bindParam('movie_star',$movie_star,PDO::PARAM_STR);
  35. $stmt -> bindParam('movie_type',$movie_type,PDO::PARAM_STR);
  36. $stmt -> bindParam('movie_area',$movie_area,PDO::PARAM_STR);
  37. $stmt -> bindParam('movie_language',$movie_language,PDO::PARAM_STR);
  38. $stmt -> bindParam('add_time',$add_time,PDO::PARAM_STR);
  39. $stmt -> bindParam('movie_length',$movie_length,PDO::PARAM_INT);
  40. $stmt -> bindParam('movie_introduction',$movie_introduction,PDO::PARAM_STR);
  42. // 5. 执行SQL操作
  43. if ($stmt -> execute()) {
  44.     if ($stmt -> rowCount() > 0) {
  45.         echo '添加成功了' . $stmt->rowCount() . '条数据';
  46.     }
  47. } else {
  48.     die('<pre>' . print_r($stmt->errorInfo(), true));
  49. }
  51. // 6. 销毁pdo，关闭连接
  52. $pdo = null;
  53. //unset($pdo);
  54. //print_r($pdo);

3. PDO操作数据库实现修改数据

  1. <?php
  3. // 1. 连接数据库
  4. require __DIR__ . '/connect.php';
  6. // 2. 创建SQL语句模板
  7. $sql = 'UPDATE `movie_list` SET `movie_name`= :movie_name,`movie_img`= :movie_img WHERE `movie_id`= :movie_id';
  9. // 3. 创建SQL语句对象
  10. $stmt = $pdo->prepare($sql);
  12. // 4. 将变量绑定到SQL语句模板的命名占位符上
  13. $movie_name = '双子杀手';
  14. $movie_img = 'szss.jpg';
  15. $movie_id = 8;
  16. $stmt->bindParam('movie_name', $movie_name, PDO::PARAM_STR);
  17. $stmt->bindParam('movie_img', $movie_img, PDO::PARAM_STR);
  18. $stmt->bindParam('movie_id', $movie_id, PDO::PARAM_INT);
  21. // 5. 执行SQL操作
  22. if ($stmt->execute()) {
  23.     if ($stmt->rowCount() > 0) {
  24.         echo '修改成功了' . $stmt->rowCount() . '条数据';
  25.     }
  26. } else {
  27.     die('<pre>' . print_r($stmt->errorInfo(), true));
  28. }
  30. // 6. 销毁pdo，关闭连接
  31. $pdo = null;

4. PDO操作数据库实现删除数据

  1. <?php
  3. // 1. 连接数据库
  4. require __DIR__ . '/connect.php';
  6. // 2. 创建SQL语句模板
  7. $sql = 'DELETE FROM `movie_list` WHERE `movie_id`= :movie_id';
  9. // 3. 创建SQL语句对象
  10. $stmt = $pdo->prepare($sql);
  12. // 4. 将变量绑定到SQL语句模板的命名占位符上
  13. $movie_id = 5;
  14. $stmt->bindParam('movie_id', $movie_id, PDO::PARAM_INT);
  17. // 5. 执行SQL操作
  18. if ($stmt->execute()) {
  19.     if ($stmt->rowCount() > 0) {
  20.         echo '删除成功了' . $stmt->rowCount() . '条数据';
  21.     }
  22. } else {
  23.     die('<pre>' . print_r($stmt->errorInfo(), true));
  24. }
  26. // 6. 销毁pdo，关闭连接
  27. $pdo = null;

5. PDO操作数据库实现查找数据

  1. <?php
  2. // 1. 连接数据库
  3. require __DIR__ . '/connect.php';
  5. // 2. 创建SQL语句模板
  6. $sql = 'SELECT * FROM `movie_list` WHERE `movie_id`= :movie_id';
  8. // 3. 创建SQL语句对象
  9. $stmt = $pdo->prepare($sql);
  11. // 4. 将变量绑定到SQL语句模板的命名占位符上
  12. $movie_id = 2;
  13. $stmt->bindParam('movie_id',$movie_id,PDO::PARAM_INT);
  15. // 5. 执行SQL操作
  16. $stmt->execute();
  17. // FETCH_ASSOC 关联数组形式
  18. // 遍历输出，返回一维数组
  19. while ($movie = $stmt->fetch(PDO::FETCH_ASSOC)) {
  20.     // 格式化输出
  21.     echo '<pre>' . print_r($movie, true);
  22. //    print_r($movie);
  23. }
  24. // 6. 销毁pdo，关闭连接
  25. $pdo = null;

  1. <?php
  2. // 1. 连接数据库
  3. require __DIR__ . '/connect.php';
  5. // 2. 创建SQL语句模板
  6. $sql = 'SELECT * FROM `movie_list` WHERE `movie_condition`= :movie_condition';
  8. // 3. 创建SQL语句对象
  9. $stmt = $pdo->prepare($sql);
  11. // 4. 将变量绑定到SQL语句模板的命名占位符上
  12. $movie_condition = 2;
  13. $stmt->bindParam('movie_condition',$movie_condition,PDO::PARAM_INT);
  15. // 5. 执行SQL操作
  16. $stmt->execute();
  17. // FETCH_ASSOC 关联数组形式
  18. // 返回二维数组
  19. $movies = $stmt->fetchAll(PDO::FETCH_ASSOC);
  20. echo '<pre>' . print_r($movies, true);
  21. echo '<hr>';
  22. foreach ($movies as $movie) {
  23. echo '<pre>' . print_r($movie, true);
  24. //    print_r($movie);
  25. }
  27. // 6. 销毁pdo，关闭连接
  28. $pdo = null;

  1. <?php
  2. // 1. 连接数据库
  3. require __DIR__ . '/connect.php';
  5. // 2. 创建SQL语句模板
  6. $sql = 'SELECT * FROM `movie_list` WHERE `movie_condition`= :movie_condition';
  8. // 3. 创建SQL语句对象
  9. $stmt = $pdo->prepare($sql);
  11. // 4. 将变量绑定到SQL语句模板的命名占位符上
  12. $movie_condition = 2;
  13. $stmt->bindParam('movie_condition',$movie_condition,PDO::PARAM_INT);
  15. // 5. 执行SQL操作
  16. $stmt->execute();
  17. $i = 1;
  18. while ($name = $stmt->fetchColumn(1)) {
  19.     echo '查到的第' . $i . '个电影名字：' . $name . '<hr>';
  20.     $i++;
  21. }
  23. // 6. 销毁pdo，关闭连接
  24. $pdo = null;

  1. <?php
  2. // 1. 连接数据库
  3. require __DIR__ . '/connect.php';
  5. // 2. 创建SQL语句模板
  6. $sql = 'SELECT * FROM `movie_list` WHERE `movie_condition`= :movie_condition';
  8. // 3. 创建SQL语句对象
  9. $stmt = $pdo->prepare($sql);
  11. // 4. 将变量绑定到SQL语句模板的命名占位符上
  12. $movie_condition = 2;
  13. $stmt->bindParam('movie_condition',$movie_condition,PDO::PARAM_INT);
  15. // 5. 执行SQL操作
  16. $stmt->execute();
  18. // 将结果集中的记录中的字段, 绑定到指定的变量上
  19. $stmt->bindColumn('movie_name', $name);
  20. $stmt->bindColumn('movie_introduction', $intr);
  22. while ($stmt->fetch()) {
  23.     echo '片名：' . $name . '，简介：' . $intr . '<hr>';
  24. }
  26. // 6. 销毁pdo，关闭连接
  27. $pdo = null;





6. 总结

PDO操作数据库的基本流程为：

  • 1 连接数据库,创建pdo对象 $pdo = new PDO($dsn, $username, $password);
  • 2 执行SQL语句完成数据库操作
    • 2.1 创建SQL语句对象: $stmt = $pdo->prepare($sql)
    • 2.2 执行SQL查询: $stmt->execute()
    • 2.3 对执行结果进行解析或进一步处理
  • 3 销毁pdo对象,关闭连接: $pdo = null
上一条：sql 2012 安装问题下一条：根据课堂案例，练习一下mvc的实现原理--1031
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多