php中PDO方式實現數據庫的增刪改查

2020-03-22 19:14:21

字體：大中小

來源：轉載

供稿：網友

需要開啟php的pdo支持，php5.1以上版本支持實現數據庫連接單例化，有三要素靜態變量、靜態實例化方法、私有html' target='_blank'>構造函數 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]- 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('Error:' . $e- getMessage() . ' br/ 用于處理字段映射，使用pdo的字段映射，可以有效避免sql注入
//字段關聯數組處理，主要用于寫入和更新數據、同and 或 or 的查詢條件，產生sql語句和映射字段的數組 public function FDFields($data, $link = ',', $judge = array(), $aliasTable = ''){ $sql = ''; $mapData = array(); foreach($data as $key = $value) { $mapIndex = ':' . ($link != ',' 'c' : '') . $aliasTable . $key; $sql .= ' ' . ($aliasTable $aliasTable . '.' : '') . '`' . $key . '` ' . ($judge[$key] $judge[$key] : '=') . ' ' . $mapIndex . ' ' . $link; $mapData[$mapIndex] = $value; $sql = trim($sql, $link); return array($sql, $mapData); //用于處理單個字段處理 public function FDField($field, $value, $judge = '=', $preMap = 'cn', $aliasTable = '') { $mapIndex = ':' . $preMap . $aliasTable . $field; $sql = ' ' . ($aliasTable $aliasTable . '.' : '') . '`' . $field . '`' . $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['str']) { if (is_string($condition['str'])) { $where = $condition['str']; } else { return false; if(is_array($condition['data'])) { $link = $condition['link'] $condition['link'] : 'and'; list($conSql, $mapConData) = $this- FDFields($condition['data'], $link, $condition['judge']); if ($conSql) { $where .= ($where ' ' . $link : '') . $conSql; $mapData = array_merge($mapData, $mapConData); return array($where, $mapData); 增刪改查的具體實現DB.php
public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR = PDO::CURSOR_FWDONLY)) { if ($sql) { $sql .= ' limit 1'; $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 .= ' limit ' . (int) $limit[0] . ',' . (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 'REPLACE INTO ' : 'INSERT INTO '; list($setSql, $mapData) = $this- FDFields($data); $sql .= $tableName . ' set ' . $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 = 'UPDATE ' . $tableName . ' SET '; list($setSql, $mapSetData) = $this- FDFields($data); $sql .= $setSql; $mapData = array_merge($mapData, $mapSetData); list($where, $mapData) = $this- FDCondition($condition, $mapData); $sql .= $where ' WHERE ' . $where : ''; $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 = 'DELETE FROM ' . $tableName; list($where, $mapData) = $this- FDCondition($condition, $mapData); $sql .= $where ' WHERE ' . $where : ''; $pdoStatement = $this- pdo- prepare($sql, array(PDO::ATTR_CURSOR = PDO::CURSOR_FWDONLY)); $execRet = $pdoStatement- execute($mapData); return $execRet;

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯系我們修改或刪除，多謝。

上一篇：PHP安全編碼規范之安全配置篇

下一篇：php自定義數組變量存放全球各個時區信息