搜索
首页后端开发php教程封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处

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

大师们,come on !

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




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


总的来说还不错,但感觉上有些方法过于细琐,可以有必要的整合在一起

几点建议:
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 已有方法


谢谢你的宝贵意见,我仅仅是想让它操作更简单化一点。
1、像你举的这个例子,可有解决方法。
2、事务我很少用到,也不知道该怎样封装。如果你能指点一下更好。
3、存储过程也很少用到。
4、抄写PDO的方法,只是想在使用上和PDO无异样,方便直接写PDO的朋友直接使用此类。无须过多的学习。不像其它的数据库类,在学完原生的数据库操作后,又要再次学习一个新的数据库操作,可能它很简单,但学习也是要时间的。



总的来说还不错,但感觉上有些方法过于细琐,可以有必要的整合在一起


请问怎样整合会更简洁此呢??

封装的目的是为了简化操作,不常用的就没有不要封装了

class PDOX extends PDO {  //执行各种 sql 指令,并可通过参数 $param 进行扩展  function query($sql, $param=null) {}  //查询并返回单条记录  function fetch($sql) {};  //查询并以数组方式返回多条记录  function fetchall($sql) {}}
数据库类只要有这三个方法就可满足绝大多数应用的需要了
由于是继承于 PDO,所以 PDO 原有的方法一个也不会少

@xuzuning

$db = new PDOX;
$a = $db->query($sql1);
$b = $db->query($sql2);
print_r($a->fetchall());
print_r($b->fetchall());

这种写法的程序员应该不多吧?如果这样的话,可以考虑先放弃这种操作支持。如果我的类在效率或者并发上有问题的话,这才是大问题。

这个类内部是否有错误或者不妥之处??

各位大牛,请多多发言。

嵌套甚至递归的查询在读取分类树时是经常用到的,怎么能说不多呢?
嗯,做个留言板是不需要的

简单的插入数据:
$data = array(':title'=>$title, ':content'=>$content);
$pdo  = new PDOX;
$lastID = $pdo->insertBind('article', $data);


修改数据:
$data = array(':title'=>$title, ':id'=>$id);
$sql   = 'update article set title=:title where id=:id';
$yesorno = $pdo->updateBind($sql, $data);

删除数据:
$data = array(':id'=>$id);
$sql   = 'delete article  where id=:id';
$yesorno = $pdo->deleteBind($sql, $data);

最主要的是这种写法,可以省下很多的代码量。这才是我写此类的关键。

嵌套甚至递归的查询在读取分类树时是经常用到的,怎么能说不多呢?
嗯,做个留言板是不需要的



你说的这个还真是,在递归中需要使用。想使用此类的朋友要注意了。

我会尽量优化PHP代码或者使用其它方法替代递归,因为递归有些耗资源。

谢谢你提醒。

表示看的挺纠结的

表示看的挺纠结的



杂纠结了???

我觉得在操作数据时挺方便的呀

大牛们,继续呀。。

封装的目的是为了简化操作,不常用的就没有不要封装了

class PDOX extends PDO {  //执行各种 sql 指令,并可通过参数 $param 进行扩展  function query($sql, $param=null) {}  //查询并返回单条记录  function fetch($sql) {};  //查询并以数组方式返回多条记录  function fetchall($sql) {}}
数据库类只要有这三个方法就可满足绝大多数应用的需要了
由于是继承于 PDO,所以 PDO 原有的方法一个也不会少



不知道版主可有更好的PDO操作类???
可否贡献一个。

不怎么样!
另外预处理部分没有封装

	/**	 * 将数组转换为SQL语句	 * @param array $where 要生成的数组	 * @param string $font 连接串。	 */	final public function sqls($where, $font = ' AND ') {				# 先将bindColumn存起来				$this->bindColumn = array();		if (is_array($where)) {			$sql = '';			foreach ($where as $key=>$val) {				$sql .= $sql ? " $font `$key` = :$key " : " `$key` = :$key";				$this->bindColumn = array($key, $val);			}			return ;		} else {			return $where;		}	}

声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
PHP的当前状态:查看网络开发趋势PHP的当前状态:查看网络开发趋势Apr 13, 2025 am 12:20 AM

PHP在现代Web开发中仍然重要,尤其在内容管理和电子商务平台。1)PHP拥有丰富的生态系统和强大框架支持,如Laravel和Symfony。2)性能优化可通过OPcache和Nginx实现。3)PHP8.0引入JIT编译器,提升性能。4)云原生应用通过Docker和Kubernetes部署,提高灵活性和可扩展性。

