search

博客列表 >0211作业+mysqli操作数据库与接口实战+10期线上班

0211作业+mysqli操作数据库与接口实战+10期线上班

江川林
江川林原创
2020年02月18日 13:39:48554浏览

MYSQLI操作数据库

以下是增加操作

  1. <?php
  2. namespace mysql;
  3. use mysqli;
  4. //添加
  6. //用mysqli来进行数据库操作
  7. //链接数据库
  8. $mysqli = new mysqli('localhost','root','root','phpedu');
  10. //数据库操作
  11. //初始化返回预处理对象
  12.  $stmt = $mysqli->stmt_init();
  13. // 准备SQL执行语句
  14. $sql = "INSERT staffs SET name=?,age=?,sex=?,position=?,mobile=?,hiredate=?" ;
  15. //创建sql语句对象
  16. $stmt->prepare($sql);
  17. //var_dump($stmt);
  18. //绑定参数
  19. $user = ['小江',23,1,'学生',1111111,2222222];
  20. list($name,$age,$sex,$position,$mobile,$hiredate) = $user;
  21. $stmt->bind_param('siisii',$name,$age,$sex,$position,$mobile,$hiredate);
  22. //执行
  23. $stmt->execute();
  24. //处理执行结果
  25. if($stmt->affected_rows === 1){
  26.     echo '添加成功,'. '受影响的条数为：'. $stmt->affected_rows;
  27. }else {
  28.     echo '添加失败'.$stmt->error;
  29. }
  31. //关闭数据库
  32. $mysqli->close();

以下是更改操作

  1. <?php
  2. namespace mysql;
  3. use mysqli;
  4. //更新/改
  6. //用mysqli来进行数据库操作
  7. //链接数据库
  8. $mysqli = new mysqli('localhost','root','root','phpedu');
  10. //数据库操作
  11. //初始化返回预处理对象
  12. $stmt = $mysqli->stmt_init();
  13. // 准备SQL执行语句
  14. //$sql = 'UPDATE `staffs` SET `name`=?,`age`=? WHERE  `id`=?';
  15. $sql = 'UPDATE `staffs` SET  `name`=?,`age`=? WHERE `id`>=?';
  16. //创建sql语句对象
  17. $stmt->prepare($sql);
  18. //var_dump($stmt);
  19. //绑定参数
  20. $user = ['小王',20,14];
  21. list($name,$age,$id) = $user;
  22. $stmt->bind_param('sii',$name,$age,$id);
  23. //执行
  24. $stmt->execute();
  25. //处理执行结果
  26. if($stmt->affected_rows > 0){
  27.     echo '更新成功,';
  28. }else {
  29.     echo '更新失败'.$stmt->error;
  30. }
  32. //关闭数据库
  33. $mysqli->close();

以下是删除操作

  1. <?php
  2. namespace mysql;
  3. use mysqli;
  4. //删除
  6. //用mysqli来进行数据库操作
  7. //链接数据库
  8. $mysqli = new mysqli('localhost','root','root','phpedu');
  10. //数据库操作
  11. //初始化返回预处理对象
  12. $stmt = $mysqli->stmt_init();
  13. // 准备SQL执行语句
  14. //$sql = 'UPDATE `staffs` SET `name`=?,`age`=? WHERE  `id`=?';
  15. $sql = 'DELETE FROM  `staffs` WHERE `id`>=?';
  16. //创建sql语句对象
  17. $stmt->prepare($sql);
  18. //var_dump($stmt);
  19. //绑定参数
  20. $user = [14];
  21. list($id) = $user;
  22. $stmt->bind_param('i',$id);
  23. //执行
  24. $stmt->execute();
  25. //处理执行结果
  26. if($stmt->affected_rows > 0){
  27.     echo '删除成功,';
  28. }else {
  29.     echo '删除失败'.$stmt->error;
  30. }
  32. //关闭数据库
  33. $mysqli->close();

