PHP8.1.21版本已发布
vue8.1.21版本已发布
jquery8.1.21版本已发布
首页
课程
路径
文章
PHP培训
精品课
下载
最新更新

博客列表 > 0211 MySQLi操作数据库与多态

0211 MySQLi操作数据库与多态

曾
曾 原创
2020年02月22日 18:59:26 934浏览

MySQLi基本操作

一.MySQLi是什么
-MySQLi是PHP内置的操作MySQL数据库的扩展，默认为开启。
-MySQLi提供了面向过程和面向对象的两种方式操作数据库
二.MySQLi操作数据库的基本步骤
-连接数据库
创建一个MySQLi类实例，需要传入(主机名，用户名，密码，数据库名)，设置字符集
-操作数据库
-1.新增
例

  1. <?php
  2. //新增操作
  3. namespace MYSQLi;
  4. use mysqli;
  5. // 1连接数据库
  6. // MYSQLI连接数据库需要主机，用户名，密码，数据库名
  7. $mysqli = new mysqli('localhost','root','root','phpedu');
  8. // 创建SQL语句 ，每个字段需要用逗号隔开 ？为占位符
  9. $sql = 'INSERT `test` SET `name`=?,`age`=?, `email`=?;';
  10. // 使用预处理方式，防止SQL注入
  11. $stmt = $mysqli->stmt_init();
  12. // 创建SQL语句对象
  13. $stmt = $mysqli->prepare($sql);
  14. // 创建数据数组，然后使用使用bind_param与占位符进行绑定
  15. $user = ['马超',22,'machao@php.cn'];
  16. list($name,$age,$email) = $user;
  17. $stmt->bind_param('sis',$name,$age,$email);
  18. // 执行SQL语句
  19. $stmt->execute();
  20. echo $stmt->affected_rows ===1 ? '新增成功' : '新增失败';
  21. //关闭数据库
  22. $stmt->close();

-2.更新
例：步骤类似，稍微改下SQL语句就能用了

  1. <?php
  2. //更新操作
  3. namespace MYSQLi;
  4. use mysqli;
  5. // 1连接数据库
  6. // MYSQLI连接数据库需要主机，用户名，密码，数据库名
  7. $mysqli = new mysqli('localhost','root','root','phpedu');
  8. // 创建SQL语句,修改邮箱，如果需要更新多个字段，每个字段需要用逗号隔开 ？为占位符
  9. $sql = 'UPDATE `test` SET `email`=? WHERE `name`=?;';
  10. $stmt = $mysqli->stmt_init();
  11. // 创建SQL语句对象
  12. $stmt ->prepare($sql); 
  13. // 创建数据数组，然后使用使用bind_param与占位符进行绑定
  14. $user = ['machao@admin.cn','马超'];
  15. list($email,$name) = $user;
  16. $stmt->bind_param('ss',$email,$name);
  17. // 执行SQL语句
  18. $stmt->execute();
  19. echo $stmt->affected_rows ===1 ? '更新成功' : '更新失败';
  20. //关闭数据库
  21. $stmt->close();

-3.删除
例

  1. <?php
  2. //删除操作
  3. namespace MYSQLi;
  4. use mysqli;
  5. // 1连接数据库
  6. // MYSQLI连接数据库需要主机，用户名，密码，数据库名
  7. $mysqli = new mysqli('localhost','root','root','phpedu');
  8. // 创建SQL语句 ？为占位符
  9. $sql = 'DELETE FROM `test` WHERE `name`=?;';
  10. $stmt = $mysqli->stmt_init();
  11. // 创建SQL语句对象
  12. $stmt ->prepare($sql);
  13. // 创建数据，然后使用使用bind_param与占位符进行绑定
  14. $name = '马超';
  15. $stmt->bind_param('s',$name);
  16. // 执行SQL语句
  17. $stmt->execute();
  18. echo $stmt->affected_rows ===1 ? '删除成功' : '删除失败';
  19. //关闭数据库
  20. $stmt->close();

