首頁 php教程 php手册 封装了一个PDO的类,希望CSDN的大牛们指导一下不足之处

封装了一个PDO的类,希望CSDN的大牛们指导一下不足之处

Jun 06, 2016 pm 07:43 PM
pdo 一下 大牛 指導

封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处 封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处。 大师们,comeon! ?php /** *PDO封装类,目的是为了使用起来更简单方便 *modifyDate:2014-07-01 */ classPDOX{ private$pdo=null; public$statem

封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处
封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处。

大师们,come on !

<?php<br />
/**<br />
 * PDO封装类,目的是为了使用起来更简单方便<br />
 * modify Date: 2014-07-01<br />
 */<br />
class PDOX {<br />
	private $pdo 	   = null;<br />
	<br />
	public  $statement = null;<br />
	<br />
	public  $options = array(<br />
		PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES ",<br />
	);<br />
	<br />
	public function __construct($dsn, $user = '', $pass = '', $persistent = false, $charset = "utf8"){<br />
		$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] .= $charset;<br />
		if($persistent){<br />
			$this->options[PDO::ATTR_PERSISTENT] = true;<br />
		}<br />
		$this->pdo = new PDO($dsn, $user, $pass, $this->options);<br />
	}<br />
	/**<br />
	全局属性设置,包括:列名格式和错误提示类型    可以使用数字也能直接使用参数<br />
	*/<br />
	public function setAttr($param, $val = ''){<br />
		if(is_array($param)){<br />
			foreach($param as $key => $val){<br />
				$this->pdo->setAttribute($key, $val);<br />
			}<br />
		}else{<br />
			if($val != '' ){<br />
				$this->pdo->setAttribute($param, $val);<br />
			}else{<br />
				return false;<br />
			}<br />
		}<br />
	}<br />
	/**<br />
	生成一个编译好的sql语句模版 你可以使用 ? :name 的形式<br />
	返回一个statement对象<br />
	*/<br />
	public function prepare($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		return $this->statement;<br />
	}<br />
	/**<br />
	执行Sql语句,一般用于 增、删、更新或者设置  返回影响的行数<br />
	*/<br />
	public function exec($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		try{<br />
			return $this->pdo->exec($sql);<br />
		}catch(Exception $e){<br />
			return $e->getMessage();<br />
		}<br />
	}<br />
	/**<br />
	执行有返回值的查询,返回PDOStatement  可以通过链式操作,可以通过这个类封装的操作获取数据<br />
	*/<br />
	public function query($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->query($sql);<br />
		return $this->statement;<br />
	}<br />
	/**<br />
	开启事务<br />
	*/<br />
	public function beginTransaction(){<br />
		return $this->pdo->beginTransaction();<br />
	}<br />
	/**<br />
	提交事务<br />
	*/<br />
	public function commit(){<br />
		return $this->pdo->commit();<br />
	}<br />
	/**<br />
	事务回滚<br />
	*/<br />
	public function rollBack(){<br />
		return $this->pdo->rollBack();<br />
	}<br />
	<br />
	public function lastInertId(){<br />
		return $this->pdo->lastInsertId();<br />
	}<br />
	<br />
	<br />
	//**   PDOStatement 类操作封装    **//<br />
	<br />
	/**<br />
	让模版执行SQL语句,1、执行编译好的 2、在执行时编译<br />
	*/<br />
	public function execute($param = ""){<br />
		if(is_array($param)){<br />
			try{<br />
				return $this->statement->execute($param);<br />
			}catch (Exception $e){<br />
				//return $this->errorInfo();<br />
				return $e->getMessage();<br />
			}<br />
		}else{<br />
			try{<br />
				return $this->statement->execute();<br />
			}catch(Exception $e){<br />
				/* 返回的错误信息格式<br />
				[0] => 42S22<br />
    			[1] => 1054<br />
    			[2] => Unknown column 'col' in 'field list'<br />
    			return $this->errorInfo();<br />
    			*/<br />
				return $e->getMessage();<br />
			}<br />
		}<br />
	}<br />
	<br />
	/**<br />
	参数1说明:<br />
	PDO::FETCH_BOTH		也是默认的,两者都有(索引,关联)<br />
	PDO::FETCH_ASSOC	关联数组<br />
	PDO::FETCH_NUM		索引<br />
	PDO::FETCH_OBJ			对象<br />
	PDO::FETCH_LAZY		对象 会附带queryString查询SQL语句<br />
	PDO::FETCH_BOUND	如果设置了bindColumn,则使用该参数<br />
	*/<br />
	public function fetch($fetch_type = PDO::FETCH_ASSOC){<br />
		if(is_object($this->statement)){<br />
			return $this->statement->fetch($fetch_type);<br />
		}<br />
		return false;<br />
	}<br />
	/**<br />
	参数1说明:<br />
	PDO::FETCH_BOTH		也是默认的,两者都有(索引,关联)<br />
	PDO::FETCH_ASSOC	关联数组<br />
	PDO::FETCH_NUM		索引<br />
	PDO::FETCH_OBJ		对象<br />
	PDO::FETCH_COLUMN	指定列 参数2可以指定要获取的列<br />
	PDO::FETCH_CLASS	指定自己定义的类<br />
	PDO::FETCH_FUNC		自定义类 处理返回的数据<br />
	PDO_FETCH_BOUND	如果你需要设置bindColumn,则使用该参数<br />
	参数2说明:<br />
	给定要处理这个结果的类或函数<br />
	*/<br />
	public function fetchAll($fetch_type = PDO::FETCH_ASSOC, $handle = ''){<br />
		if(empty($handle)){<br />
			return $this->statement->fetchAll($fetch_type);<br />
		}<br />
		return $this->statement->fetchAll($fetch_type, $handle);<br />
	}<br />
	/**<br />
	以对象形式返回 结果 跟fetch(PDO::FETCH_OBJ)一样<br />
	*/<br />
	public function fetchObject($class_name){<br />
		if(empty($clss_name)){<br />
			return $this->statement->fetchObject();<br />
		}<br />
		return $this->statement->fetchObject($class_name);<br />
	}<br />
	<br />
	public function fetchColumn($intColumn = 0){<br />
		return $this->statement->fetchColumn($intColumn);<br />
	}<br />
	<br />
	/**<br />
	public function bindColumn($array=array(),$type=EXTR_OVERWRITE){<br />
		if(count($array)>0){<br />
			extract($array,$type);<br />
		}<br />
		//$this->statement->bindColumn()<br />
	}<br />
	*/<br />
	<br />
	/**<br />
	以引用的方式绑定变量到占位符(可以只执行一次prepare,执行多次bindParam达到重复使用的效果)<br />
	*/<br />
	public function bindParam($parameter, $variable, $data_type = 'STR', $length = 0){<br />
		switch ($data_type){<br />
			case  'STR':<br />
				$data_type = PDO::PARAM_STR;<br />
				break;<br />
			case 'INT':<br />
				$data_type = PDO::PARAM_INT;<br />
				break;<br />
			default :<br />
				$data_type = '';<br />
		【本文来自鸿网互联 (http://www.68idc.cn)】		break;<br />
		}<br />
		return $this->statement->bindParam($parameter, $variable, $data_type, $length);<br />
	}<br />
	<br />
	/**<br />
	返回statement记录集的行数<br />
	*/<br />
	public function rowCount(){<br />
		return $this->statement->rowCount();<br />
	}<br />
	public function count(){<br />
		return $this->statement->rowCount();<br />
	}<br />
	public function columnCount(){<br />
		$this->statement->execute();<br />
		return $this->statement->columnCount();<br />
	}<br />
	public function getColumnMeta($intColumn){<br />
		return $this->statement->getColumnMeta($intColumn);<br />
	}<br />
	<br />
	<br />
	/**<br />
	关闭<br />
	*/<br />
	public function close(){<br />
		return $this->statement->closeCursor();<br />
	}<br />
	<br />
	public function closeCursor(){<br />
		return $this->statement->closeCursor();<br />
	}<br />
	/**<br />
	返回错误信息也包括错误号<br />
	*/<br />
	private function errorInfo(){<br />
		return $this->statement->errorInfo();<br />
	}<br />
	/**<br />
	返回错误号<br />
	*/<br />
	private function errorCode(){<br />
		return $this->statement->errorCode();<br />
	}<br />
	<br />
	<br />
	<br />
	//简化操作<br />
	public function insert($table, $data){<br />
		if(!is_array($data)){<br />
			return false;<br />
		}<br />
		$cols = array();<br />
		$vals = array();<br />
		foreach($data as $key => $val){<br />
			$cols[] = $key;<br />
			$vals[] = "'" . $val . "'";<br />
		}<br />
		$sql  = "INSERT INTO {$table} (";<br />
		$sql .= implode(",", $cols) . ") VALUES (";		<br />
		$sql .= implode(",", $vals) . ")";<br />
		return $this->exec($sql);<br />
	}<br />
	public function insertBind($table, $arrayData){<br />
		if(!is_array($arrayData)){<br />
			return false;<br />
		}<br />
		$vals = array_keys($arrayData);<br />
		$cols = array();<br />
		/*<br />
		$arrayobject  = new  ArrayObject( $arrayData );<br />
		$iterator  	  =  $arrayobject->getIterator();<br />
		while($iterator->valid()) {<br />
			$vals[] =  ':' . $iterator->key() . '';<br />
			$iterator->next();<br />
		}<br />
		*/<br />
		$c	  = implode('', $vals);<br />
		$cols = array_filter(explode(':', $c));<br />
<br />
		$sql  = "INSERT INTO {$table} (";<br />
		$sql .= implode(",", $cols) . ") VALUES (";		<br />
		$sql .= implode(",", $vals) . ")";<br />
		<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayData);<br />
		return  $this->statement->rowCount();<br />
	}<br />
	<br />
	public function update($table, $data, $where){<br />
		if(!is_array($data)){<br />
			return false;<br />
		}<br />
		$set = array();<br />
		foreach($data as $key => $val){<br />
			$set[] = $key . "='" . $val  . "'";<br />
		}<br />
		$sql = "UPDATE {$table} SET ";<br />
		$sql .= implode(",", $set);<br />
		$sql .= " WHERE " . $where;<br />
		return $this->exec($sql);<br />
	}<br />
	public function updateBind($sql, $arrayWhere){<br />
		if(empty($sql) || !is_array($arrayWhere)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayWhere);<br />
		return $this->statement->rowCount();<br />
	}<br />
<br />
	<br />
	public function delete($table, $where){<br />
		if(empty($table) || empty($where)){<br />
			return false;<br />
		} <br />
		$sql = "DELETE FROM {$table} WHERE " . $where;<br />
		return $this->exec($sql);<br />
	}<br />
	public function deleteBind($sql, $arrayWhere){<br />
		if(empty($sql) || !is_array($arrayWhere)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayWhere);<br />
		return $this->statement->rowCount();<br />
	}<br />
}<br />
?>
登入後複製




