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

博客列表 > PHP用数据库类实现数据库增删改查

PHP用数据库类实现数据库增删改查

王浩
王浩 原创
2021年10月20日 01:01:41 1106浏览 
  1. 作业内容：
  2. 1、练习课上代码 
  3. 2、看看函数库 
  4. 3、预习类 
  5. 4、修改用户功能（根据添加来改） 
  6. 5、删除用户功能

先上图



FileName : index.php（列表）

  1. <?php
  2. require_once 'Mypdo.class.php';
  3. $pdo = new Mypdo("mysql", "localhost", "study", "root", "root");
  4. $pdo->connect();
  5. $res = $pdo->select("user","*","","id","0,10");
  6. ?>
  8. <!DOCTYPE html>
  9. <html lang="en">
  10. <head>
  11.     <meta charset="UTF-8">
  12.     <meta http-equiv="X-UA-Compatible" content="IE=edge">
  13.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
  14.     <title>用户列表</title>
  15.     <style>
  16.         table{
  17.             width: 100%;
  18.             border-collapse:collapse;
  19.         }
  21.         th, td{
  22.             padding: 5px;
  23.             border: 1px solid #336699;
  24.         }
  25.         th{
  26.             font-size: 20px;
  27.             font-weight: bolder;
  28.             background: #ccc;
  29.         }
  30.     </style>
  31. </head>
  32. <body>
  33.     <h2>用户列表</h2><hr/>
  34.     <button style="margin-bottom:8px;" onclick="add();">添加用户</button>
  35.     <table>
  36.         <tr>
  37.             <th>ID</th>
  38.             <th>帐号</th>
  39.             <th>姓名</th>
  40.             <th>年龄</th>
  41.             <th>电话</th>
  42.             <th>创建时间</th>
  43.             <th>最后登陆时间</th>
  44.             <th>状态</th>
  45.             <th>操作</th>
  46.         </tr>
  47.         <?php foreach($res as $k=>$v){  ?>
  48.         <tr>
  49.             <td><?=$v['id'] ?></td>
  50.             <td><?=$v['account'] ?></td>
  51.             <td><?=$v['name'] ?></td>
  52.             <td><?=$v['age'] ?></td>
  53.             <td><?=$v['phone'] ?></td>
  54.             <td><?=date('Y-m-d', $v['add_time']) ?></td>
  55.             <td><?=date('Y-m-d', $v['last_time']) ?></td>
  56.             <td><?=$v['status']?"正常":"禁用" ?></td>
  57.             <td><a href="javascript:mod(<?=$v['id'] ?>);">修改</a> | <a href="javascript:del(<?=$v['id'] ?>);">删除</a></td>
  58.         </tr>
  59.         <?php } ?>
  60.     </table>
  61.     <script>
  62.         //添加用户
  63.         function add(){
  64.             this.location = "add.php";
  65.         }
  66.         //修改用户
  67.         function mod(id){
  68.             this.location = "mod.php?id=" + id;
  69.         }
  70.         //删除用户
  71.         function del(id){
  72.             if(confirm("确定要删除该用户吗？")){
  73.                 this.location = "del.php?id=" + id;
  74.             }else{
  75.                 return false;
  76.             }
  77.         }
  78.     </script>
  79. </body>
  80. </html>

