Exemple de code pour ajouter, supprimer, modifier et interroger la base de données à l'aide de la méthode PDO en PHP-tutoriel php-php.cn

Exemple de code pour ajouter, supprimer, modifier et interroger la base de données à l'aide de la méthode PDO en PHP

怪我咯

Libérer： 2023-03-13 19:08:01

original

1407 Les gens l'ont consulté

PDO est une classe publique pour le fonctionnement de la base de données mysql Nous pouvons directement utiliser pdo pour faire fonctionner la base de données sans personnaliser la classe. Cependant, dans la configuration par défaut de php, pdo n'est pas activé, nous devons donc. Vous devez l'activer dans php.ini avant de pouvoir l'utiliser.

Vous devez activer la prise en charge de PHP5.1 ou supérieur

pour réaliser la singletonisation de la connexion à la base de données. Il existe trois éléments de variables statiques, de méthodes d'instanciation statique et de privées. constructors 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(&#39;SET NAMES UTF-8&#39;);
    } catch(PDOException $e) {
      die(&#39;Error:&#39; . $e->getMessage() . &#39;<br/>&#39;);
    }
  }
}

Copier après la connexion

est utilisé pour traiter le mapping de champ L'utilisation du mappage de champ de pdo peut efficacement éviter l'injection SQL

//字段关联数组处理， 主要用于写入和更新数据、同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);
  }

Copier après la connexion

Détails spécifiques de. ajout, suppression, modification et requête Implémenter 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;
    }
  }

Copier après la connexion

fichier de test 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);

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!