登录  /  注册
首页 > 博客列表 > 【PHP】PDO常用的CURD操作
博主信息
博文 94
粉丝 0
评论 0
访问量 89227
专题推荐
更多>
相关推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
【PHP】PDO常用的CURD操作
可乐随笔
原创
1789人浏览过

PDO常用的CURD操作

1.数据库配置文件，示例

  1. <?php
  3. // database.php
  4. // 数据库连接默认参数
  6. return [
  7.     // 数据库的类型
  8.     'type' => 'mysql',
  9.     // 数据库默认主机
  10.     'host' => 'localhost',
  11.     // 默认数据库
  12.     'dbname' => 'dbname',
  13.      // 默认的用户名
  14.     'username' =>  'username',
  15.     // 默认的用户密码
  16.     'password' => 'username',
  17.     // 默认端口号
  18.     'port' => '3306',
  19.     // 默认字符编码集
  20.     'charset' =>  'utf8',
  21. ];

2.数据库连接文件，示例

2.1 获取配置项
2.2 自定义数据库配置
2.3 用自定义数组替换获取的配置项
$config = array_merge($config, $custom);
2.4 解析配置项（将配置项中的数组值解析到变量）
['username'=>$username,'password'=>$password] = $config;
2.5 创建数据源DSN（连接语句对象化）
2.6 创建PDO实例（连接数据库，在此时进行传参）

  1. <?php
  3. // 连接数据库
  5. // 1. 获取配置项
  6. $config = require __DIR__ . '/database.php';
  7. // print_r($config);
  8. // 自定义配置
  9. $custom = [
  10.     // 数据库默认主机
  11.     'host' => 'localhost',
  12.     // 默认数据库
  13.     'dbname' => 'phpedu',
  14.      // 默认的用户名
  15.     'username' =>  'root',
  16.     // 默认的用户密码
  17.     'password' => 'root',
  18. ];
  20. // 数组替换更新
  21. $config = array_merge($config, $custom);
  22. // print_r($config);
  24. // 2. 解析配置项
  25. // ['id'=>$id, 'name'=>$name]=['id'=>1,'name'=>'a'];
  26. ['type'=>$type,'host'=>$host,'dbname'=>$dbname] = $config;
  27. ['username'=>$username,'password'=>$password] = $config;
  28. ['port'=>$port,'charset'=>$charset] = $config;
  29. // echo $type, $username, $charset;
  30. // extract($config);
  32. // 3. 创建数据源DSN
  33. // echo vsprintf('%s,%s,%s', ['php','cn','zhu']);
  34. $tmpl = '%s:host=%s;dbname=%s;port=%s;charset=%s';
  35. $params = [$type,$host,$dbname,$port,$charset];
  36. $dsn = vsprintf($tmpl, $params);
  37. // echo $dsn;
  39. // 4. 创建PDO实例(连接数据库)
  41. try {
  42.     $db = new PDO($dsn, $username, $password);
  43.     // if ($db) {
  44.     //     echo '连接成功';
  45.     // }
  46.     // var_dump($db);
  48.     // 设置结果集的获取模式: 仅返回关联部分
  49.     $db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
  50. } catch (PDOException $e) {
  51.     die('连接失败' . $e->getMessage());
  52. }

3. 连接数据库实例(单一文件)

  1. <?php
  3. // 快速预览
  5. // 1.连接数据库
  6. $db = new PDO('mysql:dbname=phpedu','root','root');
  8. // 2.执行SQL
  9. $stmt = $db->prepare('select id,name,email from user limit 1');
  11. $stmt ->execute();
  12. print_r($stmt->fetch(PDO::FETCH_ASSOC));
  14. // 3.关闭连接
  15. unset($db);

简化版

  1. <?php
  3. // ? 连接数据库
  5. // 1. 连接数据库: PDO类实例
  6. $username = 'root';
  7. $password = 'root';
  9. $dsn = 'mysql:dbname=phpedu';
  11. try {
  12.     $db = new PDO($dsn, $username, $password);
  13.     if ($db) {
  14.         echo '连接成功';
  15.     }
  16. } catch (PDOException $e) {
  17.     die('连接失败' . $e->getMessage());
  18. }