-4.查询
例

  1. <?php
  2. //查询操作(使用结果集查看)
  3. namespace MYSQLi;
  4. use mysqli;
  5. // 1连接数据库
  6. // MYSQLI连接数据库需要主机，用户名，密码，数据库名
  7. $mysqli = new mysqli('localhost','root','root','phpedu');
  8. // 创建SQL语句 如果需要更新多个字段，每个字段需要用逗号隔开 ？为占位符
  9. $sql = 'SELECT * FROM `test` WHERE `id`>?;';
  10. // 使用预处理方式，防止SQL注入
  11. $stmt = $mysqli->stmt_init();
  12. // 创建SQL语句对象
  13. $stmt ->prepare($sql); 
  14. // 创建数据数组，然后使用使用bind_param与占位符进行绑定
  15. $id = 3;
  16. $stmt->bind_param('i',$id);
  17. // 执行SQL语句
  18. $stmt->execute();
  19. // 处理结果,获取结果集
  20. $result = $stmt->get_result();
  21. // 一条一条查看,fetch_assoc：显示结果中的关联部分（常用）
  22. // $user = $result->fetch_assoc();
  23. // 使用while循环 遍历出所有结果
  24. // while($user = $result->fetch_assoc()){
  25. //     echo "id={$user['id']}:name={$user['name']}:age={$user['age']}:email={$user['email']}<br>";
  26. // }
  29. //一次查询所有满足条件的结果
  31. $users = $result->fetch_all(MYSQLI_ASSOC);
  33. // print_r($users);
  35. //使用foreach 遍历出所有结果
  36. foreach($users as $user){
  37.     echo "id={$user['id']}:name={$user['name']}:age={$user['age']}:email={$user['email']}<br>";
  38. }
  39. // 释放结果集
  40. $stmt->free_result();
  41. //关闭数据库
  42. $stmt->close();

-最后就是关闭数据库 close()

接口与多态实例练习

1.先创建接口文件

  1. <?php
  2. namespace DETAIL;
  3. //创建一个接口，里面都是数据库连接常量
  4. interface iParam
  5. {   
  6.     const MYSQL='mysql';
  7.     const HOST='localhost';
  8.     const USERNAME='root';
  9.     const PASSWORD='root';
  10.     const DBNAME='phpedu';
  11. }
  13. // 创建一个接口，表示需要使用构造方法
  14. interface iDBlink
  15. {
  16.     public function __construct(array $link);
  17. }
  18. //创建一个接口，表示数据的操作
  20. interface iCURD extends iDBlink,iParam
  21. {  
  22.      //新增操作
  23.      public function insert(array $data);
  24.     // 更新操作
  25.     public function update(array $data,string $where);
  26.     //查询操作
  27.     public function select(string $where='');
  28.     //删除操作
  29.     public function delete(string $where);
  30.     //关闭操作
  31.     public function close();
  32. }

2.根据接口规范，创建PDO与MYSQLI两个文件来实现接口

