search

博客列表 >02月11日作业：MySQLi数据操作和多态接口

02月11日作业：MySQLi数据操作和多态接口

李东亚¹⁸⁰³⁹⁵⁴⁰¹²⁰
李东亚¹⁸⁰³⁹⁵⁴⁰¹²⁰原创
2020年02月14日 20:45:01757浏览

作业一

mysqli相关知识：

作业二

mysqli常见的CURD操作
1增加数据：
1、代码：

  1. <?php
  2. namespace part1;
  4. use mysqli;
  5. //连接数据库
  6. $mysql=new mysqli('NewYear.com','NY','123456','newyear.com');
  8. $stmt=$mysql->stmt_init();
  9. $sql="INSERT site_info SET 类型=?,优先级=?,标题=?,url=?,image=?,分类=?,标签=?;";
  11. $data=['测试1',1,'测试标题测试标题1','http://newyear.com','image/001.jpg','无','测试1'];
  13. list($type,$order,$site,$url,$image,$class,$tag)=$data;
  14. $stmt->prepare($sql);
  15. $stmt->bind_param('sisssss',$type,$order,$site,$url,$image,$class,$tag);
  17. $stmt->execute();
  19. if ($stmt->affected_rows===1):
  20.     echo '添加记录成功，新的主键ID:'.$stmt->insert_id;
  21. else:
  22.     echo '添加失败'.$stmt->error;
  23. endif;
  25. $stmt->close();

2、效果图


2、更新数据：
跟新和怎加基本一致只是SQL语句不同，另外mysqli_stmt类中insert_id();在更新下无法使用。
1、核心代码：

  1.     $stmt=$mysql->stmt_init();
  2.     $sql="UPDATE `site_info` SET `标题`=? WHERE id=? ";
  3.     $stmt->prepare($sql);
  4.     $data=['更新测试'，62];
  5.     list($site,$id)=$data;
  6.     $stmt->bind_param('si',$site,$id);

2、效果图


3、删除数据
1、核心代码：

  1. $sql='DELETE FROM `site_info` WHERE `id`=?';
  2. $stmt->prepare($sql);
  3. $id=61;
  4. $stmt->bind_param('i',$id);

2、效果图


4、查询操作
1、用mysqli_stmt类查询：
（1）代码：

  1. <?php
  2. namespace part1;
  4. use mysqli;
  6. $mysql=new mysqli('NewYear.com','NY','123456','newyear.com');
  8. $stmt=$mysql->stmt_init();
  10. $sql='SELECT `id`,`类型`,`优先级`,`标题`,`url`,`image`,`分类`,`标签` FROM `site_info` WHERE `id`>=?';
  12. $stmt->prepare($sql);
  14. $id=59;
  16. $stmt->bind_param('i',$id);
  18. $stmt->execute();
  21. $stmt->bind_result($id,$type,$order,$site,$url,$image,$class,$tag);
  22. //$stmt->fetch();
  23. while($stmt->fetch()):
  24.     echo $id,$type,$order,$site,$url,$image,$class,$tag.'<br>';
  25. endwhile;
  27. $stmt->free_result();
  28. $stmt->close();

（2）、效果图：

2、用mysqli_result类查询：
(1)、代码：

  1. <?php
  2. namespace part1;
  4. use mysqli;
  5. //连接数据库
  6. $mysql=new mysqli('NewYear.com','NY','123456','newyear.com');
  7. //mysqli_stmt类初始化
  8. $stmt=$mysql->stmt_init();
  9. //准备sql语句
  10. $sql='SELECT `id`,`类型`,`优先级`,`标题`,`url`,`image`,`分类`,`标签` FROM `site_info` WHERE `id`>?';
  11. //预处理
  12. $stmt->prepare($sql);
  14. $id=57;
  15. //绑定数据
  16. $stmt->bind_param('i',$id);
  17. //执行
  18. $stmt->execute();
  19. //获取结果返回mysql_result类实例
  20. $result=$stmt->get_result();
  21. //获取数据
  22. //$log=$result->fetch_array();
  23. //$log=$result->fetch_row();
  24. //$log=$result->fetch_assoc();
  25. $logs=$result->fetch_all(MYSQLI_ASSOC);
  26. //处理输出数据
  27. foreach ($logs as $log):
  28.     echo '<pre>'.print_r($log,true).'</pre>';
  29. endforeach;
  30. //echo print_r($log,true);
  31. //$stmt->bind_result($id,$type,$order,$site,$url,$image,$class,$tag);
  32. //while($stmt->fetch()):
  33. //    echo $id,$type,$order,$site,$url,$image,$class,$tag.'<br>';
  34. //endwhile;
  36. //释放结果集
  37. $result->free_result();
  38. //关闭数据库
  39. $stmt->close();