FileName: add.php(添加)

  1. <!DOCTYPE html>
  2. <html lang="en">
  3. <head>
  4.     <meta charset="UTF-8">
  5.     <meta http-equiv="X-UA-Compatible" content="IE=edge">
  6.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
  7.     <title>添加用户</title>
  8.     <style>
  9.         body{
  10.             background: #eee;
  11.         }
  12.         div{
  13.             padding: 2px;
  14.             background: #ccc;
  15.             width: 400px;
  16.             height: 260px;
  17.             position: absolute;
  18.             left:50%;
  19.             top:50%;
  20.             margin-left:-200px;
  21.             margin-top:-130px;
  22.             border-radius:4px;
  23.             box-shadow: 4px 4px 4px 4px #666;
  24.         }
  25.         div *{
  26.             color:#336699;
  27.             text-align: center;
  28.         }
  29.         input[type="submit"]{
  30.             margin-top:8px;
  31.             width: 220px;
  32.             height: 30px;
  33.         }
  34.     </style>
  36. </head>
  37. <body>
  38. <div>
  39. <h1>添加用户</h1>
  40.     <form method="post">
  41.         账户：<input name="account" type="text" /><br/>
  42.         密码：<input name="password" type="password" /><br/>
  43.         姓名：<input name="name" type="text" /><br/>
  44.         年龄：<input name="age" type="number" /><br/>
  45.         手机：<input name="phone" type="text" /><br/>
  46.         <input type="submit" value="添加" />
  47.     </form>
  48. </div>
  49. </body>
  50. </html>
  51. <?php
  52.     // 1、判断是否是post提交
  53.     if(!empty($_POST)){
  54.         // 2、账户必须填写，如果不填写，就会报错
  55.         if(empty($_POST['account'])){
  56.             echo '<div style="color:red;margin-top:20px;">请输入账户</div>';
  57.             exit;
  58.         }
  59.         // 3、密码必须添加
  60.         if(empty($_POST['password'])){
  61.             echo '<div style="color:red;margin-top:20px;">请输入密码</div>';
  62.             exit;
  63.         }
  64.         $_POST['password'] = md5($_POST['password']);
  65.         $data = [
  66.             "add_time" => time(),
  67.             "last_time" => time(),
  68.             "status" => 1
  69.         ];
  70.         require_once 'Mypdo.class.php';
  71.         $pdo = new Mypdo("mysql", "localhost", "study", "root", "root");
  72.         $pdo->connect();
  73.         if($pdo->insert("user", array_merge($data, $_POST))){
  74.             echo '<script>alert("添加成功"); this.location="index.php"; </script>';
  75.         }else{
  76.             echo '<script>alert("添加失败");</script>';
  77.         }
  78.     }
  79. ?>

FileName : mod.php（修改）

  1. <?php
  2. if(!isset($_GET['id'])){
  3.     die("参数有误");
  4. }
  5. require_once 'Mypdo.class.php';
  6. $pdo = new Mypdo("mysql", "localhost", "study", "root", "root");
  7. $pdo->connect();
  8. $res = $pdo->find("user","*","id={$_GET['id']}");
  9. ?>
  11. <!DOCTYPE html>
  12. <html lang="en">
  13. <head>
  14.     <meta charset="UTF-8">
  15.     <meta http-equiv="X-UA-Compatible" content="IE=edge">
  16.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
  17.     <title>修改用户</title>
  18.     <style>
  19.         body{
  20.             background: #eee;
  21.         }
  22.         div{
  23.             padding: 2px;
  24.             background: #ccc;
  25.             width: 400px;
  26.             height: 260px;
  27.             position: absolute;
  28.             left:50%;
  29.             top:50%;
  30.             margin-left:-200px;
  31.             margin-top:-130px;
  32.             border-radius:4px;
  33.             box-shadow: 4px 4px 4px 4px #666;
  34.         }
  35.         div *{
  36.             color:#336699;
  37.             text-align: center;
  38.         }
  39.         input[type="submit"]{
  40.             margin-top:8px;
  41.             width: 220px;
  42.             height: 30px;
  43.         }
  44.     </style>
  46. </head>
  47. <body>
  48. <div>
  49. <h1>修改用户</h1>
  50.     <form method="post">
  51.         账户：<input name="account" type="text" value="<?=$res['account'] ?>" /><br/>
  52.         姓名：<input name="name" type="text" value="<?=$res['name'] ?>" /><br/>
  53.         年龄：<input name="age" type="number" value="<?=$res['age'] ?>" /><br/>
  54.         手机：<input name="phone" type="text" value="<?=$res['phone'] ?>" /><br/>
  55.         <select name="status" id="status">
  56.             <?php
  57.             for($i=0;$i<2;$i++){
  58.                 echo '<option value="'.$i.'" '.($i==$res['status']?" selected":"") .'>'.($i?"正常":"禁用").'</option>';
  59.             }
  60.             ?>
  61.         </select><br>
  62.         <input type="submit" value="修改" />
  63.     </form>
  64. </div>
  65. </body>
  66. </html>
  67. <?php
  68.     // 1、判断是否是post提交
  69.     if(!empty($_POST)){
  70.         // 2、账户必须填写，如果不填写，就会报错
  71.         if(empty($_POST['account'])){
  72.             echo '<div style="color:red;margin-top:20px;">请输入账户</div>';
  73.             exit;
  74.         }
  75.         require_once 'Mypdo.class.php';
  76.         $pdo = new Mypdo("mysql", "localhost", "study", "root", "root");
  77.         $pdo->connect();
  78.         if($pdo->update("user", $_POST, "id=".$_GET['id'])){
  79.             echo '<script>alert("修改成功"); this.location="index.php"; </script>';
  80.         }else{
  81.             echo '<script>alert("修改失败");</script>';
  82.         }
  83.     }
  84. ?>

