search

博客列表 >2.11号作业MYSQLI

2.11号作业MYSQLI

- 迷舍人
- 迷舍人原创
2020年02月13日 22:15:19660浏览

新增操作

  1. <?php
  2. namespace chapter2;
  4. use mysqli;
  5. // mysqli面向对象操作数据库
  7. // 新增操作
  9. // 1.链接数据库
  10. // mysql(主机名,用户名,密码,默认数据库);
  11. $mysqli = new mysqli('localhost','root','root','phpedu');
  13. // 2.执行sql语句
  14. $sql = "INSERT `users` SET `name`=?, `email`=?, `password`=?, `register_time`=?";
  15. // 使用的是预处理方式,防止sql注入
  16. $stmt = $mysqli->stmt_init();
  18. // 创建sql语句对象
  19. $stmt->prepare($sql);
  21. // $stmt->bind_param('参数类型',参数列表....);
  22. $user = ['admin','admin@qq.cn',sha1('123456'),time()];
  23. list($name,$email,$password,$register_time) = $user;
  24. $stmt->bind_param('sssi',$name,$email,$password,$register_time);
  25. //执行
  26. $stmt->execute();
  27. // 3.处理执行结果
  28. if($stmt->affected_rows === 1){
  29.     echo '添加成功,新记录的主键ID:'.$stmt->insert_id;
  30. }else{
  31.     echo '添加失败'.$stmt->error;
  32. }
  33. // 4.结束操作
  34. $stmt->close();

更新操作

  1. <?php
  2. namespace chapter2;
  4. use mysqli;
  5. // mysqli面向对象操作数据库
  7. // 更新操作
  9. // 1.链接数据库
  10. // mysql(主机名,用户名,密码,默认数据库);
  11. $mysqli = new mysqli('localhost','root','root','phpedu');
  13. // 2.执行sql语句
  14. $sql = "UPDATE `users` SET `name`=?, `email`=? where `id`=? ";
  15. // 使用的是预处理方式,防止sql注入
  16. $stmt = $mysqli->stmt_init();
  18. // 创建sql语句对象
  19. $stmt->prepare($sql);
  21. // $stmt->bind_param('参数类型',参数列表....);
  22. $user = ['admin888','admin@qq.cn',8];
  23. list($name,$email,$id) = $user;
  24. $stmt->bind_param('ssi',$name,$email,$id);
  25. //执行
  26. $stmt->execute();
  27. // 3.处理执行结果
  28. if($stmt->affected_rows === 1){
  29.     echo '修改成功';
  30. }else{
  31.     echo '修改失败'.$stmt->error;
  32. }
  33. // 4.结束操作
  34. $stmt->close();

删除操作

  1. <?php
  2. namespace chapter2;
  4. use mysqli;
  5. // mysqli面向对象操作数据库
  7. // 删除操作
  9. // 1.链接数据库
  10. // mysql(主机名,用户名,密码,默认数据库);
  11. $mysqli = new mysqli('localhost','root','root','phpedu');
  13. // 2.执行sql语句
  14. $sql = "DELETE from `users` where `id`=? ";
  15. // 使用的是预处理方式,防止sql注入
  16. $stmt = $mysqli->stmt_init();
  18. // 创建sql语句对象
  19. $stmt->prepare($sql);
  21. // $stmt->bind_param('参数类型',参数列表....);
  22. $id = 8;
  23. $stmt->bind_param('i',$id);
  24. //执行
  25. $stmt->execute();
  26. // 3.处理执行结果
  27. if($stmt->affected_rows === 1){
  28.     echo '删除成功';
  29. }else{
  30.     echo '删除失败'.$stmt->error;
  31. }
  32. // 4.结束操作
  33. $stmt->close();