（2）、效果图

作业三

1、类接口：

  1. <?php
  2. namespace part1;
  4. //数据库连接常量
  6. interface iDbParam
  7. {
  8.     const HOST='NewYear.com';
  9.     const TYPE='mysql';
  10.     const DBNAME='newyear.com';
  11.     const USER_NAME='root';
  12.     const PASSWORD='root';
  13.     const CHARSET='utf8';
  14.     const PORT='3306';
  15. }
  16. //构造接口方法
  18. interface iDbLink
  19. {
  20.     public function __construct(...$linkParams);
  21. }
  23. interface iCURD extends iDbParam,iDbLink
  24. {
  25.    public function insert(array $data);
  27.    public function update(array $data, string $where);
  29.    public function delete(string $where);
  31.    public function select(string $where);
  32. }

（2）PDO方法代码：

  1. <?php
  2. namespace part1;
  4. use PDO;
  6. require '0211-1.php';
  8. class Db_PDO implements iCURD
  9. {
  10.     private $pdo=null;
  11.     public function __construct(...$linkParams)
  12.     {
  13.         list($dsn,$username,$password)=$linkParams;
  14.         $this->pdo=new PDO($dsn,$username,$password);
  15.     }
  16.     public function insert(array $data)
  17.     {
  18.         $sql='INSERT site_info SET 类型=?,优先级=?,标题=?,url=?,image=?,分类=?,标签=?;';
  19.         $stmt=$this->pdo->prepare($sql);
  20.         $stmt->execute($data);
  21.         return $stmt->rowCount()===1 ? '新增成功' : '新增失败';
  22.     }
  24.     public function update(array $data, string $where)
  25.     {
  26.         $params='';
  27.         foreach ($data as $key=>$value){
  28.             $params.="`{$key}`='{$value}',";
  29.         }
  30.         $params=rtrim($params,',');
  31.         $sql="UPDATE `site_info` SET {$params} WHERE {$where}";
  32. //        die($sql);
  33.         $stmt=$this->pdo->prepare($sql);
  34. //        die($stmt);
  35.         $stmt->execute();
  36.         return $stmt->rowCount()===1 ? '更新成功' : '更新失败';
  37.     }
  39.     public function delete(string $where)
  40.     {
  41.         $sql="DELETE FROM `site_info` WHERE {$where}";
  42. //        die($sql);
  43.         $stmt=$this->pdo->prepare($sql);
  44.         $stmt->execute();
  45.         return $stmt->rowCount()===1 ? '删除成功' : '删除失败';
  46.     }
  48.     public function select(string $where)
  49.     {
  50.         $where= empty($where) ? $where : 'WHERE '.$where;
  51.         $sql="SELECT * FROM `site_info` {$where}";
  52. //        die($sql);
  53.         $stmt = $this->pdo->prepare($sql);
  54. //        die($stmt);
  55.         $stmt->execute();
  56.         return $stmt->fetchAll(PDO::FETCH_ASSOC);
  57.     }
  58. }

