search

博客列表 >手敲PHP抽像类及接口案例、用类实现数据CURD－第九期（191129作业）

手敲PHP抽像类及接口案例、用类实现数据CURD－第九期（191129作业）

feng
feng原创
2019年12月01日 21:41:55751浏览

手敲PHP抽像类及接口案例：

  1. <?php
  2. interface iCurd{
  3.     public function create($data);
  4.     public function read();
  5.     public function update($data,$where);
  6.     public function delete($where);
  7. }
  9. class Db implements iCurd{
  10.     protected $pdo=null;
  11.     protected $table;
  12.     public function __construct($dsn,$user,$password,$table='staff')
  13.     {
  14.         $this->pdo=new PDO($dsn,$user,$password);
  15.         $this->table=$table;
  16.     }
  17.     public function read($fields='*',$where='',$limit='0,5')
  18.     {
  19.         // TODO: Implement read() method.
  20.         $where=empty($where)?'':' WHERE '.$where;
  21.         $limit=' LIMIT '.$limit;
  22.         $sql='SELETE '.$fields.' FROM '.$this->table.$where.$limit;
  23.         $stsm=$this->pdo->prepare($sql);
  24.         $stsm->execute();
  25.         return $stsm->fetchAll(PDO::FETCH_ASSOC);
  26.     }
  27.     public function create($data)
  28.     {
  29.         // TODO: Implement create() method.
  30.         $fields=' (name,age,sex,position,mobile,hiredate)';
  31.         $values='(:name,:age,:sex,:position,:mobile,:hiredate)';
  32.         $sql='INSERT INTO '.$this->table.$fields.' VALUES '.$values;
  33.         $stsm=$this->pdo->prepare($sql);
  34.         $stsm->execute($data);
  35.         return [
  36.             'count'=>$stsm->rowCount(),
  37.             'id'=>$this->pdo->lastInsertId()
  38.         ];
  39.     }
  41.     public function update($data, $where)
  42.     {
  43.         // TODO: Implement update() method.
  44.         $keyArr=array_keys($data);
  45.         $set='';
  46.         foreach ($keyArr as $value){
  47.             $set.=$value.' =:'.$value.', ';
  48.         }
  49.         $set=trim(rtrim($set,','));
  50.         $sql='UPDATE '.$this->table.' SET '.$set.' WHERE '.$where;
  51.         $stsm=$this->pdo->prepare($set);
  52.         $stsm->execute($data);
  53.         return $stsm->rowCount();
  54.     }
  56.     public function delete($where)
  57.     {
  58.         // TODO: Implement delete() method.
  59.         $sql='DELETE FROM '.$this->table.' WHERE '.$where;
  60.         $stsm=$this->pdo->prepare($sql);
  61.         $stsm->execute();
  62.         return $stsm->rowCount();
  63.     }
  64. }
  66. $dsn='mysql:host=localhost;dbname=ouk';
  67. $user='root';
  68. $password='123456';
  69. $db=new Db($dsn,$user,$password);
  71. foreach ($db->read() as $item){
  72.     print_r($item);
  73.     echo '<br>';
  74. }
  75. echo '<hr>';
  77. $data=[
  78.     'name'=>'郭靖',
  79.     'age'=>30,
  80.     'sex'=>1,
  81.     'position'=>'金刀附马',
  82.     'mobile'=>1388888888,
  83.     'hiretime'=>time()
  84. ];
  85. $res=$db->create($data);
  86. echo '成功新增'.$res['count'].'条记录，最新记录的主键是：'.$res['id'];
  87. echo '<hr>';
  89. $data=[
  90.     'age'=>5,
  91.     'position'=>'抗金英雄'
  92. ];
  93. $where='id=5';
  94. echo '成功更新了:'.$db->update($data,$where).'条记录';
  95. echo '<hr>';
  97. $where='id=5';
  98. echo '成功删除了'.$db->delete($where).'条记录';