4.数据库操作之：新增（Insert）（命名占位符）

  1. <?php
  3. // ? 新增: INSERT-1
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. // sql: 预处理,sql中的数据使用占位符(参数)
  10. // 参数有二种: (1) 命名占位符 ":email" (2) 匿名占位符: "?"
  11. $sql = 'INSERT user VALUES (null,:uname,:email,:password)';
  12. // ? 创建sql语句对象 PDOStatement的实例
  13. $stmt = $db->prepare($sql);
  14. // var_dump($stmt);
  15. // ? 将具体的值绑定到参数上
  16. $stmt->bindValue('uname', '老张');
  17. $stmt->bindValue('email', 'lz@qq.com');
  18. $stmt->bindValue('password', md5('123'));
  19. // 查看一下预处理sql语句
  20. // $stmt->debugDumpParams();
  22. // ? 执行sql
  23. if ($stmt->execute()) {
  24.     // 成功
  25.     echo '新增成功, 新记录的主键ID = ' . $db->lastInsertId();
  26. } else {
  27.     echo '新增失败';
  28.     print_r($stmt->errorInfo());
  29. }
  32. // 3. 关闭连接(可选)
  33. // unset($db);
  34. // $db = null;

4.数据库操作之：新增2（匿名占位符）

  1. <?php
  3. // ? 新增: INSERT-2
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. // sql: 预处理,sql中的数据使用占位符(参数)
  10. // 参数有二种: (1) 命名占位符 ":email" (2) 匿名占位符: "?"
  11. $sql = 'INSERT user VALUES (null,?,?,?)';
  12. // ? 创建sql语句对象 PDOStatement的实例
  13. $stmt = $db->prepare($sql);
  15. // ? 执行sql
  16. if ($stmt->execute(['小猪', 'xz@php.cn', md5('abc')])) {
  17.     // 成功
  18.     echo '新增成功, 新记录的主键ID = ' . $db->lastInsertId();
  19. } else {
  20.     echo '新增失败';
  21.     print_r($stmt->errorInfo());
  22. }
  24. // 3. 关闭连接(可选)
  25. // unset($db);
  26. // $db = null;

5. 数据库操作之：更新

  1. <?php
  3. // ? 更新: UPDATE
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. $sql = 'UPDATE user SET uname= ?  WHERE id = ?';
  10. // $sql = 'UPDATE user SET uname= ?';
  12. // 检测sql语句中是否存在 where 条件?没有则禁止执行
  13. if (!stristr($sql, 'WHERE')) {
  14.     die('禁止无条件更新');
  15. }
  17. // ? 创建sql语句对象
  18. $stmt = $db->prepare($sql);
  20. // ? 将某个变量绑定到参数上
  21. $stmt->bindParam(1, $uname);
  22. $stmt->bindParam(2, $id);
  23. $uname = '西门庆';
  24. $id = 4;
  26. // ? 执行sql
  28. if ($stmt->execute()) {
  29.     // $stmt->debugDumpParams();
  30.     // 更新成功有二种情况,1.数据变化了,2.数据没有发生变化
  31.     // rowCount(): 返回受影响的记录数量(修改了)
  32.     if ($stmt->rowCount() > 0) {
  33.         echo '更新成功';
  34.     } else {
  35.         echo '没有记录被更新';
  36.     }
  37. } else {
  38.     // echo '更新失败';
  39.     // print_r($stmt->errorInfo());
  41.     die('更新失败: '. $stmt->errorInfo()[2]);
  42. }