毕竟在一个项目当中,不可能到处的写PDO自身的一些东西。也不要说PDO已经封装好了,无须再次封装之类的废话。
------解决思路----------------------
几点建议:
1、如果我
$db = new PDOX;
$a = $db->query($sql1);
$b = $db->query($sql2);
print_r($a->fetchall());
print_r($b->fetchall());
可以吗?显然是不可以的,因为
$this->statement = $this->pdo->query($sql);
前一次的查询结果被后一次的覆盖了
2、事务(Transaction)操作宜封装成整体,只传入一组 sql 而隐藏相关操作
3、没考虑使用存储过程
4、PDOX 可直接继承于 PDO 而无需抄写 PDO 已有方法


本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

PHP Fatal error: Call to undefined method PDO::prepare() in的解決方法 PHP Fatal error: Call to undefined method PDO::prepare() in的解決方法 Jun 22, 2023 pm 06:40 PM

PHP作為一種流行的Web開發語言,已經被使用很久了。 PHP中整合的PDO(PHP資料物件)類別是我們在開發Web應用程式過程中與資料庫互動的常用方法。但是,一些PHP開發者經常遇到的問題是,當使用PDO類別與資料庫互動時,他們會收到這樣的錯誤:PHPFatalerror:CalltoundefinedmethodPDO::prep

