php基于PDO实现功能强大的MYSQL封装类实例

本文实例讲述了php基于PDO实现功能强大的MYSQL封装类。分享给大家供大家参考，具体如下：c

本文实例讲述了php基于PDO实现功能强大的MYSQL封装类。分享给大家供大家参考，具体如下：

class CPdo{
 protected $_dsn = "mysql:host=localhost;dbname=test";
 protected $_name = "root";
 protected $_pass = "";
 protected $_condition = array();
 protected $pdo;
 protected $fetchAll;
 protected $query;
 protected $result;
 protected $num;
 protected $mode;
 protected $prepare;
 protected $row;
 protected $fetchAction;
 protected $beginTransaction;
 protected $rollback;
 protected $commit;
 protected $char;
 private static $get_mode;
 private static $get_fetch_action;
 /**
 *pdo construct
 */
 public function __construct($pconnect = false) {
 $this->_condition = array(PDO::ATTR_PERSISTENT => $pconnect);
 $this->pdo_connect();
 }
 /**
 *pdo connect
 */
 private function pdo_connect() {
 try{
 $this->pdo = new PDO($this->_dsn,$this->_name,$this->_pass,$this->_condition);
 }
 catch(Exception $e) {
 return $this->setExceptionError($e->getMessage(), $e->getline, $e->getFile);
 }
 }
 /**
 *self sql get value action
 */
 public function getValueBySelfCreateSql($sql, $fetchAction = "assoc",$mode = null) {
 $this->fetchAction = $this->fetchAction($fetchAction);
 $this->result = $this->setAttribute($sql, $this->fetchAction, $mode);
 $this->AllValue = $this->result->fetchAll();
 return $this->AllValue;
 }
 /**
 *select condition can query
 */
 private function setAttribute($sql, $fetchAction, $mode) {
 $this->mode = self::getMode($mode);
 $this->fetchAction = self::fetchAction($fetchAction);
 $this->pdo->setAttribute(PDO::ATTR_CASE, $this->mode);
 $this->query = $this->base_query($sql);
 $this->query->setFetchMode($this->fetchAction);
 return $this->query;
 }
 /**
 *get mode action
 */
 private static function getMode($get_style){
 switch($get_style) {
 case null:
 self::$get_mode = PDO::CASE_NATURAL;
 break;
 case true:
 self::$get_mode = PDO::CASE_UPPER;
 break;
 case false;
 self::$get_mode= PDO::CASE_LOWER;
 break;
 }
 return self::$get_mode;
 }
 /**
 *fetch value action
 */
 private static function fetchAction($fetchAction) {
 switch($fetchAction) {
 case "assoc":
 self::$get_fetch_action = PDO::FETCH_ASSOC; //asso array
 break;
 case "num":
 self::$get_fetch_action = PDO::FETCH_NUM; //num array
 break;
 case "object":
 self::$get_fetch_action = PDO::FETCH_OBJ; //object array
 break;
 case "both":
 self::$get_fetch_action = PDO::FETCH_BOTH; //assoc array and num array
 break;
 default:
 self::$get_fetch_action = PDO::FETCH_ASSOC;
 break;
 }
 return self::$get_fetch_action;
 }
 /**
 *get total num action
 */
 public function rowCount($sql) {
 $this->result = $this->base_query($sql);
 $this->num = $this->result->rowCount();
 return $this->num;
 }
 /*
 *simple query and easy query action
 */
 public function query($table, $column = "*",$condition = array(), $group = "",$order = "", $having = "", $startSet = "",$endSet = "",$fetchAction = "assoc",$params = null){
 $sql = "select ".$column." from `".$table."` ";
 if ($condition != null) {
 foreach($condition as $key=>$value) {
 $where .= "$key = '$value' and ";
 }
 $sql .= "where $where";
 $sql .= "1 = 1 ";
 }
 if ($group != "") {
 $sql .= "group by ".$group." ";
 }
 if ($order != "") {
 $sql .= " order by ".$order." ";
 }
 if ($having != "") {
 $sql .= "having '$having' ";
 }
 if ($startSet != "" && $endSet != "" && is_numeric($endSet) && is_numeric($startSet)) {
 $sql .= "limit $startSet,$endSet";
 }
 $this->result = $this->getValueBySelfCreateSql($sql, $fetchAction, $params);
 return $this->result;
 }
 /**
 *execute delete update insert and so on action
 */
 public function exec($sql) {
 $this->result = $this->pdo->exec($sql);
 $substr = substr($sql, 0 ,6);
 if ($this->result) {
 return $this->successful($substr);
 } else {
 return $this->fail($substr);
 }
 }
 /**
 *prepare action
 */
 public function prepare($sql) {
 $this->prepare = $this->pdo->prepare($sql);
 $this->setChars();
 $this->prepare->execute();
 while($this->rowz = $this->prepare->fetch()) {
 return $this->row;
 }
 }
 /**
 *USE transaction
 */
 public function transaction($sql) {
 $this->begin();
 $this->result = $this->pdo->exec($sql);
 if ($this->result) {
 $this->commit();
 } else {
 $this->rollback();
 }
 }
 /**
 *start transaction
 */
 private function begin() {
 $this->beginTransaction = $this->pdo->beginTransaction();
 return $this->beginTransaction;
 }
 /**
 *commit transaction
 */
 private function commit() {
 $this->commit = $this->pdo->commit();
 return $this->commit;
 }
 /**
 *rollback transaction
 */
 private function rollback() {
 $this->rollback = $this->pdo->rollback();
 return $this->rollback;
 }
 /**
 *base query
 */
 private function base_query($sql) {
 $this->setChars();
 $this->query = $this->pdo->query($sql);
 return $this->query;
 }
 /**
 *set chars
 */
 private function setChars() {
 $this->char = $this->pdo->query("SET NAMES 'UTF8'");
 return $this->char;
 }
 /**
 *process sucessful action 
 */
 private function successful($params){
 return "The ".$params." action is successful";
 }
 /**
 *process fail action
 */
 private function fail($params){
 return "The ".$params." action is fail";
 }
 /**
 *process exception action
 */
 private function setExceptionError($getMessage, $getLine ,$getFile) {
 echo "Error message is ".$getMessage."<br /> The Error in ".$getLine." line <br /> This file dir on ".$getFile;
 exit();
 }
}