6.数据库操作之：删除

  1. <?php
  3. // ? 删除: DELETE
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. $sql = 'DELETE FROM user  WHERE id = ?';
  10. // $sql = 'DELETE FROM user';
  12. // 检测sql语句中是否存在 where 条件?没有则禁止执行
  13. if (!stristr($sql, 'WHERE')) {
  14.     die('禁止无条件删除');
  15. }
  17. // ? 创建sql语句对象
  18. $stmt = $db->prepare($sql);
  20. // ? 执行sql
  22. if ($stmt->execute([4])) {
  23.     if ($stmt->rowCount() > 0) {
  24.         echo '删除成功';
  25.     } else {
  26.         echo '没有记录被删除';
  27.     }
  28. } else {
  29.     die('删除失败: '. $stmt->errorInfo()[2]);
  30. }

7.数据库操作之：查询1

  1. <?php
  3. // ? 查询: SELECT-1
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. $sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
  10. // ? 创建sql语句对象
  11. $stmt = $db->prepare($sql);
  13. // ? 执行sql
  14. if ($stmt->execute([2, 3, 6])) {
  15.     // 查询成功,结果集解析到数组中
  16.     // 1. 逐条: fetch + while
  17.     // 2. 多条: fetchAll + foreach
  18.     // print_r($stmt->fetch());
  19.     // print_r($stmt->fetch());
  20.     // print_r($stmt->fetch());
  21.     // print_r($stmt->fetch(PDO::FETCH_ASSOC));
  22.     // print_r($stmt->fetch(PDO::FETCH_NUM));
  24.     // fetch + while
  25.     while ($user = $stmt->fetch()) {
  26.         print_r($user);
  27.     }
  28. } else {
  29.     die('查询失败: ' . $stmt->errorInfo()[2]);
  30. }

7.数据库操作之：查询2

  1. <?php
  3. // ? 查询: SELECT-1
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. $sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
  10. // ? 创建sql语句对象
  11. $stmt = $db->prepare($sql);
  13. // ? 执行sql
  14. if ($stmt->execute([2, 3, 6])) {
  15.     // 查询成功,结果集解析到数组中
  16.     // 1. 逐条: fetch + while
  17.     // 2. 多条: fetchAll + foreach
  18.     // print_r($stmt->fetch());
  19.     // print_r($stmt->fetch());
  20.     // print_r($stmt->fetch());
  21.     // print_r($stmt->fetch(PDO::FETCH_ASSOC));
  22.     // print_r($stmt->fetch(PDO::FETCH_NUM));
  24.     // fetch + while
  25.     while ($user = $stmt->fetch()) {
  26.         print_r($user);
  27.     }
  28. } else {
  29.     die('查询失败: ' . $stmt->errorInfo()[2]);
  30. }

7.数据库操作之：查询3

  1. <?php
  3. // ? 查询: SELECT-3: 将列名绑定到变量上
  5. // 1. 连接数据库
  6. require __DIR__ . '/config/connect.php';
  8. // 2. 执行操作
  9. $sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
  10. // ? 创建sql语句对象
  11. $stmt = $db->prepare($sql);
  13. // ? 执行sql
  14. if ($stmt->execute([2,3,6])) {
  15.     // 将每一列的值,绑定到指定变量上
  16.     // 三个字段,三个变量
  17.     // 字段的索引,1,2,3,4....
  18.     // $stmt->bindColumn(1, $id);
  19.     // $stmt->bindColumn(2, $uname);
  20.     // $stmt->bindColumn(3, $email);
  22.     // 用字段名称
  23.     $stmt->bindColumn('id', $id);
  24.     $stmt->bindColumn('uname', $uname);
  25.     $stmt->bindColumn('email', $email);
  29.     while ($stmt->fetch()) {
  30.         printf("%d: %s ( %s )\n", $id, $uname, $email);
  31.     }
  32. } else {
  33.     die('查询失败: '. $stmt->errorInfo()[2]);
  34. }
本博文版权归博主所有，转载请注明地址！如有侵权、违法，请联系admin@php.cn举报处理！
全部评论 文明上网理性发言，请遵守新闻评论服务协议
0条评论
作者最新博文
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
app下载
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • 精品班

  • 技术支持

  • 技术咨询

  • 学习群

  • 会员优惠

  • 返回顶部
    • 登录PHP中文网，和优秀的人一起学习！
    全站2000+教程免费学
    微信扫码登录