php如何使用PHP的PDO_PGSQL擴充? php如何使用PHP的PDO_PGSQL擴充? Jun 02, 2023 pm 06:10 PM

PHP作為一種流行的程式語言,在Web開發領域中有著廣泛的應用。其中,PHP的PDO_PGSQL擴展是一種常用的PHP擴展,它提供了與PostgreSQL資料庫的交互接口,可以實現PHP與PostgreSQL之間的資料傳輸和交互。本文將詳細介紹如何使用PHP的PDO_PGSQL擴充。一、什麼是PDO_PGSQL擴充? PDO_PGSQL是PHP的擴充庫,它

PHP和PDO: 如何執行批次插入和更新 PHP和PDO: 如何執行批次插入和更新 Jul 28, 2023 pm 07:41 PM

PHP和PDO:如何執行批次插入和更新導言:在使用PHP編寫資料庫相關的應用程式時,經常會遇到需要批次插入和更新資料的情況。傳統的做法是使用循環來執行多次資料庫操作,但這樣的方法效率較低。 PHP的PDO(PHPDataObject)提供了一種更有效率的方法來執行批次插入和更新操作,本文將介紹如何使用PDO來實現批次插入和更新。一、PDO簡介:PDO是PH

PHP和PDO: 如何進行分頁查詢和顯示數據 PHP和PDO: 如何進行分頁查詢和顯示數據 Jul 29, 2023 pm 04:10 PM

