Community Learn Tools Library Leisure
search
English
Home > List of blog posts > PHP中MySQLi常见的CURD操作以及接口多态的实现--***十期线上班
Blogger Information
Blog 22
fans 1
comment 1
visits 22268
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
PHP中MySQLi常见的CURD操作以及接口多态的实现--***十期线上班
Miss灬懒虫
Original
1422 people have browsed it

PHP中MySQLi常见的CURD操作以及接口多态的实现

学习总结

在本次学习内容的实践过程中，发现Mysqli相对于PDO的要简洁一些，而且mysql_result的结果集的操作个人感觉也比较简单。

其次，就是无论是PDO还是MySQLi，在访问数据库的步骤上基本是一致的，细节上略有差别而已。

最后，对于接口的多态实现，其本质上，还是利用了接口之间允许继承，并且可以多继承的特性。与此同时，也因为接口仅仅是定义，也就是说接口具备一个接口，允许有多个类进行不同的实现的特性。正是因为这些特性，接口才能很好地实现PHP面向对象开发中的多态。

以上仅代表个人观点哦！ - _ -

数据库

mysqli 面向对象操作-运行效果

mysqli 面向对象操作-代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 10:57
  7.  */
  9. namespace Mysql_data;
  11. use mysqli;
  13. //mysqli 面向对象操作数据库
  15. class MySQLi_Basics{
  17.     //新增
  18.     public function inter_SQL(){
  20.         //1.创建mysqli对象，连接数据库
  21.         $mysqli=new mysqli('localhost','root','root888','test');
  23.         //2.传入需要---执行的SQL语句
  24.         $sql = 'INSERT `tf_users` SET `f_name`=?, `f_password`=?,`f_email`=?,`f_phone`=?,`f_regtime`=?;';
  26.         //3.通过stmt_init(),实例化一个预处理对象，防止SQL注入攻击
  27.         $stmt=$mysqli->stmt_init();
  29.         //3.1 使用预处理对象下的prepare()方法，将SQl注入到预处理对象中
  30.         $stmt->prepare($sql);
  32.         //参数
  33.         $user = ['李木子', sha1('5649725'), 'li_muzi@mayituyu.cn', '1786411111',date('yy-m-d h:i:s',time())];
  34.         list($name, $password, $email,$phone,$regtime) = $user;
  36.         // 使用预处理对象的 bind_param('参数的类型', 参数列表.....)方法，绑定参数到其中
  37.         $stmt->bind_param('sssss', $name, $password, $email, $phone,$regtime);
  39.         // 准备完成---执行
  40.         $stmt->execute();
  42.         // 4. 处理执行的结果
  43.         if ($stmt->affected_rows === 1) :
  44.             echo '添加成功, 新记录的主键id: ' . $stmt->insert_id;
  45.         else :
  46.             echo '添加失败' . $stmt->error;
  47.         endif;
  49.         // 5. 结束操作
  50.         // 关闭数据库连接
  51.         $stmt->close();
  52.     }
  54.     //更新
  55.     public function update_SQL(){
  57.         $mysqli=new mysqli('localhost','root','root888','test');
  58.         $sql = "UPDATE `tf_users` SET `f_phone`=?,`f_regtime`=? WHERE `f_id`=?;";
  60.         //3.通过stmt_init(),实例化一个预处理对象，防止SQL注入攻击
  61.         $stmt=$mysqli->stmt_init();
  63.         //3.1 使用预处理对象下的prepare()方法，将SQl注入到预处理对象中
  64.         $stmt->prepare($sql);
  66.         //参数
  67.         $user = ['15867425596',date('yy-m-d h:i:s',time()),2];
  68.         list($phone,$regtime,$id) = $user;
  70.         // 使用预处理对象的 bind_param('参数的类型', 参数列表.....)方法，绑定参数到其中
  71.         $stmt->bind_param('ssi',  $phone,$regtime,$id);
  73.         // 准备完成---执行
  74.         $stmt->execute();
  76.         // 4. 处理执行的结果
  77.         if ($stmt->affected_rows === 1) :
  78.             echo 'ID：'.$id.'的数据更新成功！更新时间:'.$regtime;
  79.         else :
  80.             echo '更新失败' . $stmt->error;
  81.         endif;
  83.         // 5. 结束操作
  84.         // 关闭数据库连接
  85.         $stmt->close();
  86.     }
  88.     //删除
  89.     public function delete_SQL($id){
  91.         //1.创建mysqli对象，连接数据库
  92.         $mysqli=new mysqli('localhost','root','root888','test');
  94.         //2.传入需要---执行的SQL语句
  95.         $sql = 'DELETE FROM `tf_users` WHERE `f_id`=?;';
  97.         //3.通过stmt_init(),实例化一个预处理对象，防止SQL注入攻击
  98.         $stmt=$mysqli->stmt_init();
  100.         //3.1 使用预处理对象下的prepare()方法，将SQl注入到预处理对象中
  101.         $stmt->prepare($sql);
  103.         //参数
  104.         $user_id = $id;
  106.         // 使用预处理对象的 bind_param('参数的类型', 参数列表.....)方法，绑定参数到其中
  107.         $stmt->bind_param('i', $user_id);
  109.         // 准备完成---执行
  110.         $stmt->execute();
  112.         // 4. 处理执行的结果
  113.         if ($stmt->affected_rows === 1) :
  114.             echo 'ID：'.$user_id.'的数据删除成功！删除时间:'.date('yy-m-d h:i:s',time());
  115.         else :
  116.             echo '删除失败' . $stmt->error;
  117.         endif;
  119.         // 5. 结束操作
  120.         // 关闭数据库连接
  121.         $stmt->close();
  122.     }
  124.     //查询-1 使用STMT对象查询（预处理对象）
  125.     public function select_SQL($id){
  127.         //1.创建mysqli对象，连接数据库
  128.         $mysqli=new mysqli('localhost','root','root888','test');
  130.         //2.传入需要---执行的SQL语句
  131.         $sql = 'SELECT `f_name`,`f_email`,`f_regtime` FROM `tf_users` WHERE `f_id`>?;';
  133.         //3.通过stmt_init(),实例化一个预处理对象，防止SQL注入攻击
  134.         $stmt=$mysqli->stmt_init();
  136.         //3.1 使用预处理对象下的prepare()方法，将SQl注入到预处理对象中
  137.         $stmt->prepare($sql);
  139.         //参数
  140.         $user_id = $id;
  142.         // 使用预处理对象的 bind_param('参数的类型', 参数列表.....)方法，绑定参数到其中
  143.         $stmt->bind_param('i', $user_id);
  145.         // 准备完成---执行
  146.         $stmt->execute();
  148.         // 4. 处理执行的结果
  150.         //4.1使用 bind_result()方法，将结果集中的字段绑定在变量上
  151.         $stmt->bind_result($name,$email,$regtime);
  153.         //4.2 使用fetch()方法，获取结果集中的当前一条记录，并且数据指针会自动下移一个；
  154.         while ($stmt->fetch()){
  155.             echo '用户名：'.$name.',的邮箱是：'.$email.'，用户注册时间：'.$regtime.'<br>';
  156.         }
  158.         // 5. 结束操作
  159.         //5.1 使用 free_result() 释放结果集所占用的内存
  160.         $stmt->free_result();
  162.         // 关闭数据库连接
  163.         $stmt->close();
  164.     }
  166.     //查询-2 使用
  167.     public function select_results($id){
  168.         $mysqli=new mysqli('localhost','root','root888','test');
  169.         $sql = 'SELECT `f_name`,`f_email`,`f_regtime` FROM `tf_users` WHERE `f_id`>?;';
  170.         $stmt=$mysqli->stmt_init();
  171.         $stmt->prepare($sql);
  172.         $user_id = $id;
  173.         $stmt->bind_param('i', $user_id);
  174.         $stmt->execute();
  176.         //1.使用 get_result()，获取结果集对象
  177.         $result=$stmt->get_result();
  179.         /*
  180.          * 2. 处理执行的结果
  181.          * fetch_array(),获取一条记录，包含索引和关联
  182.          * fetch_row(),获取一条记录，仅索引部分；
  183.          * fetch_assoc()获取一条记录，仅关联部分;
  184.          * fetch_all(),一次性获取所有数据(参数为MYSQLI_ASSOC)时，只返回关联部分;
  185.          * data_seek(0),索引归 0 复位;
  186.          * free_result(),释放结果集所占用的内存;
  187.          * */
  189.         //循环遍历输出
  190.         while ($users=$result->fetch_assoc()){
  191.             echo '用户名：'.$users['f_name'].',的邮箱是：'.$users['f_email'].'，用户注册时间：'.$users['f_regtime'].'<br>';
  192.         }
  194.         //索引复位  因为上面以及遍历完了 ，我们下面使用fetch_all一次性返回所有数据，所以需要先将指针复位;
  195.         echo '<br>========一次性输出所有========<br>';
  196.         $result->data_seek(0);
  198.         //fetch_all
  199.         $users=$result->fetch_all(MYSQLI_ASSOC);
  200.         foreach ($users as $user){
  201.             echo '用户名：'.$user['f_name'].',的邮箱是：'.$user['f_email'].'，用户注册时间：'.$user['f_regtime'].'<br>';
  202.         }
  204.         // 5. 结束操作
  205.         //5.1 使用 free_result() 释放结果集所占用的内存;
  206.         $result->free_result();
  208.         // 关闭数据库连接
  209.         $stmt->close();
  210.     }
  212. }
  214. $mysql_sql=new MySQLi_Basics();
  216. //新增
  217. $mysql_sql->inter_SQL();
  218. echo '<hr>';
  220. //更新
  221. $mysql_sql->update_SQL();
  222. echo '<hr>';
  224. //删除
  225. $mysql_sql->delete_SQL(9);
  226. echo '<hr>';
  228. //查询-1
  229. $mysql_sql->select_SQL(2);
  230. echo '<hr>';
  232. //查询-2
  233. $mysql_sql->select_results(2);
  235. ?>

