Community Learn Tools Library Leisure
search
English
Home > List of blog posts > 0211 MySQLi操作数据库与多态
Blogger Information
Blog 30
fans 0
comment 1
visits 24059
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
0211 MySQLi操作数据库与多态
曾
Original
969 people have browsed it

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

Correcting teacher：天蓬老师天蓬老师

Correction status：qualified

Teacher's comments：namespace 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