微信公众号 讲师中心
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机/移动开发 手机游戏
搜索
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程
自媒体 新闻
首页 > 博客列表 > 0211 MySQLi操作数据库与多态
博主信息
博文 30
粉丝 0
评论 1
访问量 30335
专题推荐
更多>
相关推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
0211 MySQLi操作数据库与多态
曾
原创
1132人浏览过

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，很多时候都是一行一行的自己慢慢找。输入法错误也有，有时候明明看上去正确的代码，就因为输入法变成全角了而错误
然后注释是个好东西，建议和我一样初学的，一定要习惯写注释，帮助学习有好处

批改老师：天蓬老师天蓬老师

批改状态：合格

老师批语：namespace MYSQLi; 命名空间不要使用这样的关键字, 有可能出现一些难以察觉的错误, 下次注意
本博文版权归博主所有，转载请注明地址！如有侵权、违法，请联系admin@php.cn举报处理！
全部评论 文明上网理性发言，请遵守新闻评论服务协议
0条评论
作者最新博文
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新 English
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • PHP学习

  • 技术支持

  • 返回顶部
    • 登录PHP中文网，和优秀的人一起学习！
    全站2000+教程免费学
    微信扫码登录