suchen

Heim >Backend-Entwicklung >PHP-Tutorial >Beispielcode zum Hinzufügen, Löschen, Ändern und Abfragen der Datenbank mithilfe der PDO-Methode in PHP

Beispielcode zum Hinzufügen, Löschen, Ändern und Abfragen der Datenbank mithilfe der PDO-Methode in PHP

怪我咯
怪我咯Original
2017-07-12 16:10:551413Durchsuche

PDO ist eine öffentliche Klasse für den MySQL-Datenbankbetrieb Wir können pdo direkt zum Betreiben der Datenbank verwenden, ohne die Klasse anzupassen. In der Standardkonfiguration von PHP ist pdo jedoch nicht aktiviert, daher müssen wir es tun Sie müssen es in php.ini aktivieren, bevor Sie es verwenden können.

Sie müssen die PDO-Unterstützung von PHP aktivieren

, um eine Singletonisierung der Datenbankverbindung zu erreichen. Es gibt drei Elemente: statische Variablen, statische Instanziierungsmethoden und private Konstruktoren DPDO.php

class DPDO{
  private $DSN;
  private $DBUser;
  private $DBPwd;
  private $longLink;
  private $pdo;
  //私有构造函数 防止被直接实例化
  private function construct($dsn, $DBUser, $DBPwd, $longLink = false) {
    $this->DSN = $dsn;
    $this->DBUser = $DBUser;
    $this->DBPwd = $DBPwd;
    $this->longLink = $longLink;
    $this->connect();
  }
  //私有 空克隆函数 防止被克隆
  private function clone(){}
  //静态 实例化函数 返回一个pdo对象
  static public function instance($dsn, $DBUser, $DBPwd, $longLink = false){
    static $singleton = array();//静态函数 用于存储实例化对象
    $singIndex = md5($dsn . $DBUser . $DBPwd . $longLink);
    if (empty($singleton[$singIndex])) {
      $singleton[$singIndex] = new self($dsn, $DBUser, $DBPwd, $longLink = false);
    }
    return $singleton[$singIndex]->pdo;
  }
   
  private function connect(){
    try{
      if($this->longLink){
        $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd, array(PDO::ATTR_PERSISTENT => true));
      }else{
        $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd);
      }
      $this->pdo->query('SET NAMES UTF-8');
    } catch(PDOException $e) {
      die(&#39;Error:&#39; . $e->getMessage() . &#39;<br/>&#39;);
    }
  }
}

wird zur Verarbeitung der Feldzuordnung verwendet. Durch die Verwendung der Feldzuordnung von pdo kann SQL-Injection effektiv vermieden werden