接口多态—文件目录

运行效果

PDO


MySQLi

DB_interface.php 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 15:27
  7.  * Description: 数据访问接口定义
  8.  */
  10. /*
  11.  * 接口之间允许继承，并且可以多继承。与此同时，一个接口，允许有多个类进行不同的实现。
  12.  * 正是因为接口的这些特性，才能使其实现面向对象的 `多态`实现；
  13.  * */
  15. namespace Database;
  17. //设置数据库连接参数：默认值
  18. interface inter_DbParam{
  19.     const HOST='localhost';
  20.     const TYPE='mysql';
  21.     const DB_NAME='test';
  22.     const USER_NAME='root';
  23.     const PASSWORD='root888';
  24.     const PORT='3306';
  25.     const CHARSET='utf8'; //默认字符集
  26. }
  28. //接口构造方法
  29. interface inter_DbConnection{
  30.     //构造方法，
  31.     public function __construct(array $connectionParams);
  32. }
  34. //下面是数据库连接接口中，主要被实现的类
  35. interface inter_Execute extends inter_DbParam,inter_DbConnection{
  37.     //新增操作,其参数是多个，所以参数是一个数组类型
  38.     public function ex_Insert(array $data);
  40.     //删除操作,参数是删除数据的条件
  41.     public function ex_Delete(string $where);
  43.     //更新操作,参数是更新的数据和更新条件
  44.     public function ex_Update(array $data,string $where);
  46.     //查询操作
  47.     public function ex_Select(string $where);
  48. }

