2020年6月5日

    1. <?php
    2. echo"<pre>";
    3. include './demo6.php';
    4. include './Model.demo7.php';
    5. $obj=Model::connect();
    6. $res=$obj
    7.   ->table('books')
    8.     ->where('book_id','=',1000)
    9.     ->sava([
    10.   'title' => 'qt'
    11.   ]);
    12.   var_dump("执行语句结果：",$res);
    13.   var_dump($obj);
    14. echo"</pre>";
    17. class Model{
    18. private static $obj =null;//保存model对象
    19. protected $link= null;//保存数据库链接
    20.  protected $tableName;//保存表名
    21.   protected $sql;//保存完成的sql语句
    22. protected $where ='WHERE';//保存条件
    26. private function{
    27. try{
    28. //连接数据库
    29. $this->link=new PDO(DSN,USER,PASS);
    30. //设置错误报告
    31.   $this->link->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
    32. }catch(PDOException $e){
    33. exit($e->getMessage());
    34. }
    35.   }
    36.  public static function connect(){
    37.  if(self::$obj===null){
    38.  self::$obj=new self(); 
    39.  }
    40.  return self::$obj;
    41.  }
    43. public static add($data){
    44. $keys=array_keys($data);
    45. $vals=array_values($data);
    46. //生成字段
    47. $keys_str=implode(',',$keys);
    48. $vals_str=sprintf("'$s'",implode("','",$vals));
    49. $this->getsql('add',[
    50. $keys_str,
    51.   $vals_str,
    52. ]);
    53. return $this->exec();
    54. }  
    55.  //数据库删除函数 
    56.   public function delete{
    57.   $this->getsql('del');
    58.   return $this->exec();
    59.   }
    62.   //修改函数
    63.   public function sava{
    64.   $sava_data=[];
    65.   foreach($data as $k => $v){
    66.   $sava_data[]=sprintf("%s='$s'",$k,$v);
    67.   }
    68.     $sava_data_str=imlode(',',$sava_data);
    70.     $this->getsql('edit',[
    71.     $sava_data_str
    72.     ]);
    73.     return $this->exec();
    74.   }
    76.   //辅助函数 设置表名
    77.   public function table($name){
    78.   $this->tableName=$name;
    79.   return $this;
    80.   }
    83.   protected function getsql($type,$data=[]){
    84.   if(!$this->tableName){
    85.   exit("请设置表名");
    86.   }
    87.   switch($type){
    88.     case 'add':
    89.       $this->sql = sprintf("INSERT INTO %s(%s) VALUES(%s)",$this->tableName,$data[0],$data[1]);
    90.       break;
    91.     case 'del':
    92.       if($this->where == 'WHERE'){
    93.       exit("delete操作不能没有where条件;");
    94.       }
    95.   $this->sql=sprintf("DELETE FROM %s %s",$this->tableName,$this->where);
    96.  break; 
    97.     case 'edit':
    98.       if($this->where == 'WHERE'){
    99.        $this->sql=sprintf("UPDATE %s SET %s %s",$this->tableName,$data[0],$this->where);
    100.         break; 
    101.       }
    102.   }
    103.   }
    105.   public function exec(){
    106.   return $this->link->exec($this->sql);
    107.   }
    109.    public function where($field,$mark,$data,$rel='AND'){
    110.    if($this->where=='WHERE'){
    111.      //第一个条件
    112.    $this->.=sprintf("%s %s '%s'",$field,$mark,$data);
    113.    }else{
    114.      //第二个条件和第n个
    115.    $this->.=sprintf(" %s %s %s %s",$rel,$field,$mark,$data);
    116.    }
    117.    return $this;
    119.    }
    120.   //设置查询时的字段
    121. public function field(){
    122. $p=func_get_args();
    123. $this->field-implode(',',$p);
    124. return $this;
    125. }
    126. }
    129. <?php
    130. echo"<pre>";
    131. include './demo6.php';
    132. include './Model.demo7.php';
    133. $obj=Model::connect();
    134. $res=$obj
    135.   ->table('books')
    136.     ->where('book_id','=',1000)
    137.     ->sava([
    138.   'title' => 'qt'
    139.   ]);
    140.   var_dump("执行语句结果：",$res);
    141.   var_dump($obj);
    142. echo"</pre>";
    145. class Model{
    146. private static $obj =null;//保存model对象
    147. protected $link= null;//保存数据库链接
    148.  protected $tableName;//保存表名
    149.   protected $sql;//保存完成的sql语句
    150. protected $where ='WHERE';//保存条件
    154. private function{
    155. try{
    156. //连接数据库
    157. $this->link=new PDO(DSN,USER,PASS);
    158. //设置错误报告
    159.   $this->link->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
    160. }catch(PDOException $e){
    161. exit($e->getMessage());
    162. }
    163.   }
    164.  public static function connect(){
    165.  if(self::$obj===null){
    166.  self::$obj=new self(); 
    167.  }
    168.  return self::$obj;
    169.  }
    171. public static add($data){
    172. $keys=array_keys($data);
    173. $vals=array_values($data);
    174. //生成字段
    175. $keys_str=implode(',',$keys);
    176. $vals_str=sprintf("'$s'",implode("','",$vals));
    177. $this->getsql('add',[
    178. $keys_str,
    179.   $vals_str,
    180. ]);
    181. return $this->exec();
    182. }  
    183.  //数据库删除函数 
    184.   public function delete{
    185.   $this->getsql('del');
    186.   return $this->exec();
    187.   }
    190.   //修改函数
    191.   public function sava{
    192.   $sava_data=[];
    193.   foreach($data as $k => $v){
    194.   $sava_data[]=sprintf("%s='$s'",$k,$v);
    195.   }
    196.     $sava_data_str=imlode(',',$sava_data);
    198.     $this->getsql('edit',[
    199.     $sava_data_str
    200.     ]);
    201.     return $this->exec();
    202.   }
    204.   //辅助函数 设置表名
    205.   public function table($name){
    206.   $this->tableName=$name;
    207.   return $this;
    208.   }
    211.   protected function getsql($type,$data=[]){
    212.   if(!$this->tableName){
    213.   exit("请设置表名");
    214.   }
    215.   switch($type){
    216.     case 'add':
    217.       $this->sql = sprintf("INSERT INTO %s(%s) VALUES(%s)",$this->tableName,$data[0],$data[1]);
    218.       break;
    219.     case 'del':
    220.       if($this->where == 'WHERE'){
    221.       exit("delete操作不能没有where条件;");
    222.       }
    223.   $this->sql=sprintf("DELETE FROM %s %s",$this->tableName,$this->where);
    224.  break; 
    225.     case 'edit':
    226.       if($this->where == 'WHERE'){
    227.        $this->sql=sprintf("UPDATE %s SET %s %s",$this->tableName,$data[0],$this->where);
    228.         break; 
    229.       }
    230.   }
    231.   }
    233.   public function exec(){
    234.   return $this->link->exec($this->sql);
    235.   }
    237.    public function where($field,$mark,$data,$rel='AND'){
    238.    if($this->where=='WHERE'){
    239.      //第一个条件
    240.    $this->.=sprintf("%s %s '%s'",$field,$mark,$data);
    241.    }else{
    242.      //第二个条件和第n个
    243.    $this->.=sprintf(" %s %s %s %s",$rel,$field,$mark,$data);
    244.    }
    245.    return $this;
    247.    }
    248.   //设置查询时的字段
    249. public function field(){
    250. $p=func_get_args();
    251. $this->field-implode(',',$p);
    252. return $this;
    253. }
    254. }
    258. <?php
    259. echo"<pre>";
    260. include './demo6.php';
    261. include './Model.demo7.php';
    262. $obj=Model::connect();
    263. $res=$obj
    264.   ->table('books')
    265.     ->where('book_id','=',1000)
    266.     ->sava([
    267.   'title' => 'qt'
    268.   ]);
    269.   var_dump("执行语句结果：",$res);
    270.   var_dump($obj);
    271. echo"</pre>";
    274. class Model{
    275. private static $obj =null;//保存model对象
    276. protected $link= null;//保存数据库链接
    277.  protected $tableName;//保存表名
    278.   protected $sql;//保存完成的sql语句
    279. protected $where ='WHERE';//保存条件
    283. private function{
    284. try{
    285. //连接数据库
    286. $this->link=new PDO(DSN,USER,PASS);
    287. //设置错误报告
    288.   $this->link->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
    289. }catch(PDOException $e){
    290. exit($e->getMessage());
    291. }
    292.   }
    293.  public static function connect(){
    294.  if(self::$obj===null){
    295.  self::$obj=new self(); 
    296.  }
    297.  return self::$obj;
    298.  }
    300. public static add($data){
    301. $keys=array_keys($data);
    302. $vals=array_values($data);
    303. //生成字段
    304. $keys_str=implode(',',$keys);
    305. $vals_str=sprintf("'$s'",implode("','",$vals));
    306. $this->getsql('add',[
    307. $keys_str,
    308.   $vals_str,
    309. ]);
    310. return $this->exec();
    311. }  
    312.  //数据库删除函数 
    313.   public function delete{
    314.   $this->getsql('del');
    315.   return $this->exec();
    316.   }
    319.   //修改函数
    320.   public function sava{
    321.   $sava_data=[];
    322.   foreach($data as $k => $v){
    323.   $sava_data[]=sprintf("%s='$s'",$k,$v);
    324.   }
    325.     $sava_data_str=imlode(',',$sava_data);
    327.     $this->getsql('edit',[
    328.     $sava_data_str
    329.     ]);
    330.     return $this->exec();
    331.   }
    333.   //辅助函数 设置表名
    334.   public function table($name){
    335.   $this->tableName=$name;
    336.   return $this;
    337.   }
    340.   protected function getsql($type,$data=[]){
    341.   if(!$this->tableName){
    342.   exit("请设置表名");
    343.   }
    344.   switch($type){
    345.     case 'add':
    346.       $this->sql = sprintf("INSERT INTO %s(%s) VALUES(%s)",$this->tableName,$data[0],$data[1]);
    347.       break;
    348.     case 'del':
    349.       if($this->where == 'WHERE'){
    350.       exit("delete操作不能没有where条件;");
    351.       }
    352.   $this->sql=sprintf("DELETE FROM %s %s",$this->tableName,$this->where);
    353.  break; 
    354.     case 'edit':
    355.       if($this->where == 'WHERE'){
    356.        $this->sql=sprintf("UPDATE %s SET %s %s",$this->tableName,$data[0],$this->where);
    357.         break; 
    358.       }
    359.   }
    360.   }
    362.   public function exec(){
    363.   return $this->link->exec($this->sql);
    364.   }
    366.    public function where($field,$mark,$data,$rel='AND'){
    367.    if($this->where=='WHERE'){
    368.      //第一个条件
    369.    $this->.=sprintf("%s %s '%s'",$field,$mark,$data);
    370.    }else{
    371.      //第二个条件和第n个
    372.    $this->.=sprintf(" %s %s %s %s",$rel,$field,$mark,$data);
    373.    }
    374.    return $this;
    376.    }
    377.   //设置查询时的字段
    378. public function field(){
    379. $p=func_get_args();
    380. $this->field-implode(',',$p);
    381. return $this;
    382. }
    383. }

    笔记：
    Model:封装数据库的增删改查操作函数

    数据库的新增操作：
    INSERT INTO money(name,rmb)VALUES(‘QT’,’1000’)
    INSERT INTO 表名（字段名，字段名2…）VALUES(值,值2…)
    数组方式：[‘name’=>’qt’]按前面的格式；设置字段和值
    数组的下标为字段名，数组的值为要添加的值

    封装生成语句函数：
    $type:add
    del
    edit
    get

    修改函数：
    UPDATA money SET 字段=值，字段=值 WHERE id=1

    封装where条件设置：
    WHERE id= 1;
    WHERE id= 1 OR id = 2;
    WHERE id= 1AND name =2;
    WHERE id= 1AND name =2 AND title = 3;
    WHERE id= 1AND name =2 OR title = 3;
    每调用一次则设置一次where条件；当第一次设置时则直接设置，当第二次或多次时那新增条件需要和原有条件相结合