二、用类实现数据库CURD

  1. <?php
  2. class Db{
  3.     public $dsn;
  4.     public $user;
  5.     public $password;
  6.     public $pdo=null;
  8.     public function __construct($dsn,$user,$password)
  9.     {
  10.         $this->dsn=$dsn;
  11.         $this->user=$user;
  12.         $this->password=$password;
  13.         $this->connect();
  14.     }
  16.     public function connect(){
  17.         $this->pdo=new PDO($this->dsn,$this->user,$this->password);
  18.     }
  20.     public function select($table,$fields='*',$where='',$order='',$limit=''){
  21.         $sql='SELECT ';
  22.         if (is_array($fields)){
  23.             foreach ($fields as $field){
  24.                 $sql=$sql.$field.',';
  25.             }
  26.             $sql=rtrim(trim($sql),',');
  27.         }else{
  28.             $sql.=$fields;
  29.         }
  30.         $sql.=' FROM '.$table;
  31. //        die($sql);
  32.         if (!is_null($where)){
  33.             $sql.=' WHERE '.$where;
  34.         }
  35. //        die($sql);
  36.         if(!is_null($order)){
  37.             $sql.=' order by '.$order;
  38.         }
  39.         if(!is_null($limit)){
  40.             $sql.=' limit '.$limit;
  41.         }
  42. //        var_dump($this->pdo);die;
  43.         $stsm=$this->pdo->prepare($sql);
  44.         if($stsm->execute()){
  45.             if($stsm->rowCount()>0){
  46.                 $stsm->setFetchMode(PDO::FETCH_ASSOC);
  47.                 return $stsm->fetchAll();
  48.             }
  49.         }
  50.         return false;
  51.     }
  53.     public function insert($table,$data=[]){
  54.         $sql='insert into '.$table.' set ';
  55.         if (is_array($data)){
  56.             foreach ($data as $field => $value){
  57.                 $sql.=($field.'=\''.$value.'\',');
  58.             }
  59.             $sql=rtrim(trim($sql),',');
  60.             $stsm=$this->pdo->prepare($sql);
  61.             if($stsm->execute()){
  62.                 if($stsm->rowCount()>0){
  63.                     return '插入的ID号为'.$this->pdo->lastInsertID();
  64.                 }else{
  65.                     return false;
  66.                 }
  67.             }else{
  68.                 return false;
  69.             }
  70.         }
  71.         return false;
  72.     }
  74.     public function update($table,$where=[],$set=[]){
  75.         $sql="update {$table} set ";
  76.         if(is_array($set)){
  77.             foreach ($set as $field => $value){
  78.                 $sql.=($field.'=\''.$value.'\',');
  79.             }
  80.             $sql=rtrim(trim($sql),',');
  81. //            die($sql);
  82.         }else{
  83.             return false;
  84.         }
  85.         if (is_array($where)){
  86.             $sql.=' where ';
  87.             foreach ($where as $field => $value){
  88.                 $sql.=($field.' = \''.$value.'\'' . ' and ');
  89.             }
  90.             $sql=rtrim(trim($sql),' and ');
  91.             $stsm=$this->pdo->prepare($sql);
  92.             if ($stsm->execute()){
  93.                 if ($stsm->rowcount()>0){
  94.                     return '修改记录数为：'.$stsm->rowcount();
  95.                 }else{
  96.                     return false;
  97.                 }
  98.             }else{
  99.                 return false;
  100.             }
  101.         }else{
  102.             return false;
  103.         }
  104.     }
  106.     public function delete($table,$where=[]){
  107.         $sql="delete from {$table} where ";
  108.         if (is_array($where)){
  109.             foreach ($where as $field => $value){
  110.                 $sql.=($field.' = \''.$value.'\'' . ' and ');
  111.             }
  112.             $sql=rtrim(trim($sql),' and ');
  113. //            die($sql);
  114.             $stsm=$this->pdo->prepare($sql);
  115.             if ($stsm->execute()){
  116.                 if ($stsm->rowcount()>0){
  117.                     return '删除记录数为：'.$stsm->rowcount();
  118.                 }else{
  119.                     return false;
  120.                 }
  121.             }else{
  122.                 return false;
  123.             }
  124.         }else{
  125.             return false;
  126.         }
  127.     }
  129.     public function count_num($table){
  130.         $sql='select count(*) as total from '.$table;
  131.         $stsm=$this->pdo->prepare($sql);
  132.         if ($stsm->execute()){
  133.             if ($stsm->rowCount()>0){
  134.                 $total=$stsm->fetchColumn();
  135.                 return "表{$table}总共有记录数{$total}条";
  136.             }else{
  137.                 return false;
  138.             }
  139.         }else{
  140.             return false;
  141.         }
  142.     }
  143. }
  144. $dsn='mysql:host=localhost;dbname=emshop';
  145. $obj=new Db($dsn,'root',123456);
  146. //print_r($obj->select('movies',['mov_id','name','cate_id'],'mov_id>3','mov_id desc','4'));
  147. //echo $obj->insert('category',['name'=>'aa','alias'=>'bb']);
  148. //echo $obj->update('category',['cate_id'=>'9','name'=>'aa'],['name'=>'cc','alias'=>'dd']);
  149. //echo $obj->delete('category',['cate_id'=>'9','name'=>'aa']);
  150. echo $obj->count_num('movies');
上一条：11月29日_抽象类和接口下一条：PHP第13课-类的封装继承-九期线上班
声明：本文内容转载自脚本之家，由网友自发贡献，版权归原作者所有，如您发现涉嫌抄袭侵权，请联系admin@php.cn 核实处理。
全部评论
文明上网理性发言，请遵守新闻评论服务协议

相关文章

查看更多