PHP与其他语言:比较PHP与其他语言:比较Apr 13, 2025 am 12:19 AM

PHP适合web开发,特别是在快速开发和处理动态内容方面表现出色,但不擅长数据科学和企业级应用。与Python相比,PHP在web开发中更具优势,但在数据科学领域不如Python;与Java相比,PHP在企业级应用中表现较差,但在web开发中更灵活;与JavaScript相比,PHP在后端开发中更简洁,但在前端开发中不如JavaScript。

PHP与Python:核心功能PHP与Python:核心功能Apr 13, 2025 am 12:16 AM

PHP和Python各有优势,适合不同场景。1.PHP适用于web开发,提供内置web服务器和丰富函数库。2.Python适合数据科学和机器学习,语法简洁且有强大标准库。选择时应根据项目需求决定。

PHP:网络开发的关键语言PHP:网络开发的关键语言Apr 13, 2025 am 12:08 AM

PHP是一种广泛应用于服务器端的脚本语言,特别适合web开发。1.PHP可以嵌入HTML,处理HTTP请求和响应,支持多种数据库。2.PHP用于生成动态网页内容,处理表单数据,访问数据库等,具有强大的社区支持和开源资源。3.PHP是解释型语言,执行过程包括词法分析、语法分析、编译和执行。4.PHP可以与MySQL结合用于用户注册系统等高级应用。5.调试PHP时,可使用error_reporting()和var_dump()等函数。6.优化PHP代码可通过缓存机制、优化数据库查询和使用内置函数。7

PHP:许多网站的基础PHP:许多网站的基础Apr 13, 2025 am 12:07 AM

PHP成为许多网站首选技术栈的原因包括其易用性、强大社区支持和广泛应用。1)易于学习和使用,适合初学者。2)拥有庞大的开发者社区,资源丰富。3)广泛应用于WordPress、Drupal等平台。4)与Web服务器紧密集成,简化开发部署。

超越炒作:评估当今PHP的角色超越炒作:评估当今PHP的角色Apr 12, 2025 am 12:17 AM

PHP在现代编程中仍然是一个强大且广泛使用的工具,尤其在web开发领域。1)PHP易用且与数据库集成无缝,是许多开发者的首选。2)它支持动态内容生成和面向对象编程,适合快速创建和维护网站。3)PHP的性能可以通过缓存和优化数据库查询来提升,其广泛的社区和丰富生态系统使其在当今技术栈中仍具重要地位。

PHP中的弱参考是什么?什么时候有用?PHP中的弱参考是什么?什么时候有用?Apr 12, 2025 am 12:13 AM

在PHP中,弱引用是通过WeakReference类实现的,不会阻止垃圾回收器回收对象。弱引用适用于缓存系统和事件监听器等场景,需注意其不能保证对象存活,且垃圾回收可能延迟。

解释PHP中的__ Invoke Magic方法。解释PHP中的__ Invoke Magic方法。Apr 12, 2025 am 12:07 AM

\_\_invoke方法允许对象像函数一样被调用。1.定义\_\_invoke方法使对象可被调用。2.使用$obj(...)语法时,PHP会执行\_\_invoke方法。3.适用于日志记录和计算器等场景,提高代码灵活性和可读性。

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
3 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
3 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
3 周前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解锁Myrise中的所有内容
4 周前By尊渡假赌尊渡假赌尊渡假赌

热工具

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver Mac版

Dreamweaver Mac版

视觉化网页开发工具

WebStorm Mac版

WebStorm Mac版

好用的JavaScript开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

mPDF

mPDF

mPDF是一个PHP库,可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件,并处理不同的语言。与原始脚本如HTML2FPDF相比,它的速度较慢,并且在使用Unicode字体时生成的文件较大,但支持CSS样式等,并进行了大量增强。支持几乎所有语言,包括RTL(阿拉伯语和希伯来语)和CJK(中日韩)。支持嵌套的块级元素(如P、DIV),