本文實(shí)例講述了PHP的PDO常用類庫。分享給大家供大家參考，具體如下：

1、Db.class.php 連接數(shù)據(jù)庫

<?php

// 連接數(shù)據(jù)庫

class Db {

  static public function getDB() {

    try {

      $pdo = new PDO(DB_DSN, DB_USER, DB_PWD);

      $pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 設(shè)置數(shù)據(jù)庫連接為持久連接

      $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 設(shè)置拋出錯(cuò)誤

      $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 設(shè)置當(dāng)字符串為空轉(zhuǎn)換為 SQL 的 NULL

      $pdo->query('SET NAMES utf8'); // 設(shè)置數(shù)據(jù)庫編碼

    } catch (PDOException $e) {

      exit('數(shù)據(jù)庫連接錯(cuò)誤，錯(cuò)誤信息：'. $e->getMessage());

    }

    return $pdo;

  }

}

?>

2、Model.class.php 數(shù)據(jù)庫操作類

<?php

/**

* 數(shù)據(jù)庫操作類庫

* author Lee.

* Last modify $Date: 2012-1-19 13:59；04 $

*/

class M {

  private $_db; //數(shù)據(jù)庫句柄

  public $_sql; //SQL語句

  /**

   * 構(gòu)造方法

   */

  public function __construct() {

    $this->_db = Db::getDB();

  }

  /**

   * 數(shù)據(jù)庫添加操作

   * @param string $tName 表名

   * @param array $field 字段數(shù)組

   * @param array $val 值數(shù)組

   * @param bool $is_lastInsertId 是否返回添加ID

   * @return int 默認(rèn)返回成功與否，$is_lastInsertId 為true，返回添加ID

   */