DB_pdo.php 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 15:51
  7.  * Description: PDO方式，实现数据库访问
  8.  */
  10. namespace Database;
  12. //导入PDO
  13. use PDO;
  15. //载入接口文件
  16. require 'DB_interface.php';
  18. class db_PDO implements inter_Execute{
  19.     //连接对象
  20.     private $pdo=null;
  22.     //实现接口中的构造方法
  23.     public function __construct(array $connectionParams)
  24.     {
  25.         //将传入参数 $connectionParams 中的值，分别绑定给指定变量
  26.         list($dsn,$username,$password)=$connectionParams;
  28.         //实例化PDO对象
  29.         $this->pdo=new PDO($dsn,$username,$password);
  30.     }
  32.     //新增操作
  33.     public function ex_Insert(array $data){
  34.         $sql="INSERT `tf_users` SET `f_name`=?, `f_password`=?,`f_email`=?,`f_phone`=?,`f_regtime`=?;";
  36.         //使用PDO对象的 prepare方法创建预处理对象
  37.         $stmt=$this->pdo->prepare($sql);
  39.         //执行语句的时候，需要将新增的数据传参给execute()
  40.         $stmt->execute($data);
  42.         //rowCount()返回受影响的行数
  43.         if ($stmt->rowCount()===1){
  44.             $message='新增数据成功！';
  45.         }else{
  46.             $message='新增数据失败！';
  47.         }
  48.         return$message;
  49.     }
  51.     //删除操作
  52.     public function ex_Delete(string $where){
  53.         $sql = 'DELETE FROM `tf_users` WHERE '.$where;
  54.         $stmt=$this->pdo->prepare($sql);
  55.         $stmt->execute();
  57.         //rowCount()返回受影响的行数
  58.         if ($stmt->rowCount()===1){
  59.             $message='删除数据成功！';
  60.         }else{
  61.             $message='删除数据失败！';
  62.         }
  63.         return$message;
  64.     }
  66.     //更新操作
  67.     public function ex_Update(array $data,string $where){
  68.         //设置更新的参数
  69.         $params='';
  70.         foreach ($data as $key=>$value){
  71.             $params.="`$key`='$value',";
  72.         }
  73.         //使用 rtrim() 去掉最后的多于的 逗号
  74.         $params=rtrim($params,',');
  76.         //执行更新
  77.         $sql = "UPDATE `tf_users` SET {$params} WHERE {$where}";
  78.         $stmt = $this->pdo->prepare($sql);
  79.         $stmt->execute();
  81.         //rowCount()返回受影响的行数
  82.         if ($stmt->rowCount()===1){
  83.             $message='更新数据成功！';
  84.         }else{
  85.             $message='更新数据失败！';
  86.         }
  87.         return$message;
  88.     }
  90.     //查询操作
  91.     public function ex_Select(string $where){
  92.         //判断传入条件
  93.         $where = empty($where) ? '' : ' WHERE ' . $where;
  94.         $sql='SELECT * FROM  `tf_users` '.$where;
  95.         $stmt=$this->pdo->prepare($sql);
  96.         $stmt->execute();
  97.         //PDO::FETCH_ASSOC 输出关联部分
  98.         return $stmt->fetchAll(PDO::FETCH_ASSOC);
  100.     }
  101. }

