PDO数据库操作类——更新数据的实现

曾经终败给现在 2021-12-12 09:47 450阅读 0赞

使用PDO数据库抽象层往数据表中更新、插入或者删除数据，都是通过PDO的exec()方法，如果你熟悉Mysql数据库的sql语句，那么理解起来就更轻松了，你可以把它当作mysql的query()来使用，而且exec()执行完毕还会返回影响的数据行总数。

例如存在表mo2g\_test

我们要更新mo2g\_test中id为1的数据，把他的name值更改为mysql，那么mysql的使用方法如下

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> </td> 
   <td> <p><code>$strSql&nbsp;=&nbsp;</code><code>"update&nbsp;mo2g_test&nbsp;set&nbsp;name&nbsp;=&nbsp;'mysql'&nbsp;where&nbsp;id&nbsp;=&nbsp;1"</code><code>;</code></p> <p><code>mysql_query($strSql);</code></p> <p><code>$reslut&nbsp;=&nbsp;mysql_affected_rows();//返回影响了多少行数据</code></p> </td> 
  </tr> 
 </tbody> 
</table>

PDO的exec()更简单

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> </td> 
   <td> <p><code>$strSql</code>&nbsp;<code>=&nbsp;</code><code>"update&nbsp;mo2g_test&nbsp;set&nbsp;name&nbsp;=&nbsp;'mysql'&nbsp;where&nbsp;id&nbsp;=&nbsp;1"</code><code>;</code></p> <p><code>$reslut</code>&nbsp;<code>=&nbsp;</code><code>$pdo</code><code>-&gt;</code><code>exec</code><code>(</code><code>$strSql</code><code>);</code><code>//返回影响了多少行数据</code></p> </td> 
  </tr> 
 </tbody> 
</table>

其实更新数据的sql都有固定的格式：

1）更新一个属性

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>update</code>&nbsp;<code>数据表&nbsp;</code><code>set</code>&nbsp;<code>属性名&nbsp;=&nbsp;</code><code>'更新内容'</code>&nbsp;<code>where</code>&nbsp;<code>更新条件</code></p> </td> 
  </tr> 
 </tbody> 
</table>

2）更新多个属性

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>update</code>&nbsp;<code>数据表&nbsp;</code><code>set</code>&nbsp;<code>属性名1&nbsp;=&nbsp;</code><code>'更新内容'</code><code>,属性名2&nbsp;=&nbsp;</code><code>'更新内容'</code><code>,属性名n&nbsp;=&nbsp;</code><code>'更新内容'</code>&nbsp;<code>where</code>&nbsp;<code>更新条件</code></p> </td> 
  </tr> 
 </tbody> 
</table>

所以，我根据这一特征封装了PDO类的update方法

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>function</code>&nbsp;<code>update(</code><code>$table</code><code>,</code><code>$arrData</code><code>,</code><code>$condition</code><code>)&nbsp;{}</code></p> </td> 
  </tr> 
 </tbody> 
</table>

1）$table为数据表的名称

2）$arrData为要更新的数据

3）$condition为更新条件

这里我们使用封装好的update演示一下如何更新上述的数据：

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> <p>4</p> </td> 
   <td> <p><code>$talbe</code>&nbsp;<code>=&nbsp;</code><code>'mo2g_test'</code><code>;</code></p> <p><code>$arrData</code>&nbsp;<code>=&nbsp;</code><code>array</code><code>(</code><code>'name'</code><code>=&gt;</code><code>'mysql'</code><code>);</code></p> <p><code>$condition</code>&nbsp;<code>=&nbsp;</code><code>'id&nbsp;=&nbsp;1'</code><code>;</code></p> <p><code>$pdo</code><code>-&gt;update(</code><code>$table</code><code>,</code><code>$arrData</code><code>,</code><code>$condition</code><code>);</code></p> </td> 
  </tr> 
 </tbody> 
</table>