PHP和PDO:如何進行分頁查詢和顯示資料在開發網頁應用程式時,分頁查詢和顯示資料是一個非常常見的需求。透過分頁,我們可以一次顯示一定數量的數據,提高頁面載入速度和使用者體驗。在PHP中,使用PHP資料物件(PDO)函式庫可以輕鬆實現分頁查詢和顯示資料的功能。本文將介紹如何在PHP中使用PDO進行分頁查詢和顯示數據,並提供相應的程式碼範例。一、建立資料庫和資料表

PHP PDO 與 mysqli:比較和對比 PHP PDO 與 mysqli:比較和對比 Feb 19, 2024 pm 12:24 PM

PDOPDO是一個物件導向的資料庫存取抽象層,它為PHP提供了一個統一的接口,允許您使用相同的程式碼與不同的資料庫(如Mysql、postgresql、oracle)進行互動。 PDO隱藏了底層資料庫連線的複雜性,簡化了資料庫操作。優缺點優點:統一接口,支援多種資料庫簡化資料庫操作,降低開發難度提供預處理語句,提高安全性支援事務處理缺點:效能可能比原生擴充稍低依賴外部函式庫,可能會增加開銷演示程式碼使用PDO連線mysql資料庫:$db=newPDO("mysql:host=localhost;dbnam

PHP和PDO: 如何處理資料庫中的JSON數據 PHP和PDO: 如何處理資料庫中的JSON數據 Jul 29, 2023 pm 05:17 PM

PHP和PDO:如何處理資料庫中的JSON資料在現代web開發中,處理和儲存大量資料是一個非常重要的任務。隨著行動應用和雲端運算的普及,越來越多的資料以JSON(JavaScriptObjectNotation)格式儲存在資料庫中。 PHP作為一種常用的伺服器端語言,它的PDO(PHPDataObject)擴充提供了一種方便的方式來處理和操作資料庫。本

PHP和PDO: 如何執行資料庫中的全文搜索 PHP和PDO: 如何執行資料庫中的全文搜索 Jul 30, 2023 pm 04:33 PM

PHP和PDO:如何執行資料庫中的全文搜尋在現代的Web應用程式中,資料庫是一個很重要的組成部分。當我們需要從大量的資料中搜尋特定的資訊時,全文搜尋是一種非常有用的功能。 PHP和PDO(PHPDataObjects)提供了一種簡單且強大的方法來執行資料庫中的全文搜尋。本文將介紹如何使用PHP和PDO來實現全文搜索,並提供一些範例程式碼來示範這個過程。首先

PHP和PDO: 如何執行資料庫備份和還原作業 PHP和PDO: 如何執行資料庫備份和還原作業 Jul 29, 2023 pm 06:54 PM

PHP和PDO:如何執行資料庫備份和還原作業在開發Web應用程式時,資料庫的備份和還原是非常重要的任務。 PHP作為一門流行的伺服器端腳本語言,提供了豐富的函式庫和擴展,其中PDO(PHP資料物件)是一款強大的資料庫存取抽象層。本文將介紹如何使用PHP和PDO來執行資料庫備份和還原作業。第一步:連接資料庫在實際操作之前,我們需要建立與資料庫的連線。使用PDO對

See all articles