FileName：del.php（删除）

  1. <?php
  2. require_once 'Mypdo.class.php';
  3. $pdo = new Mypdo("mysql", "localhost", "study", "root", "root");
  4. $pdo->connect();
  5. if($pdo->delete("user","id=".$_GET['id'])){
  6.     echo '<script>alert("删除成功"); this.location="index.php"; </script>';
  7. }else{
  8.     echo '<script>alert("删除失败");</script>';
  9. }
  10. ?>

Mypdo.class.php（引用类库）

  1. <?php
  3. /**
  4.  * Pdo操作数据库类
  5.  * 2021年10月19日
  6.  */
  8.  class Mypdo{
  9.     private $db_type;       //数据库类型
  10.     private $db_host;       //数据库主机
  11.     private $db_name;       //数据库名
  12.     private $db_user;       //连接数据库帐号
  13.     private $db_password;   //连接数据库密码
  14.     private $pdo;           //连接句柄
  16.     public function __construct($type, $host, $name, $user, $password, $charset = 'utf-8')
  17.     {
  18.         // 存储相关参数
  19.         $this->db_type = $type;
  20.         $this->db_host = $host;
  21.         $this->db_name = $name;
  22.         $this->db_user = $user;
  23.         $this->db_password = $password;
  24.     }
  26.     public function connect(){
  27.         $dsn = "{$this->db_type}:host={$this->db_host}; dbname={$this->db_name}";//数据源
  28.         // echo $dsn;
  29.         // exit;
  30.         try {
  31.             //实例化PDO类,创建PDO对象
  32.             $this->pdo = new PDO($dsn,$this->db_user, $this->db_password);
  33.         } catch (PDOException $e) {
  34.             die('数据库错误:'.$e->getMessage());
  35.         }
  36.         return $this->pdo;
  37.     }
  39.     // 按指定条件，查询多条记录
  40.     public function select($table, $fields='*', $where='', $order='', $limit=''){
  41.         //创建SQL语句
  42.         $sql = 'SELECT ';
  43.         if (is_array($fields)) {    // 支持数组
  44.             foreach ($fields as $field) {
  45.                 $sql .= $field.', ';
  46.             }
  47.         } else {    // 也支持字符串
  48.             $sql .= $fields;
  49.         }
  50.         //去掉最后的豆号和空格
  51.         $sql = rtrim(trim($sql),',');
  52.         $sql .= ' FROM '.$table;
  53.         //查询条件：暂只支持字符串
  54.         if(!empty($where)){
  55.             $sql .= ' WHERE '.$where;
  56.         }
  57.         //排序条件，暂未支持顺序和倒序，默认用倒序吧，新添加的放最前面
  58.         if(!empty($order)) {
  59.             $sql .= ' order by '.$order.' DESC';
  60.         }
  61.         //分页条件
  62.         if(!empty($limit)) {
  63.             $sql .= ' limit '.$limit;
  64.         }
  65.         $sql .= ';';
  66.         //创建PDO预处理对象
  67.         $stmt = $this->pdo->prepare($sql);
  68.         //执行查询操作
  69.         if($stmt->execute()){
  70.             if($stmt->rowCount()>0){
  71.                 $stmt->setFetchMode(PDO::FETCH_ASSOC);
  72.                 //返回一个二维数组
  73.                 return $stmt->fetchAll();
  74.             }
  75.         } else {
  76.             return false;
  77.         }
  78.     }
  80.     // 查询单条记录
  81.     public function find($table,$fields,$where=''){
  82.         //创建SQL语句
  83.         $sql = 'SELECT ';
  84.         if (is_array($fields)) {
  85.             foreach ($fields as $field) {
  86.                 $sql .= $field.', ';
  87.             }
  88.         } else {
  89.             $sql .= $fields;
  90.         }
  91.         $sql = rtrim(trim($sql),',');
  92.         $sql .= ' FROM '.$table;
  93.         //查询条件
  94.         if(!empty($where)){
  95.             $sql .= ' WHERE '.$where;
  96.         }
  97.         $sql .= ' LIMIT 1;';
  98.         //创建PDO预处理对象
  99.         $stmt = $this->pdo->prepare($sql);
  100.         //执行查询操作
  101.         if($stmt->execute()){
  102.             if($stmt->rowCount()>0){
  103.                 $stmt->setFetchMode(PDO::FETCH_ASSOC);
  104.                 return $stmt->fetch();
  105.             }
  106.         } else {
  107.             return false;
  108.         }
  109.     }
  111.     //插入数据
  112.     public function insert($table,$data=[]){
  113.         //创建SQL语句
  114.         $sql = "INSERT INTO {$table} SET ";
  115.         //组装插入语句
  116.         if(is_array($data)){
  117.             foreach ($data as $k=>$v) {
  118.                 $sql .= $k.'="'.$v.'", ';
  119.             }
  120.         }else{
  121.             return false;
  122.         }
  123.         //去掉尾部逗号,并添加分号结束
  124.         $sql = rtrim(trim($sql),',').';';
  125.         //创建PDO预处理对象
  126.         $stmt = $this->pdo->prepare($sql);
  127.         //执行新增操作
  128.         if($stmt->execute()){
  129.             if($stmt->rowCount()>0){
  130.                 return true;
  131.             }
  132.         } else {
  133.             return false;
  134.         }
  135.     }
  137.     // 更新数据
  138.     public function update($table,$data=[], $where='') {
  139.         //创建SQL语句
  140.         $sql = "UPDATE {$table} SET ";
  141.         //组装修改语句
  142.         if(is_array($data)){
  143.             foreach ($data as $k=>$v) {
  144.                 $sql .= $k.'="'.$v.'", ';
  145.             }
  146.         }
  147.         //去掉尾部逗号,并添加分号结束
  148.         $sql = rtrim(trim($sql),',');
  149.         //查询条件
  150.         if(!empty($where)){
  151.             $sql .= ' WHERE '.$where;
  152.         }
  153.         //创建PDO预处理对象
  154.         $stmt = $this->pdo->prepare($sql);
  155.         //执行新增操作
  156.         if($stmt->execute()){
  157.             if($stmt->rowCount()>0){
  158.                 return true;
  159.             }
  160.         } else {
  161.             return false;
  162.         }
  163.     }
  165.     // 删除数据
  166.     public function delete($table,$where=''){
  167.         //创建SQL语句
  168.         $sql = "DELETE FROM {$table}  ";
  169.         //查询条件
  170.         if(!empty($where)){
  171.             $sql .= ' WHERE '.$where;
  172.         }else{  //加上这一句。以防没有条件，删除了所有数据
  173.             return false;
  174.         }
  175.         //创建PDO预处理对象
  176.         $stmt = $this->pdo->prepare($sql);
  177.         //执行删除操作
  178.         if($stmt->execute()){
  179.             if($stmt->rowCount()>0){
  180.                 return true;
  181.             }
  182.         } else {
  183.             return false;
  184.         }
  185.     }
  186.  }
上一条： 记录下我的副业，4个月赚200%，门槛不高 下一条： js执行机制与异步任务
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多
热门课程