update函数的实现代码如下

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> <p>4</p> <p>5</p> <p>6</p> <p>7</p> <p>8</p> <p>9</p> <p>10</p> <p>11</p> <p>12</p> <p>13</p> <p>14</p> </td> 
   <td> <p><code>public</code>&nbsp;<code>function</code>&nbsp;<code>update(</code><code>$table</code><code>,</code><code>$arrData</code><code>,</code><code>$condition</code><code>)&nbsp;{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$flag</code>&nbsp;<code>=&nbsp;1;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>foreach</code><code>(</code><code>$arrData</code>&nbsp;<code>as</code>&nbsp;<code>$key</code>&nbsp;<code>=&gt;&nbsp;</code><code>$value</code><code>)&nbsp;{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code><code>(</code><code>$flag</code><code>)&nbsp;{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$data</code>&nbsp;<code>=&nbsp;</code><code>"$key&nbsp;=&nbsp;'$value'"</code><code>;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$flag</code>&nbsp;<code>=&nbsp;0;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>$data</code>&nbsp;<code>.=&nbsp;</code><code>",$key&nbsp;=&nbsp;'$value'"</code><code>;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$strSql</code>&nbsp;<code>=&nbsp;</code><code>"update&nbsp;$table&nbsp;set&nbsp;$data&nbsp;where&nbsp;$condition"</code><code>;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code><code>(</code><code>$this</code><code>-&gt;result&nbsp;=&nbsp;</code><code>$this</code><code>-&gt;db-&gt;</code><code>exec</code><code>(</code><code>$strSql</code><code>))&nbsp;{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>true;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>false;</code></p> <p><code>}</code></p> </td> 
  </tr> 
 </tbody> 
</table>

<?php
     2          $data = array(array('id' => 1, 'val' => 2), array('id' => 2, 'val' => 3));
     3          $update_sql = 'UPDATE tbl_test SET val = CASE id';
     4          $params = array();
     5          $params[":ids"] = $ids;
     6          $in_arr = array();
     7 
     8          foreach($data as $key => $item) {
     9                  $update_sql .= "WHEN :id_" . $key . "THEN :val_" . $key . " ";
    10                  $params[":id_" . $key] = $item['id'];
    11                  $params[":val_" . $key] = $item['val'];
    12                  $params[":ids_" . $key] = $item['id'];
    13                  array_push($in_arr, ":id_" . $key);
    14          }
    15          $update_sql .= "END WHERE id IN (" . implode(',' $in_arr) . ")";
    16          TEST::execute($update_sql, $params);//此处会调用bindParam绑定参数
    ?>

$pdo->select('*','mo2g_test','id=1');//获取id为1的数据
    $arrData = $pdo->fetch();//获取找到的数据
    print_r($arrData);//输出找到的数据
     
    $pdo->select('*','mo2g_test','id>1','id');//根据id从大到小进行排序
    $pdo->select('*','mo2g_test','id>1','id asc');//根据id从小到大进行排序
    $pdo->select('*','mo2g_test','id>1',array('field'=>'id','order'=>'asc'));//根据id从小到大进行排序
    $pdo->select('*','mo2g_test','id>1','id','limit 1');//根据id从大到小进行排序,并只获取1条数据
    $arrData = $pdo->fetch_all();//获取找到的所有数据
    print_r($arrData);//输出找到的数据
     
    //推荐使用的查询方式
    public function query($strSql) {
        $this->result = $this->db->query($strSql);
        return $this;
    }
     
    /*
    $select：要获取的属性
    $table：数据表名称
    $condition：获取条件
    $order：数据排序
    $limit：获取几条数据
    */
    public function select($select,$table,$condition = '',$order = array(), $limit = '') {
        if( is_array($order) && isset($order['order']) && ( $order['order'] == 'desc' || $order['order'] == 'asc' ) && isset($order['field']) ) {
            $order = "order by $order[field] $order[order]";
        } elseif( is_string($order) ) {
            $order = "order by {$order}";
        } else $order = '';
        $this->sql = $strSql = $condition == '' ?
            "select $select 
            from $table 
            $order 
            $limit"    
            :  
            "select $select 
            from $table 
            where $condition 
            $order 
            $limit";
        if($this->result = $this->db->query($strSql)) {
            return $this;
        }
        return $this;
    }
    //获取所有查询到的数据
    public function fetch_all() {
        $arrData = array();
        if( $this->result ) {
            while($row = $this->result->fetch(PDO::FETCH_ASSOC) ) {
                $arrData[] = $row;
            }
        }
        return $arrData;
    }
    //获取一条查询到的数据
    public function fetch() {
        $arrData = array();
        if( $this->result ) {
            $arrData = $this->result->fetch(PDO::FETCH_ASSOC);
        }
        return $arrData;
    }

public function delete($table,$condition) {
        $strSql = "delete from $table where $condition";
        if($this->result = $this->db->exec($strSql)){
            return $this;
        }
        return false;
    }

# [使用PHP的PDO扩展进行批量更新操作][PHP_PDO] #

<?php
         $data = array(array('id' => 1, 'val' => 2), array('id' => 2, 'val' => 3));
         $update_sql = 'UPDATE tbl_test SET val = CASE id';
         $params = array();
         $params[":ids"] = $ids;
         $in_arr = array();
    
         foreach($data as $key => $item) {
                 $update_sql .= "WHEN :id_" . $key . "THEN :val_" . $key . " ";
                 $params[":id_" . $key] = $item['id'];
                 $params[":val_" . $key] = $item['val'];
                 $params[":ids_" . $key] = $item['id'];
                 array_push($in_arr, ":id_" . $key);
         }
         $update_sql .= "END WHERE id IN (" . implode(',' $in_arr) . ")";
         TEST::execute($update_sql, $params);//此处会调用bindParam绑定参数
    ?>

[PHP_PDO]: https://segmentfault.com/a/1190000005001059