以下是查询操作

  1. <?php
  2. namespace mysql;
  3. use mysqli;
  4. //查询操作
  5. //STMT查询操作
  6. //连接数据库
  7. $mysqli = new mysqli('localhost','root','root','phpedu');
  8. //var_dump($mysqli);
  9. //创建SQL语句
  10. $sql = 'SELECT `id`,`name`,`sex` FROM `staffs` ';
  11. //创建预处理对象
  12. $stmt = $mysqli->stmt_init();
  13. $stmt->prepare($sql);
  14. //执行
  15. $stmt->execute();
  16. //处理执行结果
  17. //绑定结果集
  18. $stmt->bind_result($id,$name,$sex);
  19. //遍历结果集
  20. //2，循环结果遍历
  21. while ($stmt->fetch()){
  22.     if ($sex ==1 ) {
  23.         echo "$id 号选手是:$name,性别男 '<br>'";
  24.     }else{
  25.         echo "$id 号选手是:$name, 性别女'<br>' ";
  26.     }
  27. }

接口与多态实战

创建基础接口

  1. <?php
  2. namespace chapterA;
  3. //创建基础接口_接口常量
  4. interface iPARAM
  5. {
  6.     const SDN = 'mysql';
  7.     const HOST = 'localhost';
  8.     const USERNAME = 'root';
  9.     const PASSWORD = 'root';
  10.     const CHARSET = 'utf8';
  11.     const DBNAME = 'phpedu';
  12. }
  14. //创建接口方法——构造函数，连接数据库
  15. interface iMYSQL
  16. {
  17.     public function __construct(...$link);
  18. }
  19. //进行接口继承，以后就用以下主接口
  20. interface iCURD extends iPARAM, iMYSQL
  21. {
  22. //    增
  23.     public function insert(array $data);
  24. //    删
  25.     public function delete(string $where);
  26. //    改
  27.     public function update(array $data,string $where);
  28. //    查
  29.     public function select(string $where);
  30. }

实现基础接口PDO

  1. <?php
  2. namespace chapterA;
  3. //用PDO操作数据库
  4. use PDO;
  5. //实现主接口
  6. require 'demo8.php';
  7. class PDO_mysql implements iCURD
  8. {
  9.     //连接对象
  10.     private $pdo = '';
  11.     //连接数据库
  12.     public function __construct(...$link)
  13.     {
  14.         list($dsn,$username,$password) = $link;
  15.        $this->pdo = new PDO($dsn,$username,$password);
  16.     }
  17. //    增
  18.     public function insert(array $data)
  19.     {
  20.         $sql = "INSERT `users` SET `name`=?,`email`=?,`password`=?,`register_time`=?";
  21.         $stmt = $this->pdo->prepare($sql);
  22.         $stmt->execute($data);
  23.         return $stmt->rowCount() === 1 ? '添加成功' : '添加失败' ;
  24.     }
  25. //    删
  26.     public function delete(string $where)
  27.     {
  28.         $sql = "DELETE FROM `users` WHERE {$where }" ;
  29.         $stmt = $this->pdo->prepare($sql);
  30.         $stmt->execute();
  31.         return $stmt->rowCount() === 1 ? '删除成功' : '删除失败' ;
  32.     }
  33. //    改
  34.     public function update(array $data,string $where)
  35.     {
  36. //        获取输入数据并转化为更新参数
  37.         $params = '';
  38.         foreach ($data as $key => $value){
  39.             $params .= "`$key`= '{$value}' ,";
  40.         }
  41. //        去除右边的‘，’；
  42.         $params = rtrim($params, ',');
  44. //        执行
  45.         $sql = "UPDATE `users` SET  {$params} WHERE  {$where}";
  46.         $stmt = $this->pdo->prepare($sql);
  47.         $stmt->execute();
  48.         return $stmt->rowCount() === 1 ? '更改成功' : '更改失败' ;
  49.     }
  50. //    查
  51.     public function select(string $where)
  52.     {
  53.         $where = empty($where) ? $where : 'WHERE' . $where;
  54.         $sql = "SELECT * FROM `users` {$where}";
  55.         $stmt = $this->pdo->prepare($sql);
  56.         $stmt->execute();
  57.         return $stmt->fetchAll(PDO::FETCH_ASSOC);
  58.     }
  59. }