DB_mysqli 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 17:56
  7.  * Description: MySQLi方式，实现数据库访问
  8.  */
  10. namespace Database;
  12. //导入MySQLi
  13. use mysqli;
  15. //载入接口文件
  16. require 'DB_interface.php';
  18. class db_MySQLi implements inter_Execute{
  19.     //连接对象
  20.     private $mysqli=null;
  22.     //实现接口中的构造方法
  23.     public function __construct(array $connectionParams)
  24.     {
  25.         //将传入参数 $connectionParams 中的值，分别绑定给指定变量
  26.         list($host,$username,$password,$dbname)=$connectionParams;
  28.         //实例化mysqli
  29.         $this->mysqli=new mysqli($host,$username,$password,$dbname);
  32.         //设置默认字符集
  33.         $this->mysqli->set_charset('utf8');
  34.     }
  37.     //新增操作
  38.     public function ex_Insert(array $data){
  39.         $sql="INSERT `tf_users` SET `f_name`=?, `f_password`=?,`f_email`=?,`f_phone`=?,`f_regtime`=?;";
  41.         //使用PDO对象的 prepare方法创建预处理对象
  42.         $stmt=$this->mysqli->prepare($sql);
  44.         //数据绑定
  45.         $stmt->bind_param('sssss',$name,$password,$email,$phone,$regtime);
  46.         list($name,$password,$email,$phone,$regtime)=$data;
  47.         //执行语句的时候，需要将新增的数据传参给execute()
  48.         $stmt->execute();
  50.         //rowCount()返回受影响的行数
  51.         if ($stmt->affected_rows===1){
  52.             $message='新增数据成功！';
  53.         }else{
  54.             $message='新增数据失败！';
  55.         }
  56.         return$message;
  57.     }
  59.     //删除操作
  60.     public function ex_Delete(string $where){
  61.         $sql = 'DELETE FROM `tf_users` WHERE '.$where;
  62.         $stmt=$this->mysqli->prepare($sql);
  63.         $stmt->execute();
  65.         //rowCount()返回受影响的行数
  66.         if ($stmt->affected_rows===1){
  67.             $message='删除数据成功！';
  68.         }else{
  69.             $message='删除数据失败！';
  70.         }
  71.         return$message;
  72.     }
  74.     //更新操作
  75.     public function ex_Update(array $data,string $where){
  76.         //设置更新的参数
  77.         $params='';
  78.         foreach ($data as $key=>$value){
  79.             $params.="`$key`='$value',";
  80.         }
  82.         //使用 rtrim() 去掉最后的多于的 逗号
  83.         $params=rtrim($params,',');
  85.         //执行更新
  86.         $sql = "UPDATE `tf_users` SET {$params} WHERE {$where}";
  87.         $stmt = $this->mysqli->prepare($sql);
  88.         $stmt->execute();
  90.         //rowCount()返回受影响的行数
  91.         if ($stmt->affected_rows===1){
  92.             $message='更新数据成功！';
  93.         }else{
  94.             $message='更新数据失败！';
  95.         }
  96.         return$message;
  97.     }
  99.     //查询操作
  100.     public function ex_Select(string $where){
  101.         //判断传入条件
  102.         $where = empty($where) ? '' : ' WHERE ' . $where;
  103.         $sql='SELECT * FROM  `tf_users` '.$where;
  104.         $stmt=$this->mysqli->prepare($sql);
  105.         $stmt->execute();
  107.         //通过 get_result()获取预处理对象的结果集
  108.         $results=$stmt->get_result();
  109.         return $results;
  111.     }
  112. }

