Community Learn Tools Library Leisure
search
English
Home > php教程 > php手册 > body text

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

WBOY
Release： 2016-06-06 19:43:14
Original
1128 people have browsed it

封装了一个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 />
?>
Copy after login




毕竟在一个项目当中，不可能到处的写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 已有方法


Related labels：
pdo one time large cow guide
source：php.cn
Previous article：php表单无法获取值,该如何解决 Next article：用tinkphp框架套模板时候。add页面出错，请帮小弟我看看哪个地方
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Latest Articles by Author
Latest Issues
Move the content to the left by adding the Width property I have provided margins to the body. main {left margin: 200px; right margin: 200px; text a...
From 2024-04-06 22:01:35
0
3
816
Where should I place CustomLog directive in apache I'm using php:7.2-apachedocker. I need to disable health check url login access log. Based...
From 2024-04-06 22:03:59
0
1
990
The page suddenly cannot pull css or bootstrap So I'm developing a page, I did part of it yesterday and it worked great, and today I cont...
From 2024-04-06 21:58:04
0
1
800
How to display only the lowest value from a result set (MYSQL) I have the following statement: selectDATE(recieved_on)asDay,round(count(*)/24)AS'average'...
From 2024-04-06 21:44:19
0
1
603
Sudoku checker not working? Can anyone help me identify the error? I tried everything on the online editor but still get the error. But when I do this on VSC...
From 2024-04-06 21:21:07
0
1
474
Related Topics
More>
Popular Recommendations
Popular Tutorials
More>
Related Tutorials
Popular Recommendations
Latest courses
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template