实现基础接口Mysqli

  1. <?php
  2. namespace chapterA;
  3. //用mysqli操作数据库
  4. use mysqli;
  5. //实现主接口
  6. require 'demo8.php';
  7. class Mysqli_mysql implements iCURD
  8. {
  9.     //连接对象
  10.     private $mysqli = '';
  11.     //连接数据库
  12.     public function __construct(...$link)
  13.     {
  14.         list($host,$username,$password,$dbname) = $link;
  15.         $this->mysqli = new mysqli($host,$username,$password,$dbname);
  16.         //设置默认字符集
  17.         $this->mysqli->set_charset('utf8');
  18.     }
  19. //    增
  20.     public function insert(array $data)
  21.     {
  22.         $sql = 'INSERT `users` SET `name`=?,`email`=?,`password`=?,`register_time`=? ';
  23.         $stmt = $this->mysqli->prepare($sql);
  24.         list($name,$email,$password,$register_time) = $data;
  25.         $stmt->bind_param('sssi',$name,$email,$password,$register_time);
  26.         $stmt->execute();
  27.         return $stmt->affected_rows === 1 ? '添加成功' : '添加失败' ;
  28.     }
  29. //    删
  30.     public function delete(string $where)
  31.     {
  32.         $sql = "DELETE FROM `users` WHERE {$where }" ;
  33.         $stmt = $this->mysqli->prepare($sql);
  34.         $stmt->execute();
  35.         return $stmt->affected_rows === 1 ? '删除成功' : '删除失败' ;
  36.     }
  37. //    改
  38.     public function update(array $data,string $where)
  39.     {
  40.         $params = ' ';
  41.         foreach ($data as $key=>$value){
  42.             $params .= "`{$key}` = '{$value}' ,";
  43.         }
  44.         $params = rtrim($params, ',');
  45.         $sql = "UPDATE `users` SET  $params WHERE $where ";
  46.         $stmt = $this->mysqli->prepare($sql);
  47.         $stmt->execute();
  48.         return $stmt->affected_rows === 1 ? '更改成功' : '更改失败' ;
  49.     }
  50. //    查
  51.     public function select( string $where)
  52.     {
  53.         $where = empty($where) ? $where : 'WHERE' . $where;
  54.         $sql = "SELECT * FROM `users` {$where}";
  55.         $stmt = $this->mysqli->prepare($sql);
  56.         $stmt->execute();
  57.         return $stmt->get_result();
  58.     }
  59. }

创建通用类

  1. <?php
  2. namespace chapterA;
  3. use chapterA\iCURD;
  5. //通用类，数据库操作，面向接口实现多态
  6. class DB
  7. {
  8.     //    增
  9.     public function insert(iCURD $db, array $data){
  10.         return $db->insert($data);
  11.     }
  12. //    删
  13.     public function delete(iCURD $db,string $where){
  14.         return $db->delete($where);
  15.     }
  16. //    改
  17.     public function update(iCURD $db,array $data,string $where){
  18.         return $db->update($data,$where);
  19.     }
  20. //    查
  21.     public function select(iCURD $db,string $where){
  22.         return $db->select($where);
  23.     }
  24. }

进行数据库操作

  1. <?php
  2. //使用PDO操作数据库：接口实现
  3. namespace chapterA;
  4. use PDO;
  5. //加载PDO接口
  6. require 'demo9.php';
  7. //加载通用类
  8. require 'demo11.php';
  10. //创建DSN
  11. $dsn = iPARAM::SDN.':host='.iPARAM::HOST.';dbname='.iPARAM::DBNAME.';';
  12. //连接数据库
  13. $link =  new PDO_mysql($dsn,PDO_mysql::USERNAME,PDO_mysql::PASSWORD);
  14. //var_dump($link);
  15. //die();
  16. //测试增加操作
  17. //$pdop = new DB();
  18. //echo $pdop->insert($link,['小江','jiang@php.cn',sha1('123456'),time()]);
  19. //测试删除操作
  20. //$pdop = new DB();
  21. //echo $pdop->delete($link,'`id`=9');
  22. //测试更新数据
  23. //$pdop = new DB();
  24. //echo $pdop->update($link,['name'=>'小李','email'=>'jiang@php.cn'],'id=7');
  25. //测试查询操作
  26. $pdop = new DB();
  27. foreach ($pdop->select($link,'`id`>2') as $user){
  28.     echo "{$user['id']} -- {$user['name']} -- {$user['email']} <br>";
  29. }

手写mysqli_result相关类用途

上传不起，一直显示未发现，，，

上一条：补作业——0705作业下一条：命名空间完全限定名称与别名导入
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多