search

博客列表 >面向对象操作mysql数据库及预处理方式

面向对象操作mysql数据库及预处理方式

嘬一口啊
嘬一口啊原创
2020年07月20日 09:08:341252浏览

面向对象操作数据库步骤

  • 1.连接数据库及判断是否连接成功

mysqli对象的属性 作用
$mysqli::connect_errno 返回最后一次连接数据库的错误代码
$mysqli::connect_error 返回最后一次连接数据库的错误描述，类型为字符串
$mysqli::connect_error 返回最后一次连接数据库的错误描述，类型为字符串
$mysqli::errno 返回最近一次函数调用所产生的错误代码
$mysqli::error 返回最近一次错误代码的描述，类型是字符串 
  1. new mysqli('主机名','用户名','密码','要连接的数据库名');
  2. 例:
  3. // @:错误抑制符
  4. // 连接成功打印输出$mysqli是一个对象,失败返回fales
  5. $mysqli = @new mysqli('localhost','root','root','test');
  6. // 判断是否连接成功
  7. if ($mysqli->connect_errno) {
  8.     // die();就是停止掉
  9.     // 停止程序运行,提示错误
  10.     die("CONNECT_ERROR:".$mysqli->connect_error);
  11. }

  • 2.设置字符集

  1. $mysqli->set_charset('utf-8');

  • 3.定义sql语句[根据自身需求来编写]

  1. `添加数据sql语句`
  2. INSERT INTO 表名 (字段名,字段名...) VALUES (对应值,对应值);
  3. 例:
  4. INSERT INTO user (username,age) VALUES ('张三',21);
  6. `删除语句:删除语句一定要加wher条件否则很惨`
  7. DELETE FROM USER WHERE 条件;
  8. 例:
  9. DELETE FROM USER WHERE ID=2;
  11. `修改语句`
  12. UPDATE 表名 SET `字段名`='修改的值',`字段名`='修改的值' WHERE 条件
  13. 例:
  14. UPDATE USER SET `USERNAME`='李四',`age`='18' WHERE ID=1;
  16. `查询语句`
  17. SELECT * FROM 表名; // 查询该表所有数据
  18. SELECT * FROM 表名 WHERE 条件; // 查询复合条件的数据
  19. SELECT 字段,字段 FROM 表名 WHERE 条件; // 查询指定条件的指定字段数据
  20. 例:
  21. SELECT * FROM USER;

  • 4.执行sql语句

删除/修改/添加语句执行成功后返回true;,执行失败返回false

查询语句执行成功返回mysqli_result 对象,失败返回false

  1. // $sql就是承接的定义sql语句的变量
  2. // 执行完使用一个变量来承接[$res就是承接的变量]
  3. $res = $mysqli->query($sql);

  • 5.使用执行sql语句返回的mysqli_result结果集对象

这个类的对象包含SELECT查询的结果、获取结果集中数据的成员方法，以及和查询的结果有关的成员属性。

$mysqli::insert_id:返回上一次执行添加语句的id

mysqli_result对象中的属性 作用
mysqli_result::fetch_all() 抓取所有的结果行并且以关联数组，数值索引数组，或者两者皆有的方式返回结果集。fetch_all(MYSQLI_ASSOC/MYSQLI_NUM/ MYSQLI_BOTH)
mysqli_result::fetch_array() 以一个关联数组，数值索引数组，或者两者皆有的方式抓取一行结果 fetch_array(MYSQLI_ASSOC, MYSQLI_NUM, or MYSQLI_BOTH)
mysqli_result::fetch_assoc() 以一个关联数组方式抓取一行结果
mysqli_result::fetch_row() 以一个枚举数组方式返回一行结果
$mysqli_result::num_rows 获取结果中行的数量 
  1. 例:
  2. // 执行sql语句
  3. $res = $mysqli->query($sql);
  4. $res->mysqli_result::fetch_all(MYSQLI_ASSOC);
  5. 例:
  6. $res->mysqli_result::fetch_array(MYSQLI_ASSOC);
  7. 例:
  8. $res->mysqli_result::fetch_assoc();
  9. 例:
  10. $res->mysqli_result::fetch_row();
  11. 例:
  12. $res->$mysqli_result::num_rows;
  13. 例:
  14. $res->mysqli_result::free();

  • 6.释放结果集

