讲师中心 微信公众号
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机游戏
最近更新
首页 > php教程 > php手册 > 正文

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

php中文网
发布： 2016-06-06 19:43:14
原创
1373人浏览过

封装了一个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 已有方法


最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。

下载
来源：php中文网
收藏 点赞
上一篇：php表单无法获取值,该如何解决 下一篇：用tinkphp框架套模板时候。add页面出错，请帮小弟我看看哪个地方
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
最新问题
在python的开发过程中如何进行单链表的实现（代码） 本文介绍了如何实现单链表，希望大家耐心学习。
2018-09-15 09:33:11
11059
如何理解Elasticsearch单机双节点集群部署 这篇文章，我们还是做些基础的学习，在Elasticsearch如何进行CRUD。
2018-09-14 16:03:42
12926
如何理解关于memset函数 本文介绍了如何理解关于memset函数 ，希望大家耐心学习。
2018-09-14 15:27:49
5421
启动页进入时有短暂黑屏或白屏现象的终极解决方案 irontec 推出了一个开源项目 PHP for Android （PFA），把php带到Android平台上。现在我们来介绍一下。
2018-09-14 15:13:15
5495
如何把WebStorm上传代码到Git ​我是一名前端开发工程师。大概1年前开始使用webstorm这个编辑器，今天向大家介绍一下这个软件。
2018-09-14 14:49:20
6315
分布式系统唯一ID生成方案汇总 系统唯一ID是我们在设计一个系统的时候常常会遇见的问题，也常常为这个问题而纠结。生成ID的方法有很多，适应不同的场景、需求以及性能要求。所以有些比较复杂的系统会有多个ID生成的策略。下面就介绍一些常见的ID生成策略。
2018-09-14 13:39:20
5965
如何在远程过程调用（RPC） HTTP请求式 做过Socket编程的人都知道，当我们设计一个通信协议时，“消息头/消息体”的分割方式是很常用的，消息头告诉对方这个消息是干什么的，消息体告诉对方怎么干。
2018-09-14 11:44:18
4522
Visual Studio Code中安装go语言插件 PHP入门之语句，包括if语句、while语句、go语句，供PHP初学者参考。
2018-09-14 11:38:24
5353
详解Sublime Text 2 代码编辑器或者文本编辑器，对于程序员来说，就像剑与战士一样，谁都想拥有一把可以随心驾驭且锋利无比的宝剑，而每一位程序员，同样会去追求最适合自己的强大、灵活的编辑器，相信你和我一样，都不会例外。我用过的编辑器不少，真不少～ 但却没有哪款让我特别心仪的，直到我遇到了 Sublime Text 2 ！如果说“神器”是我能给予一款软件最高的评价，那么我很乐意为它封上这么一个称号。它小巧绿色且速度非常快
2018-06-11 16:24:34
2917
用CSS实现的一张图完成的按钮实例 用CSS实现的一张图完成的导航条ul,li{ list-style:non...
2018-05-09 20:23:31
2458
相关专题
更多>
热门推荐
开源免费商场系统广告
热门教程
更多>
相关推荐
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • PHP学习

  • 技术支持

  • 返回顶部