//字段关联数组处理， 主要用于写入和更新数据、同and 或 or 的查询条件，产生sql语句和映射字段的数组
  public function FDFields($data, $link = &#39;,&#39;, $judge = array(), $aliasTable = &#39;&#39;){
    $sql = &#39;&#39;;
    $mapData = array();
    foreach($data as $key => $value) {
      $mapIndex = &#39;:&#39; . ($link != &#39;,&#39; ? &#39;c&#39; : &#39;&#39;) . $aliasTable . $key;
      $sql .= &#39; &#39; . ($aliasTable ? $aliasTable . &#39;.&#39; : &#39;&#39;) . &#39;`&#39; . $key . &#39;` &#39; . ($judge[$key] ? $judge[$key] : &#39;=&#39;) . &#39; &#39; . $mapIndex . &#39; &#39; . $link;
      $mapData[$mapIndex] = $value;
    }
    $sql = trim($sql, $link);
    return array($sql, $mapData);
  }
  //用于处理单个字段处理
  public function FDField($field, $value, $judge = &#39;=&#39;, $preMap = &#39;cn&#39;, $aliasTable = &#39;&#39;) {
    $mapIndex = &#39;:&#39; . $preMap . $aliasTable . $field;
    $sql = &#39; &#39; . ($aliasTable ? $aliasTable . &#39;.&#39; : &#39;&#39;) . &#39;`&#39; . $field . &#39;`&#39; . $judge . $mapIndex;
    $mapData[$mapIndex] = $value;
    return array($sql, $mapData);
  }
  //使用刚方法可以便捷产生查询条件及对应数据数组
  public function FDCondition($condition, $mapData) {
    if(is_string($condition)) {
        $where = $condition;
    } else if (is_array($condition)) {
      if($condition[&#39;str&#39;]) {
        if (is_string($condition[&#39;str&#39;])) {
          $where = $condition[&#39;str&#39;];
        } else {
          return false;
        }
      }
      if(is_array($condition[&#39;data&#39;])) {
        $link = $condition[&#39;link&#39;] ? $condition[&#39;link&#39;] : &#39;and&#39;;
        list($conSql, $mapConData) = $this->FDFields($condition[&#39;data&#39;], $link, $condition[&#39;judge&#39;]);
        if ($conSql) {
          $where .= ($where ? &#39; &#39; . $link : &#39;&#39;) . $conSql;
          $mapData = array_merge($mapData, $mapConData);
        }
      }
    }
    return array($where, $mapData);
  }

Details zum Hinzufügen , Löschen, Ändern und Abfragen Implementieren Sie DB.php

public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
    if ($sql) {
      $sql .= &#39; limit 1&#39;;
      $pdoStatement = $this->pdo->prepare($sql, $preType);
      $pdoStatement->execute($searchData);
      return $data = $pdoStatement->fetch($dataMode);
    } else {
      return false;
    }
  }
   
  public function fetchAll($sql, $searchData = array(), $limit = array(0, 10), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
    if ($sql) {
      $sql .= &#39; limit &#39; . (int) $limit[0] . &#39;,&#39; . (intval($limit[1]) > 0 ? intval($limit[1]) : 10);
      $pdoStatement = $this->pdo->prepare($sql, $preType);
      $pdoStatement->execute($searchData);
      return $data = $pdoStatement->fetchAll($dataMode);
    } else {
      return false;
    }
  }
   
  public function insert($tableName, $data, $returnInsertId = false, $replace = false) {
    if(!empty($tableName) && count($data) > 0){
      $sql = $replace ? &#39;REPLACE INTO &#39; : &#39;INSERT INTO &#39;;
      list($setSql, $mapData) = $this->FDFields($data);
      $sql .= $tableName . &#39; set &#39; . $setSql;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet ? ($returnInsertId ? $this->pdo->lastInsertId() : $execRet) : false;
    } else {
      return false;
    }
  }
   
  public function update($tableName, $data, $condition, $mapData = array(), $returnRowCount = true) {
    if(!empty($tableName) && count($data) > 0) {
      $sql = &#39;UPDATE &#39; . $tableName . &#39; SET &#39;;
      list($setSql, $mapSetData) = $this->FDFields($data);
      $sql .= $setSql;
      $mapData = array_merge($mapData, $mapSetData);
      list($where, $mapData) = $this->FDCondition($condition, $mapData);
      $sql .= $where ? &#39; WHERE &#39; . $where : &#39;&#39;;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet ? ($returnRowCount ? $pdoStatement->rowCount() : $execRet) : false;
    } else {
      return false;
    }
  }
   
  public function delete($tableName, $condition, $mapData = array()) {
    if(!empty($tableName) && $condition){
      $sql = &#39;DELETE FROM &#39; . $tableName;
      list($where, $mapData) = $this->FDCondition($condition, $mapData);
      $sql .= $where ? &#39; WHERE &#39; . $where : &#39;&#39;;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet;
    }
  }

Testdatei test.php

header("Content-type: text/html; charset=utf-8");
define(&#39;APP_DIR&#39;, dirname(FILE));
 
if (function_exists(&#39;spl_autoload_register&#39;)) {
  spl_autoload_register(&#39;autoClass&#39;);
} else {
  function auto_load($className){
    autoClass($className);
  }
}
 
function autoClass($className){
  try{
    require_once APP_DIR.&#39;/class/&#39;.$className.&#39;.php&#39;;
  } catch (Exception $e) {
    die(&#39;Error:&#39; . $e->getMessage() . &#39;<br />&#39;);
  }
}
$DB = new DB();
//插入
$inData[&#39;a&#39;] = rand(1, 100);
$inData[&#39;b&#39;] = rand(1, 1000);
$inData[&#39;c&#39;] = rand(1,200) . &#39;.&#39; . rand(1,100);
$ret = $DB->insert(&#39;a&#39;, $inData);
echo &#39;插入&#39; . ($ret ? &#39;成功&#39; : &#39;失败&#39;) . &#39;<br/>&#39;;
//更新
$upConData[&#39;a&#39;] = 100;
$upConJudge[&#39;a&#39;] = &#39;<&#39;;
$upConData[&#39;b&#39;] = 30;
$upConJudge[&#39;b&#39;] = &#39;>&#39;;
list($upConStr, $mapUpConData) = $DB->FDField(&#39;b&#39;, 200, &#39;<&#39;, &#39;gt&#39;);
$condition = array(
  &#39;str&#39; => $upConStr,
  &#39;data&#39; => $upConData,
  &#39;judge&#39; => $upConJudge,
  &#39;link&#39; => &#39;and&#39;
);
$upData[&#39;a&#39;] = rand(1, 10);
$upData[&#39;b&#39;] = 1;
$upData[&#39;c&#39;] = 1.00;
$changeRows = $DB->update(&#39;a&#39;, $upData, $condition, $mapUpConData);
echo &#39;更新行数:&#39; . (int) $changeRows . &#39;<br/>&#39;;
//删除
$delVal = rand(1, 10);
list($delCon, $mapDelCon) = $DB->FDField(&#39;a&#39;, $delVal);
$delRet = $DB->delete(&#39;a&#39;, $delCon, $mapDelCon);
echo &#39;删除a=&#39; . $delVal . ($delRet ? &#39;成功&#39; : &#39;失败&#39;) . &#39;<br/>&#39;;
 
//查询
$data[&#39;a&#39;] = &#39;10&#39;;
$judge[&#39;a&#39;] = &#39;>&#39;;
$data[&#39;b&#39;] = &#39;400&#39;;
$judge[&#39;b&#39;] = &#39;<&#39;;
list($conSql, $mapConData) = $DB->FDFields($data, &#39;and&#39;, $judge);
$mData = $DB->fetch(&#39;select * from a where &#39; . $conSql . &#39; order by `a` desc&#39;, $mapConData);
 
var_dump($mData);

Das obige ist der detaillierte Inhalt vonBeispielcode zum Hinzufügen, Löschen, Ändern und Abfragen der Datenbank mithilfe der PDO-Methode in PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme：
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Vorheriger Artikel：Detaillierte Erläuterung der Beispiele für vorbereitete PHP-PDO-AnweisungenNächster Artikel：Detaillierte Erläuterung der Beispiele für vorbereitete PHP-PDO-Anweisungen

In Verbindung stehende Artikel

Mehr sehen