stmt对象查询

  1. <?php
  2. namespace chapter2;
  4. use mysqli;
  5. // mysqli面向对象操作数据库
  7. // 查询1.使用stmt对象
  9. // 1.链接数据库
  10. // mysql(主机名,用户名,密码,默认数据库);
  11. $mysqli = new mysqli('localhost','root','root','phpedu');
  13. // 2.执行sql语句
  14. $sql = "SELECT `id`,`name`,`email` from  `users` where `id`>? ";
  15. // 使用的是预处理方式,防止sql注入
  16. $stmt = $mysqli->stmt_init();
  18. // 创建sql语句对象
  19. $stmt->prepare($sql);
  21. // $stmt->bind_param('参数类型',参数列表....);
  22. $id = 2;
  23. $stmt->bind_param('i',$id);
  24. //执行
  25. $stmt->execute();
  26. // 3.处理执行结果
  27. // bind_result():将结果集中的字段|列，绑定到指定的变量上
  28. $stmt->bind_result($id,$name,$email);
  29. // 遍历结果集 fetch()：获取当前的记录，并将记录指针自动移到下一条记录
  30. while($stmt->fetch()){
  31.     echo "$id:$name ---> $email <br>";
  32. }
  33. // 4.结束操作
  34. // 释放结果集
  35. $stmt->free_result();
  36. // 关闭数据库链接
  37. $stmt->close();

结果集查询

  1. <?php
  2. namespace chapter2;
  4. use mysqli;
  5. // mysqli面向对象操作数据库
  7. // 查询2.使用结果集对象
  9. // 1.链接数据库
  10. // mysql(主机名,用户名,密码,默认数据库);
  11. $mysqli = new mysqli('localhost','root','root','phpedu');
  13. // 2.执行sql语句
  14. $sql = "SELECT `id`,`name`,`email` from  `users` where `id`>? ";
  15. // 使用的是预处理方式,防止sql注入
  16. $stmt = $mysqli->stmt_init();
  18. // 创建sql语句对象
  19. $stmt->prepare($sql);
  21. // $stmt->bind_param('参数类型',参数列表....);
  22. $id = 4;
  23. $stmt->bind_param('i',$id);
  24. //执行
  25. $stmt->execute();
  27. // 获取到结果集对象
  28. $result = $stmt->get_result();
  29. // var_dump($result);
  30. // 3.处理执行结果
  31. // 获取一条数据，返回：索引+关联
  32. // $user = $result->fetch_array();
  33. // 获取一条数据，返回：索引
  34. // $user = $result->fetch_row();
  35. // 获取一条数据，返回：关联
  36. // $user = $result->fetch_assoc();
  37. while($user = $result->fetch_assoc()){
  38.     echo "{$user['id']} : {$user['name']} ===> {$user['email']} <br>";
  39. }
  40. echo '<hr>';
  41. // 数据表指针复位  归零
  42. $result->data_seek(0);
  43. // 一次性获取到所有记录 $result->fetch_all()
  44. $users = $result->fetch_all(MYSQLI_ASSOC);
  45. // print_r($users);
  46. foreach($users as $user2){
  47.     echo "{$user2['id']} : {$user2['name']} ===> {$user2['email']} <br>";
  48. }
  51. // 4.结束操作
  52. // 释放结果集
  53. $result->free_result();
  54. // 关闭数据库链接
  55. $stmt->close();

手写

PDO为例多态