mysqli_result::free():释放与一个结果集相关的内存

  1. 例:
  2. // 执行sql语句
  3. $res = $mysqli->query($sql);
  4. // 释放结果集
  5. $res->free():

  • 7.关闭打开的数据库

mysqli::close();:关闭先前打开的数据库连接

  1. // 这里的$mysqli就是承接连接数据库返回值的变量
  2. $mysqli->close($mysqli);

  • 综合实例

  1. // 实例
  2. // 登录界面
  3. <!DOCTYPE html>
  4. <html>
  5. <head>
  6.     <title>用户登录</title>
  7. </head>
  8. <body>
  9.     <h2>用户登录</h2>
  10.     <form action="actions.php" method="post">
  11.     <!-- <form action="action.php" method="post"> -->
  12.         <table>
  13.             <tr>
  14.                 <td>用户名</td>
  15.                 <td>
  16.                     <input type="text" name="username">
  17.                 </td>
  18.             </tr>
  19.             <tr>
  20.                 <td>密码</td>
  21.                 <td>
  22.                     <input type="password" name="password">
  23.                 </td>
  24.             </tr>
  25.             <tr align="center">
  26.                 <td colspan="2">
  27.                     <input  type="submit" name="sub">
  28.                 </td>
  29.             </tr>
  30.         </table>
  31.     </form>
  32. </body>
  33. </html>
  1. //数据处理文件
  2. <?php
  3. // 不使用任何方sql注入
  4. // 接受表单传过来的值
  5. $username = $_POST['username'];
  6. $password = $_POST['password'];
  8. // 连接数据库
  9. $mysqli = @new mysqli('localhost','root','root','test');
  11. if ($mysqli->connect_error) {
  12.     die("CONNECT_ERROR:".$mysqli->connect_error);
  13. }
  15. // 设置字符集
  16. $mysqli->set_charset('utf-8');
  18. // 创建sql语句
  19. $sql = "SELECT * FROM `user` WHERE `name`='{$username}' AND `password`='{$password}'";
  21. // 执行sql语句
  22. $res = $mysqli->query($sql);
  24. // 查看受影响行数
  25. // var_dump($res->num_rows);
  27. // 查看所有数据
  28. // $res->fetch_all();
  30. // 以一个关联数组，数值索引数组，或者两者皆有的方式抓取一行结果 
  31. // $res->fetch_array();
  33. // 以一个关联数组方式抓取一行结果
  34. // $res->fetch_assoc()
  36. // 以一个枚举数组方式返回一行结果
  37. // $res->fetch_row();
  39. // 释放结果集
  40. // $res->free():
  42. // 关闭数据库
  43. // $mysqli->close($mysqli);
  44. ?>

防sql注入/预处理/mysqli_stmt类

mysqli_stmt类的对象可以定义和执行参数化的SQL命令,即预处理（Prepared Statement）的机制。