PDO

  1. <?php
  3. namespace DETAIL;
  4. //导入PDO
  5. use PDO;
  6. class DB_PDO implements iCURD
  7. {
  8.     private $pdo;
  9.     //实现接口的构造方法,需要传入一个数组参数，数组里面包括（PDO数据源，数据库用户名，密码）
  10.     public function __construct(array $links)
  11.     {
  12.         list($dsn, $username, $password) = $links;
  13.         $this->pdo = new pdo($dsn, $username, $password);
  14.     }
  15.     //实现接口的新增方法，需要传入一个数组参数，数组里面包括（姓名，年龄，邮箱）例（'张三',20,'zhangsan@php.cn'）
  16.     public function insert(array $data)
  17.     {
  18.         $sql = 'INSERT `test` SET `name`=?,`age`=?,`email`=?';
  19.         $stmt = $this->pdo->prepare($sql);
  20.         $stmt->execute($data);
  21.         return $stmt->rowCount() === 1 ? '新增成功' : '新增失败';
  22.     }
  23.     // 实现接口更新操作，需要传入一个更新参数数组
  24.     // 再传入一个条件参数必须为字符串（传递进来的字符串必须与SQL命令语句符合）例（"`name`='张三'"）
  25.     public function update(array $data, string $where = '')
  26.     {
  27.         //因为更新参数都为字符串，要先创建一个空变量
  28.         $params = '';
  29.         //遍历传递进来的更新参数数组，并把键名与键值输出，拼接赋值给$params
  30.         foreach ($data as $key => $value) {
  31.             $params .= "`{$key}`='{$value}',";
  32.         }
  33.         //去掉最右边的逗号
  34.         $params = rtrim($params, ',');
  35.         $sql = "UPDATE `test` SET {$params} WHERE {$where}";
  36.         $stmt = $this->pdo->prepare($sql);
  37.         $stmt->execute();
  38.         return $stmt->rowCount() === 1 ? '更新成功' : '更新失败';
  39.     }
  40.     //实现接口查询操作 
  41.     //传入一个条件参数必须为字符串（传递进来的字符串必须与SQL命令语句符合）例（"`name`='张三'"）
  42.     public function select(string $where = '')
  43.     {
  44.         //查询的时候条件可以为空，所以要判断$where时候为空，如果为空就查询整张数据表
  45.         //如果不为空，就把后面拼接的赋值给$where组成完整的SQL语句
  46.         $where = empty($where) ? $where : ' WHERE ' . $where;
  47.         $sql = "SELECT * FROM `test`  {$where}";
  48.         $stmt = $this->pdo->prepare($sql);
  49.         $stmt->execute();
  50.         return $stmt->fetchall(PDO::FETCH_ASSOC);
  51.     }
  52.     //实现接口删除操作
  53.     public function delete(string $where)
  54.     {
  55.         $sql = "DELETE FROM `test` WHERE {$where}";
  56.         $stmt = $this->pdo->prepare($sql);
  57.         $stmt->execute();
  58.         return $stmt->rowCount() === 1 ? '删除成功' : '删除失败';
  59.     }
  60.     //关闭数据库
  61.     public function close()
  62.     {
  63.         return  $this->pdo = null;
  64.     }
  65. }

MYSQLI

  1. <?php
  3. namespace DETAIL;
  5. use MYSQLi;
  7. class DB_MYSQLI implements iCURD
  8. {
  9.     private $mysqli;
  10.     //连接数据库
  11.     //实现接口的构造方法,需要传入一个数组参数，数组里面包括（数据库主机名，数据库用户名，密码，数据库名）
  12.     public function __construct(array $links)
  13.     {
  14.         list($host, $username, $password, $dbname) = $links;
  15.         $this->mysqli = new MYSQLI($host, $username, $password, $dbname);
  16.         //设置默认字符集,防止有乱码出现
  17.         $this->mysqli->set_charset('uft8');
  18.     }
  19.     //实现接口的新增方法，需要传入一个数组参数，数组里面包括（姓名，年龄，邮箱）例（'张三',20,'zhangsan@php.cn'）
  20.     public function insert(array $data)
  21.     {
  22.         //创建SQL语句
  23.         $sql = 'INSERT `test` SET `name`=?,`age`=?,`email`=?';
  24.         $stmt = $this->mysqli->prepare($sql);
  25.         list($name, $age, $email) = $data;
  26.         $stmt->bind_param('sis', $name, $age, $email);
  27.         $stmt->execute();
  28.         return $stmt->affected_rows === 1 ? '新增成功' : '新增失败';
  29.     }
  31.     // 实现接口更新操作，需要传入一个更新参数数组
  32.     // 再传入一个条件参数必须为字符串（传递进来的字符串必须与SQL命令语句符合）例（"`name`='张三'"）
  33.     public function update(array $data, string $where)
  34.     {
  35.         //创建SQL语句
  36.         //因为更新参数都为字符串，要先创建一个空变量
  37.         $params = '';
  38.         //遍历传递进来的更新参数数组，并把键名与键值输出，拼接赋值给$params
  39.         foreach ($data as $key => $value) {
  40.             $params .= "`{$key}`='{$value}',";
  41.         }
  42.         $params = rtrim($params, ',');
  44.         $sql = "UPDATE `test` SET {$params} WHERE {$where}";
  45.         $stmt = $this->mysqli->prepare($sql);
  46.         $stmt->execute();
  47.         return $stmt->affected_rows === 1 ? '更新成功' : '更新失败';
  48.     }
  49.     //实现接口查询操作 
  50.     //传入一个条件参数必须为字符串（传递进来的字符串必须与SQL命令语句符合）例（"`name`='张三'"）
  51.     public function select(string $where = '')
  52.     {
  53.         //查询的时候条件可以为空，所以要判断$where时候为空，如果为空就查询整张数据表
  54.         //如果不为空，就把后面拼接的赋值给$where组成完整的SQL语句
  55.         $where = empty($where) ? $where : ' WHERE ' . $where;
  56.         $sql = "SELECT * FROM `test` WHERE {$where}";
  57.         $stmt = $this->mysqli->prepare($sql);
  58.         $stmt->execute();
  59.         $result = $stmt->get_result();
  60.         return $result->fetch_all(MYSQLI_ASSOC);
  61.     }
  62.     //删除操作
  63.     public function delete(string $where)
  64.     {
  65.         $sql = "DELETE FROM `test` WHERE {$where}";
  66.         $stmt = $this->mysqli->prepare($sql);
  67.         $stmt->execute();
  68.         return $stmt->affected_rows === 1 ? '删除成功' : '删除失败';
  69.     }
  70.     //关闭数据库
  71.     public function close()
  72.     {
  73.         return $this->mysqli->close();
  74.     }
  75. }