DB.php 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 16:34
  7.  * Description: DB通用类，面向接口实现PDO、MySQLi的动态支持（多态）
  8.  */
  10. namespace Database;
  11. use Database\inter_Execute as iDb;
  13. /*
  14.  * DB 通用类中，使用了接口作为 类方法参数，
  15.  * 并且在类方法中返回了接口的方法结果;
  16.  * */
  17. class DB{
  18.     //新增
  19.     public static function db_Insert(iDb $db,array $data){
  20.         return $db->ex_Insert($data);
  21.     }
  23.     //删除
  24.     public static function db_Delete(iDb $db,string $where){
  25.         return $db->ex_Delete($where);
  26.     }
  28.     //更新
  29.     public static function db_Update(iDb $db,array $data,string $where){
  30.         return $db->ex_Update($data,$where);
  31.     }
  33.     //查询
  34.     public static function db_Select(iDb $db, $where){
  35.         return $db->ex_Select($where);
  36.     }
  37. }

Access_pdo.php 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 16:51
  7.  * Description: 通过BD类，使用PDO方式访问数据库
  8.  */
  10. namespace Database;
  12. //加载文件
  13. require 'DB_pdo.php';
  14. require 'DB.php';
  16. // 拼接 $dsn
  17. $dsn= inter_DbParam::TYPE . ':host='.inter_DbParam::HOST . ';dbname=' . inter_DbParam::DB_NAME . ';charset='.inter_DbParam::CHARSET;
  19. // 拼接数组参数
  20. $paranms=[
  21.     $dsn,
  22.     inter_DbParam::USER_NAME,
  23.     inter_DbParam::PASSWORD
  24. ];
  26. //创建PDO
  27. $link=new db_PDO($paranms);
  29. echo '===========PDO测试============<br>';
  30. // 测试新增操作
  31. echo '消息：'.DB::db_Insert($link,['李继承',sha1('584627'),'zhang_chenghao@mayitiyu.cn','17569842711',date('yy-m-d h:i:s',time())]);
  32. echo '<hr>';
  34. // 测试查询
  35. foreach (DB::db_Select($link, 'f_id > 2') as $user) {
  36.     echo '用户名：'.$user['f_name'].',的邮箱是：'.$user['f_email'].'，用户注册时间：'.$user['f_regtime'].'<br>';
  37. }
  38. echo '<hr>';
  40. // 更新测试
  41. echo DB::db_Update($link,['f_name'=>'逍遥王子', 'f_email'=>'xiaoyao_wangzi@mayitiyu.cn'], 'f_id=5');
  42. echo '<hr>';
  44. // 删除操作
  45. echo DB::db_Delete($link,'f_id=13');

Access_mysqli.php 文件代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Air15_2019
  5.  * Date: 2020/2/12
  6.  * Time: 17:55
  7.  * Description: 通过BD类，使用MySQLi方式访问数据库
  8.  */
  10. namespace Database;
  12. //加载文件
  13. require 'DB_mysqli.php';
  14. require 'DB.php';
  16. // 拼接数组参数
  17. $paranms=[
  18.     inter_DbParam::HOST,
  19.     inter_DbParam::USER_NAME,
  20.     inter_DbParam::PASSWORD,
  21.     inter_DbParam::DB_NAME
  22. ];
  24. //创建PDO
  25. $link=new db_MySQLi($paranms);
  27. echo '===========MySQLi测试============<br>';
  28. // 测试新增操作
  29. echo '消息：'.DB::db_Insert($link,['王重阳',sha1('75264889'),'wang_chongyang@mayitiyu.cn','17569842711',date('yy-m-d h:i:s',time())]);
  30. echo '<hr>';
  32. // 测试查询
  33. foreach (DB::db_Select($link, 'f_id > 2') as $user) {
  34.     echo '用户名：'.$user['f_name'].',的邮箱是：'.$user['f_email'].'，用户注册时间：'.$user['f_regtime'].'<br>';
  35. }
  36. echo '<hr>';
  38. // 更新测试
  39. echo DB::db_Update($link,['f_name'=>'逍遥王孙', 'f_email'=>'xiaoyao_wangsun@mayitiyu.cn'], 'f_id=5');
  40. echo '<hr>';
  42. // 删除操作
  43. echo DB::db_Delete($link,'f_id=14');

MySQLi 基础知识抄写



Correcting teacher：天蓬老师天蓬老师

Correction status：qualified

Teacher's comments：命名注意规范, select_SQL, 算什么呢? 要么select_sql, 要么selectSql
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