（3）MySQLi方法代码：

  1. <?php
  2. namespace part1;
  4. require '0211-1.php';
  6. use mysqli;
  8. class MySQL implements iCURD
  9. {
  10.     private $mysqli = null;
  11.     public function __construct(...$linkParams)
  12.     {
  13.         list($host,$username,$password,$dbname)=$linkParams;
  14.         $this->mysqli=new mysqli($host,$username,$password,$dbname);
  15.         $this->mysqli->set_charset('utf8');
  16.     }
  18.     public function insert(array $data){
  19.         $sql='INSERT site_info SET 类型=?,优先级=?,标题=?,url=?,image=?,分类=?,标签=?;';
  20.         $stmt=$this->mysqli->stmt_init();
  21.         $stmt->prepare($sql);
  22.         list($type,$order,$site,$url,$image,$class,$tag)=$data;
  23.         $stmt->bind_param('sisssss',$type,$order,$site,$url,$image,$class,$tag);
  24.         $stmt->execute();
  25.         return $stmt->affected_rows===1 ? '增加成功' : '增加失败';
  26.     }
  28.     public function update(array $data, string $where)
  29.     {
  30.         $params='';
  31.         foreach ($data as $key=>$value){
  32.             $params.="`{$key}`='{$value}',";
  33.         }
  34.         $params=rtrim($params,',');
  36.         $sql="UPDATE `site_info` SET {$params} WHERE {$where}";
  37. //        die($sql);
  38.         $stmt=$this->mysqli->stmt_init();
  39.         $stmt->prepare($sql);
  40.         $stmt->execute();
  41.         return $stmt->affected_rows===1 ? '更新成功' : '更新失败';
  43.     }
  45.     public function delete(string $where)
  46.     {
  47.         $sql="DELETE FROM `site_info` WHERE {$where}";
  48.         $stmt=$this->mysqli->stmt_init();
  49.         $stmt->prepare($sql);
  50.         $stmt->execute();
  51.         return $stmt->affected_rows===1 ? '删除成功' : '删除失败';
  52.     }
  54.     public function select(string $where)
  55.     {
  56.         $where= empty($where) ? $where : 'WHERE '.$where;
  57.         $sql="SELECT * FROM `site_info`".$where;
  58.         $stmt=$this->mysqli->stmt_init();
  59.         $stmt->prepare($sql);
  60.         $stmt->execute();
  61.         return $stmt->get_result();
  62.     }
  64. }

（4）通用类：数据库操作：

  1. <?php
  2. namespace part1;
  4. use part1\iCURD;
  6. class DB
  7. {
  8.     public static function insert(iCURD $db, array $data)
  9.     {
  10.         return $db->insert($data);
  11.     }
  13.     public static function update(iCURD $db, array $data,string $where)
  14.     {
  15.         return $db->update($data,$where);
  16.     }
  18.     public static function delete(iCURD $db,string $where)
  19.     {
  20.         return $db->delete($where);
  21.     }
  23.     public static function select(iCURD $db,string $where)
  24.     {
  25.         return $db->select($where);
  26.     }
  27. }

（5）操作代码：
a、pdo操作数据库：

  1. <?php
  3. //PDO操作数据库
  4. namespace part1;
  6. require '0211-2.php';
  7. require '0211-3.php';
  9. $dsn=$dsn = iDbParam::TYPE . ':host='.'NewYear.com'. ';dbname='.'newyear.com'  . ';charset='.iDbParam::CHARSET;
  10. $link=new Db_PDO($dsn,'NY','123456');
  12. //echo DB::insert($link,['测试0211',1,'测试标题测试标题0211','http://newyear.com','image/001.jpg','无','测试1']);
  14. //echo DB::update($link,['类型'=>'PDO测试'],'`id`=62');
  16. //echo DB::delete($link,'id=64');
  18. foreach (DB::select($link,'id>54') as $arr)
  19. {
  20.     echo '<pre>'.print_r($arr,true).'</pre>>';
  21. }

b、mysqli操作数据库：

  1. <?php
  3. namespace part1;
  5. require '0211-21.php';
  7. require '0211-3.php';
  10. $link = new MySQL('NewYear.com', 'NY', '123456','newyear.com');
  12. //echo DB::insert($link,['测试mysqli',1,'测试标题测试标题0211','http://newyear.com','image/001.jpg','无','测试1']);
  14. //echo DB::update($link,['类型'=>'PDO-测试'],'`id`=62');
  16. //echo DB::delete($link,'id=63');
  18. $result=DB::select($link,'id=59');
  20. $results=$result->fetch_all(MYSQLI_ASSOC);
  22. echo '<pre>'.print_r($results,true).'</pre>';

四：补充

mysql_result:
$result->num_rows:返回结果的记录行数；

上一条：实时微信域名检测API接口的实现方式下一条：前端下拉框2
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多