Community
Learn
Tools Library
AI Tools
Leisure
search
English
Home > List of blog posts > 02月11日作业：MySQLi数据操作和多态接口
Blogger Information
Blog 145
fans 7
comment 7
visits 165382
Special Recommendation
More>
Related recommendations
Popular Tutorials
More>
Related Tutorials
Popular Recommendations
Latest courses
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template
02月11日作业：MySQLi数据操作和多态接口
李东亚¹⁸⁰³⁹⁵⁴⁰¹²⁰
Original
758 people have browsed it

作业一

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:返回结果的记录行数；

Correcting teacher：天蓬老师天蓬老师

Correction status：qualified

Teacher's comments：mysqli中有一些数据,即可以用方法, 也可以用属性获取,要注意, 推荐用方法
Statement of this Website
The copyright of this blog article belongs to the blogger. Please specify the address when reprinting! If there is any infringement or violation of the law, please contact admin@php.cn Report processing!
All comments Speak rationally on civilized internet, please comply with News Comment Service Agreement
0 comments
Author's latest blog post