最后创建一个通用类文件

  1. <?php
  2. namespace DETAIL;
  4. //创建数据操作通用类
  5. class DB
  6. {
  7.     //通用操作，$db为操作语言（传入$DB_PDO实例就是PDO，传入$DB_MYSQLI实例就是mysqli语言）
  8.     public function insert(iCURD $db,array $data)
  9.     {
  10.         return $db->insert($data);
  11.     }
  12.     public function update(iCURD $db,array $data,string $where)
  13.     {
  14.         return $db->update($data,$where);
  15.     }
  16.     public function select(iCURD $db,string $where='')
  17.     {
  18.         return $db->select($where);
  19.     }
  20.     public function delete(iCURD $db,string $where)
  21.     {
  22.         return $db->delete($where);
  23.     }
  24.     public function close(iCURD $db)
  25.     {
  26.         return $db->close();
  27.     }
  28. }

最后调用

  1. <?php
  2. namespace DETAIL;
  3. //导入接口文件
  4. require 'demo4.php';
  5. //导入MYSQLI类，接口实现方法
  6. require 'demo6.php';
  7. //导入数据库查询通用类
  8. require 'demo7.php';
  10. //创建MYSQLI数据源
  11. $links = [iParam::HOST,iParam::USERNAME,iParam::PASSWORD,iParam::DBNAME];
  12. //实例化MYSQLI
  13. $db_mysqli = new DB_MYSQLI($links);
  14. //实例化通用类
  15. $db =new db;
  17. //新增测试
  18. // echo $db->insert($db_mysqli,['孙权',28,'sunquan@php.cn']);
  19. //更新测试
  20. // echo $db->update($db_mysqli,['age'=>38],'id=25');
  21. //查询测试
  22. // echo '<pre>'.print_r($db->select($db_mysqli,'`id`>2'),true).'</pre>';
  23. //删除测试
  24. // echo $db->delete($db_mysqli,"`name`='孙权'");
  26. //关闭数据库
  27. echo $db->close($db_mysqli);

笔记1

笔记2

实战练习的时候，感觉错误还是很多(主要写少了)，都是写完整了一个方法就测试，有问题马上修改，就是怕如果全部写完了在测试会找不到错误在哪里！一边写一边改，不太会查找BUG，很多时候都是一行一行的自己慢慢找。输入法错误也有，有时候明明看上去正确的代码，就因为输入法变成全角了而错误
然后注释是个好东西，建议和我一样初学的，一定要习惯写注释，帮助学习有好处

上一条： 服务容器与设计模式的学习（单例模式 和 工厂模式的应用）-PHP培训十期线上班 下一条： laravel扩展权限校验中间键
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多
热门课程