mysqli_stmt对象中的属性 作用
$mysqli_stmt::affected_rows 返回受上次执行语句影响的总行数：修改、删除或插入
$mysqli_stmt::num_rows 返回语句结果集中的行数
$mysqli_stmt::errno 返回最近一次语句调用的错误代码
$mysqli_stmt::error 返回最后一条语句错误的字符串描述
mysqli_stmt::prepare() 准备执行 SQL 语句
mysqli_stmt::bind_param() 绑定变量参数到 prepared 语句
mysqli_stmt::bind_result() 绑定变量参数到 prepared 语句，用于结果存储
mysqli_stmt::execute() 执行预处理sql语句
mysqli_stmt::get_result() 获取 prepared 语句中的结果。
mysqli_stmt::fetch() 获取 prepared 语句中的结果， 返回true,否则返回false
mysqli_stmt::free_result() 释放给定语句处理存储的结果集所占内存 
  1. $sql = "INSERT INTO 表名(字段名) values (?[使用?给值占位])";
  2. 例:
  3. $sql = "INSERT INTO STU(USERNAME) VALUES (?)";
  5. // 给预处理sql语句准备sql语句
  6. $stmt = $mysqli->prepare($sql);
  8. // 给占位符绑定值
  9. $stmt->bind_param('值类型[首字母缩写]',变量[值用一个变量]);
  10. 例:
  11. $name = '秀儿';
  12. // s 是字符串类型
  13. $stmt->bind_param('s',$name);
  15. // 执行预处理语句[mysqli_stmt::execute()执行 prepared 查询]
  16. 例:
  17. $res = $stmt->execute();
  19. // 判断sql语句是否执行成功
  20. if ($res) {
  21.     echo $stmt->affected_rows;
  22. } else {
  23.     echo '错误';
  24. }

  • 综合实例

  1. // 登录界面
  2. <!DOCTYPE html>
  3. <html>
  4. <head>
  5.     <title>用户登录</title>
  6. </head>
  7. <body>
  8.     <h2>用户登录</h2>
  9.     <form action="actions.php" method="post">
  10.     <!-- <form action="action.php" method="post"> -->
  11.         <table>
  12.             <tr>
  13.                 <td>用户名</td>
  14.                 <td>
  15.                     <input type="text" name="username">
  16.                 </td>
  17.             </tr>
  18.             <tr>
  19.                 <td>密码</td>
  20.                 <td>
  21.                     <input type="password" name="password">
  22.                 </td>
  23.             </tr>
  24.             <tr align="center">
  25.                 <td colspan="2">
  26.                     <input  type="submit" name="sub">
  27.                 </td>
  28.             </tr>
  29.         </table>
  30.     </form>
  31. </body>
  32. </html>
  1. // 数据处理文件
  2. <?php
  3. // 使用预处理防sql注入
  5. // 接受post传值
  7. $username = $_POST['username'];
  9. $password = $_POST['password'];
  11. // 连接数据库
  12. $mysqli = @new mysqli('localhost','root','root','test');
  14. if ($mysqli->connect_error) {
  15.     die("COONECT_ERROR:".$mysqli->connect_error);
  16. }
  18. // 设置字符集
  19. $mysqli->set_charset('utf-8');
  21. // 设置sql语句
  22. $sql = "SELECT * FROM `user` WHERE `name`=? AND `password`=?";
  24. // 准备预处理sql语句
  25. $stmt = $mysqli->prepare($sql);
  27. // 绑定参数
  28. $stmt->bind_param('ss',$username,$password);
  30. // 执行预处理sql语句
  31. $stmt->execute();
  33. // mysqli_stmt::get_result()获取 prepared 语句中的结果。
  34. $res = $stmt->get_result();
  36. // 返回受上次执行语句影响的总行数：修改、删除或插入
  37. // $stmt->affected_rows;
  39. // 返回语句结果集中的行数
  40. // $stmt->num_rows
  42. // 返回最近一次语句调用的错误代码
  43. // $stmt->errno;
  45. //返回最后一条语句错误的字符串描述
  46. // $stmt->error;
  48. // 获取 prepared 语句中的结果， 返回true,否则返回false
  49. // $stmt->fetch();
  51. // 释放结果集
  52. $stmt->free_result();
  54. // 关闭数据库
  55. // $mysqli->close($mysqli);
  56. ?>

使用mysqli_result对象中的属性将获得的结果集中的数据[二维数组]遍历出来

  1. <?php
  2. // 连接数据
  4. $mysqli = @new mysqli('localhost','root','root','test');
  6. if ($mysqli->connect_errno) {
  7.     die("CONNECT:".$mysqli->connect_errno);
  8. }
  10. // 设置字符集
  11. $mysqli->set_charset('utf-8');
  13. // 设置sql语句
  14. $sql = "SELECT * FROM `stu`";
  16. // 执行sql语句
  17. $res = $mysqli->query($sql);
  19. $res = $res->fetch_all(MYSQLI_ASSOC);
  21. if (is_array($res) && !empty($res)) {
  22.     echo "<table border='1' width='300px' align='center' >";
  23.         echo "<tr align='center'>";
  24.             echo "<td>ID</td>";
  25.             echo "<td>姓名</td>";
  26.             echo "<td>年龄</td>";
  27.         echo "</tr>";
  28.     foreach ($res as $v) {
  29.         echo "<tr align='center'>";
  30.             echo "<td>{$v['id']}</td>";
  31.             echo "<td>{$v['name']}</td>";
  32.             echo "<td>{$v['age']}</td>";
  33.         echo "</tr>";
  34.     }
  35.     echo "</table>";
  36. }
  38. ?>
上一条：cenos7环境下离线部署Mycat1.6.6.1下一条：PHP的cookie 与 session 技术、7天免密登录
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议
灭绝师太2020-07-20 14:35:471楼
笔记很详细，越往后面的学习，逻辑一定要跟上，不再是学习一些函数对数组，字符串的简单数据操作了，更多的是把这些当工具，去组织逻辑，完成某种功能。

相关文章

查看更多