代码部分

  1. <?php
  2. # 接口实战: 使用PDO/MySQLi实现数据库的多态操作
  4. namespace chapter3;
  6. // 配置数据库的连接参数: 接口常量
  7. interface iDbParam
  8. {
  9.     const HOST = 'localhost';
  10.     const TYPE = 'mysql';
  11.     const DBNAME = 'phpedu';
  12.     const USER_NAME = 'root';
  13.     const PASSWORD = 'root';
  14.     const CHARSET = 'utf8';
  15.     const PORT = '3306';
  16. }
  18. // 接口构造方法
  19. interface iDbLink
  20. {
  21.     // 接口中允许构造方法
  22.     public function __construct(...$linkParams);
  23. }
  25. // 接口方法: 后面的代码就是用下面的这个主接口
  26. // 接口之间允许继承, 而且允许多重继承
  27. interface iCURD extends iDbLink, iDbParam
  28. {
  29.     // 新增
  30.     public function insert(array $data);
  32.     // 查询
  33.     public function select(string $where = '');
  35.     // 更新
  36.     public function update(array $data, string $where);
  38.     // 删除
  39.     public function delete(string $where);
  40. }
  1. <?php
  3. namespace chapter3;
  5. // 用PDO来实现数据库操作
  6. use PDO;
  8. // 加载iCURD的接口声明
  9. require 'demo2.php';
  11. class Db_PDO implements iCURD
  12. {
  13.     // 连接对象
  14.     private $pdo = null;
  16.     // 实现接口中的构造方法:连接数据库
  17.     public function __construct(...$linkParams)
  18.     {
  19.         list($dsn, $username, $password) = $linkParams;
  20.         $this->pdo = new PDO($dsn, $username, $password);
  21.     }
  22.     // 新增
  23.     public function insert(array $data)
  24.     {
  25.         $sql = "INSERT `users` SET `name`=?, `email`=?,`password`=?,`register_time`=?";
  26.         $stmt = $this->pdo->prepare($sql);
  27.         $stmt->execute($data);
  28.         return $stmt->rowCount() === 1 ? '新增成功' : '新增失败';
  29.     }
  31.     // 查询
  32.     public function select(string $where = '')
  33.     {
  34.         $where = empty($where) ? $where : ' WHERE ' . $where;
  35.         $sql = "SELECT * FROM `users` {$where}";
  36.         $stmt = $this->pdo->prepare($sql);
  37.         $stmt->execute();
  38.         return $stmt->fetchAll(PDO::FETCH_ASSOC);
  39.     }
  41.     // 更新
  42.     public function update(array $data, string $where)
  43.     {
  44.         // 设置更新参数
  45.         $params = '';
  46.         foreach ($data as $key => $value) {
  47.             $params .= "`{$key}` = '{$value}', ";
  48.         }
  49.         // 将最后的", "去掉
  50.         $params = rtrim($params, ', ');
  52.         // 执行更新
  53.         $sql = "UPDATE `users` SET {$params} WHERE {$where}";
  54.         $stmt = $this->pdo->prepare($sql);
  55.         $stmt->execute();
  56.         return $stmt->rowCount() === 1 ? '更新成功' : '更新失败';
  57.     }
  59.     // 删除
  60.     public function delete(string $where)
  61.     {
  62.         $sql = "DELETE FROM  `users` WHERE {$where}";
  63.         $stmt = $this->pdo->prepare($sql);
  64.         $stmt->execute();
  65.         return $stmt->rowCount() === 1 ? '删除成功' : '删除失败';
  66.     }
  67. }

通用类

  1. <?php
  2. namespace chapter3;
  3. // 通用类: 数据库操作,面向接口实现多态, 动态的支持PDO, MySQLi
  4. use chapter3\iCURD;
  5. class DB
  6. {
  7.     // 新增
  8.     public static function insert(iCURD $db, array $data)
  9.     {
  10.         return $db->insert($data);
  11.     }
  13.     // 查询
  14.     public static function select(iCURD $db, string $where = '')
  15.     {
  16.         return $db->select($where);
  17.     }
  19.     // 更新
  20.     public static function update(iCURD $db, array $data, string $where='')
  21.     {
  22.         return $db->update($data, $where);
  23.     }
  25.     // 删除
  26.     public static function delete(iCURD $db, string $where='')
  27.     {
  28.         return $db->delete($where);
  29.     }
  30. }

pdo操作 接口实现

  1. <?php
  2. namespace chapter3;
  3. // 使用PDO来操作数据库: 接口实现
  5. // 加载PDO操作类: DB_pdo
  6. require 'demo3.php';
  7. // 加载数据库的通用类
  8. require 'demo5.php';
  10. // 先创建DSN
  11. $dsn = iDbParam::TYPE . ':host='.iDbParam::HOST . ';dbname=' . iDbParam::DBNAME . ';charset='.iDbParam::CHARSET;
  13. $link = new DB_pdo($dsn, iDbParam::USER_NAME, iDbParam::PASSWORD);
  15. // // 测试新增操作
  16. echo DB::insert($link, ['郭靖', 'gunjin@php.cn', sha1('123456'), time()]);
  18. // 测试查询
  19. // foreach (DB::select($link, 'id > 2') as $user) {
  20. //     echo "{$user['id']} -- {$user['name']} -- {$user['email']} <br>";
  21. // }
  23. // 更新测试
  24. // echo DB::update($link, ['name'=>'朱老师', 'email'=>'zhulaoshi@php.cn'], 'id=10');
  26. // 删除操作
  27. // echo DB::delete($link,'id=10');
上一条：什么是单点登录，主要会应用于哪些场景？下一条：PHP基础 类与对象基本知识------PHP培训十期线上班 学号：510251 01月15日作业
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多