  public function insert($tName, $fields, $vals, $is_lastInsertId=FALSE) {

    try {

      if (!is_array($fields) || !is_array($vals))

        exit($this->getError(__FUNCTION__, __LINE__));

      $fields = $this->formatArr($fields);

      $vals = $this->formatArr($vals, false);

      $tName = $this->formatTabName($tName);

      $this->_sql = "INSERT INTO {$tName} ({$fields}) VALUES ({$vals})";

      if (!$is_lastInsertId) {

        $row = $this->_db->exec($this->_sql);

        return $row;

      } else {

        $this->_db->exec($this->_sql);

        $lastId = (int)$this->_db->lastInsertId();

        return $lastId;

      }

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 數(shù)據(jù)庫修改操作

   * @param string $tName 表名

   * @param array $field 字段數(shù)組

   * @param array $val 值數(shù)組

   * @param string $condition 條件

   * @return int 受影響的行數(shù)

   */

  public function update($tName, $fieldVal, $condition) {

    try {

      if (!is_array($fieldVal) || !is_string($tName) || !is_string($condition))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $upStr = '';

      foreach ($fieldVal as $k=>$v) {

        $upStr .= '`'.$k . '`=' . '\'' . $v . '\'' . ',';

      }

      $upStr = rtrim($upStr, ',');

      $this->_sql = "UPDATE {$tName} SET {$upStr} WHERE {$condition}";

      $row = $this->_db->exec($this->_sql);

      return $row;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 數(shù)據(jù)庫刪除操作（注：必須添加 where 條件）

   * @param string $tName 表名

   * @param string $condition 條件

   * @return int 受影響的行數(shù)

   */

  public function del($tName, $condition) {

    try {

      if (!is_string($tName) || !is_string($condition))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName= $this->formatTabName($tName);

      $this->_sql = "DELETE FROM {$tName} WHERE {$condition}";

      $row = $this->_db->exec($this->_sql);

      return $row;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 返回表總個(gè)數(shù)

   * @param string $tName 表名

   * @param string $condition 條件

   * @return int

   */

  public function total($tName, $condition='') {

    try {

      if (!is_string($tName))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $this->_sql = "SELECT COUNT(*) AS total FROM {$tName}" .

      ($condition=='' ? '' : ' WHERE ' . $condition);

      $re = $this->_db->query($this->_sql);

      foreach ($re as $v) {

        $total = $v['total'];

      }

      return (int)$total;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 數(shù)據(jù)庫刪除多條數(shù)據(jù)

   * @param string $tName 表名

   * @param string $field 依賴字段

   * @param array $ids 刪除數(shù)組

   * @return int 受影響的行數(shù)

   */

  public function delMulti($tName, $field, $ids) {

    try {

      if (!is_string($tName) || !is_array($ids))

        exit($this->getError(__FUNCTION__, __LINE__));

      $delStr = '';

      $tName = $this->formatTabName($tName);

      $field = $this->formatTabName($field);

      foreach ($ids as $v) {

        $delStr .= $v . ',';

      }

      $delStr = rtrim($delStr, ',');

      $this->_sql = "DELETE FROM {$tName} WHERE {$field} IN ({$delStr})";

      $row = $this->_db->exec($this->_sql);

      return $row;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 獲取表格的最后主鍵（注：針對 INT 類型）

   * @param string $tName 表名

   * @return int

   */

  public function insertId($tName) {

    try {

      if (!is_string($tName))

        exit($this->getError(__FUNCTION__, __LINE__));

      $this->_sql = "SHOW TABLE STATUS LIKE '{$tName}'";

      $result = $this->_db->query($this->_sql);

      $insert_id = 0;

      foreach ($result as $v) {

        $insert_id = $v['Auto_increment'];

      }

      return (int)$insert_id;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 檢查數(shù)據(jù)是否已經(jīng)存在（依賴條件）

   * @param string $tName 表名

   * @param string $field 依賴的字段

   * @return bool

   */

  public function exists($tName, $condition) {

    try {

      if (!is_string($tName) || !is_string($condition))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$condition}";

      $result = $this->_db->query($this->_sql);

      foreach ($result as $v) {

         $b = $v['total'];

      }

      if ($b) {

        return true;

      } else {

        return false;

      }

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 檢查數(shù)據(jù)是否已經(jīng)存在（依賴 INT 主鍵）

   * @param string $tName 表名

   * @param string $primary 主鍵

   * @param int $id 主鍵值

   * @return bool

   */

  public function existsByPK($tName, $primary, $id) {

    try {

      if (!is_string($tName) || !is_string($primary)

      || !is_int($id))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$primary} = ". $id;

      $result = $this->_db->query($this->_sql);

      foreach ($result as $v) {

         $b = $v['total'];

      }

      if ($b) {

        return true;

      } else {

        return false;

      }

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 預(yù)處理刪除（注：針對主鍵為 INT 類型，推薦使用）

   * @param string $tName 表名

   * @param string $primary 主鍵字段

   * @param int or array or string $ids 如果是刪除一條為 INT，多條為 array，刪除一個(gè)范圍為 string

   * @return int 返回受影響的行數(shù)

   */

  public function delByPK($tName, $primary, $ids, $mult=FALSE) {

    try {

      if (!is_string($tName) || !is_string($primary)

      || (!is_int($ids) && !is_array($ids) && !is_string($ids))

      || !is_bool($mult)) exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $stmt = $this->_db->prepare("DELETE FROM {$tName} WHERE {$primary}=?");

      if (!$mult) {

        $stmt->bindParam(1, $ids);

        $row = $stmt->execute();

      } else {

        if (is_array($ids)) {

          $row = 0;

          foreach ($ids as $v) {

            $stmt->bindParam(1, $v);

            if ($stmt->execute()) {

              $row++;

            }

          }

        } elseif (is_string($ids)) {

          if (!strpos($ids, '-'))

            exit($this->getError(__FUNCTION__, __LINE__));

          $split = explode('-', $ids);

          if (count($split)!=2 || $split[0]>$split[1])

            exit($this->getError(__FUNCTION__, __LINE__));

          $i = null;

          $count = $split[1]-$split[0]+1;

          for ($i=0; $i<$count; $i++) {

            $idArr[$i] = $split[0]++;

          }

          $idStr = '';

          foreach ($idArr as $id) {

            $idStr .= $id . ',';

          }

          $idStr = rtrim($idStr, ',');

          $this->_sql ="DELETE FROM {$tName} WHERE {$primary} in ({$idStr})";

          $row = $this->_db->exec($this->_sql);

        }

      }

      return $row;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 返回單個(gè)字段數(shù)據(jù)或單條記錄

   * @param string $tName 表名

   * @param string $condition 條件

   * @param string or array $fields 返回的字段，默認(rèn)是*

   * @return string || array

   */

  public function getRow($tName, $condition='', $fields="*") {

    try {

      if (!is_string($tName) || !is_string($condition)

      || !is_string($fields) || empty($fields))

         exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $this->_sql = "SELECT {$fields} FROM {$tName} ";

      $this->_sql .= ($condition=='' ? '' : "WHERE {$condition}") . " LIMIT 1";

      $sth = $this->_db->prepare($this->_sql);

      $sth->execute();

      $result = $sth->fetch(PDO::FETCH_ASSOC);

      if ($fields === '*') {

        return $result;

      } else {

        return $result[$fields];

      }

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 返回多條數(shù)據(jù)

   * @param string $tName 表名

   * @param string $fields 返回字段，默認(rèn)為*

   * @param string $condition 條件

   * @param string $order 排序

   * @param string $limit 顯示個(gè)數(shù)

   * @return PDOStatement

   */

  public function getAll($tName, $fields='*', $condition='', $order='', $limit='') {

    try {

      if (!is_string($tName) || !is_string($fields)

      || !is_string($condition) || !is_string($order)

      || !is_string($limit))

        exit($this->getError(__FUNCTION__, __LINE__));

      $tName = $this->formatTabName($tName);

      $fields = ($fields=='*' || $fields=='') ? '*' : $fields;

      $condition = $condition=='' ? '' : " WHERE ". $condition ;

      $order = $order=='' ? '' : " ORDER BY ". $order;

      $limit = $limit=='' ? '' : " LIMIT ". $limit;

      $this->_sql = "SELECT {$fields} FROM {$tName} {$condition} {$order} {$limit}";

      $sth = $this->_db->prepare($this->_sql);

      $sth->execute();

      $result = $sth->fetchAll(PDO::FETCH_ASSOC);

      return $result;

    } catch (PDOException $e) {

      exit($e->getMessage());

    }

  }

  /**

   * 格式化數(shù)組（表結(jié)構(gòu)和值）

   * @param array $field

   * @param bool $isField

   * @return string

   */

  private function formatArr($field, $isField=TRUE) {

    if (!is_array($field)) exit($this->getError(__FUNCTION__, __LINE__));

    $fields = '';

    if ($isField) {

      foreach ($field as $v) {

        $fields .= '`'.$v.'`,';

      }

    } else {

      foreach ($field as $v) {

        $fields .= '\''.$v.'\''.',';

      }

    }

    $fields = rtrim($fields, ',');

    return $fields;

  }

  /**

   * 格式化問號

   * @param int $count 數(shù)量

   * @return string 返回格式化后的字符串

   */

  private function formatMark($count) {

    $str = '';

    if (!is_int($count)) exit($this->getError(__FUNCTION__, __LINE__));

    if ($count==1) return '?';

    for ($i=0; $i<$count; $i++) {

      $str .= '?,';

    }

    return rtrim($str, ',');

  }

  /**

   * 錯(cuò)誤提示

   * @param string $fun

   * @return string

   */

  private function getError($fun, $line) {

    return __CLASS__ . '->' . $fun . '() line<font color="red">'. $line .'</font> ERROR!';

  }

  /**

   * 處理表名

   * @param string $tName

   * @return string

   */

  private function formatTabName($tName) {

    return '`' . trim($tName, '`') . '`';

  }

  /**

   * 析構(gòu)方法

   */

  public function __destruct() {

    $this->_db = null;

  }

}

希望本文所述對大家PHP程序設(shè)計(jì)有所幫助。