Community Learn Tools Library Leisure
search
English
Home > List of blog posts > PHP用数据库类实现数据库增删改查
Blogger Information
Blog 19
fans 0
comment 0
visits 13238
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
PHP用数据库类实现数据库增删改查
王浩
Original
1146 people have browsed it
  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.  }
Correcting teacher：PHPzPHPz

Correction status：qualified

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